this->clientAck = clientAck;
}
- virtual ~SimpleAsyncConsumer(){
+ virtual ~SimpleAsyncConsumer() throw() {
this->cleanup();
}
}
// Called from the consumer since this class is a registered MessageListener.
- virtual void onMessage( const Message* message ){
+ virtual void onMessage( const Message* message ) throw() {
static int count = 0;
fflush(outputfile);
} catch (CMSException& e) {
e.printStackTrace();
+ } catch (Exception& e) {
+ e.printStackTrace();
+ } catch (...) {
+ fprintf(stderr, "Unknown Exception occurred.\n");
}
}