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");
                }
        }