activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r775980 [1/4] - in /activemq/activemq-cpp/trunk/activemq-cpp/src: main/ main/activemq/cmsutil/ main/activemq/commands/ main/activemq/core/ main/activemq/transport/mock/ main/activemq/wireformat/openwire/ main/activemq/wireformat/stomp/ main...
Date Mon, 18 May 2009 15:13:33 GMT
Author: tabish
Date: Mon May 18 15:13:29 2009
New Revision: 775980

URL: http://svn.apache.org/viewvc?rev=775980&view=rev
Log:
Adds missing methods into the CMS API and adds default implementations in the ActiveMQ-CPP code for them that throw UnsupportedOperationExceptions.  Cleans up a bunch of code in preperation for the release, fixes warnings and removes debug code.

Added:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/StompHelper.cpp
      - copied, changed from r774862, activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/marshal/MarshalerHelper.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/StompHelper.h
      - copied, changed from r774862, activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/marshal/MarshalerHelper.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/IllegalStateException.cpp   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/IllegalStateException.h   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/InvalidClientIdException.cpp   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/InvalidClientIdException.h   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/InvalidDestinationException.cpp   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/InvalidDestinationException.h   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/InvalidSelectorException.cpp   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/InvalidSelectorException.h   (with props)
Removed:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/StompResponseBuilder.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/StompResponseBuilder.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/marshal/
Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedConsumer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedProducer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMessageTemplate.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQStreamMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionControl.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionError.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerControl.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ControlCommand.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataArrayResponse.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataResponse.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DestinationInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DiscoveryEvent.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ExceptionResponse.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/FlushCommand.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/IntegerResponse.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalQueueAck.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTopicAck.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTrace.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTransaction.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/KeepAliveInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LastPartialCommand.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LocalTransactionId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Message.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageAck.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatch.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatchNotification.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessagePull.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/NetworkBridgeFilter.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/PartialCommand.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerAck.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveSubscriptionInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ReplayCommand.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Response.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ShutdownInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SubscriptionInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/XATransactionId.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransportFactory.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/OpenWireFormat.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/StompFrame.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/StompFrame.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/StompWireFormat.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/stomp/StompWireFormat.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/BytesMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/CMSProperties.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/CMSSecurityException.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/CMSSecurityException.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Closeable.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Config.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Connection.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/ConnectionFactory.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/ConnectionMetaData.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/DeliveryMode.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Destination.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/ExceptionListener.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MapMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Message.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageConsumer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageEOFException.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageEOFException.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageFormatException.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageFormatException.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageListener.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageNotReadableException.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageNotReadableException.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageNotWriteableException.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageNotWriteableException.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageProducer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/ObjectMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Queue.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/QueueBrowser.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Session.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Startable.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Stoppable.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/StreamMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/TemporaryQueue.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/TemporaryTopic.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/TextMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Topic.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/internal/io/StandardInputStream.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/internal/nio/CharArrayBuffer.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/internal/util/HexStringParser.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/lang/Long.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/lang/Throwable.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/URL.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/concurrent/TimeUnit.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/concurrent/atomic/AtomicBoolean.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/TestRegistry.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/activemq/util/IntegrationCommon.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummyConsumer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummyMessage.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummyProducer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummySession.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/exceptions/ActiveMQExceptionTest.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/internal/nio/LongArrayBufferTest.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/net/URISyntaxExceptionTest.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am Mon May 18 15:13:29 2009
@@ -89,10 +89,13 @@
     decaf/io/BlockingByteArrayInputStream.cpp \
     decaf/io/DataInputStream.cpp \
     cms/MessageNotWriteableException.cpp \
+    cms/InvalidSelectorException.cpp \
+    cms/InvalidDestinationException.cpp \
     cms/CMSException.cpp \
     cms/CMSSecurityException.cpp \
     cms/MessageEOFException.cpp \
     cms/MessageNotReadableException.cpp \
+    cms/InvalidClientIdException.cpp \
     cms/MessageFormatException.cpp \
     activemq/transport/mock/MockTransportFactory.cpp \
     activemq/transport/mock/MockTransport.cpp \
@@ -309,10 +312,8 @@
     activemq/wireformat/openwire/utils/BooleanStream.cpp \
     activemq/wireformat/openwire/utils/HexTable.cpp \
     activemq/wireformat/openwire/OpenWireFormatNegotiator.cpp \
-    activemq/wireformat/stomp/StompResponseBuilder.cpp \
     activemq/wireformat/stomp/StompCommandConstants.cpp \
-    activemq/wireformat/stomp/marshal/Marshaler.cpp \
-    activemq/wireformat/stomp/marshal/MarshalerHelper.cpp \
+    activemq/wireformat/stomp/StompHelper.cpp \
     activemq/wireformat/stomp/StompFrame.cpp \
     activemq/wireformat/stomp/StompWireFormatFactory.cpp \
     activemq/wireformat/stomp/StompWireFormat.cpp \
@@ -603,11 +604,14 @@
     cms/QueueBrowser.h \
     cms/MessageEOFException.h \
     cms/TemporaryQueue.h \
+    cms/InvalidSelectorException.h \
     cms/MapMessage.h \
     cms/Connection.h \
     cms/ConnectionMetaData.h \
     cms/Message.h \
+    cms/InvalidDestinationException.h \
     cms/Session.h \
+    cms/InvalidClientIdException.h \
     cms/ExceptionListener.h \
     cms/Stoppable.h \
     cms/StreamMessage.h \
@@ -853,10 +857,8 @@
     activemq/wireformat/WireFormatNegotiator.h \
     activemq/wireformat/stomp/StompFrame.h \
     activemq/wireformat/stomp/StompCommandConstants.h \
-    activemq/wireformat/stomp/StompResponseBuilder.h \
     activemq/wireformat/stomp/StompWireFormatFactory.h \
-    activemq/wireformat/stomp/marshal/Marshaler.h \
-    activemq/wireformat/stomp/marshal/MarshalerHelper.h \
+    activemq/wireformat/stomp/StompHelper.h \
     activemq/wireformat/stomp/StompWireFormat.h \
     activemq/wireformat/WireFormatFactory.h \
     activemq/wireformat/MarshalAware.h \

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedConsumer.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedConsumer.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedConsumer.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedConsumer.h Mon May 18 15:13:29 2009
@@ -60,11 +60,11 @@
             return consumer->receiveNoWait();
         }
 
-        virtual void setMessageListener( cms::MessageListener* listener ) {
+        virtual void setMessageListener( cms::MessageListener* listener ) throw ( cms::CMSException ) {
             consumer->setMessageListener( listener );
         }
 
-        virtual cms::MessageListener* getMessageListener() const {
+        virtual cms::MessageListener* getMessageListener() const throw ( cms::CMSException ) {
             return consumer->getMessageListener();
         }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedProducer.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedProducer.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedProducer.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedProducer.h Mon May 18 15:13:29 2009
@@ -74,43 +74,43 @@
             producer->send( destination, message, deliveryMode, priority, timeToLive );
         }
 
-        virtual void setDeliveryMode( int mode ) {
+        virtual void setDeliveryMode( int mode ) throw ( cms::CMSException ) {
             producer->setDeliveryMode( mode );
         }
 
-        virtual int getDeliveryMode() const {
+        virtual int getDeliveryMode() const throw ( cms::CMSException ) {
             return producer->getDeliveryMode();
         }
 
-        virtual void setDisableMessageID( bool value ) {
+        virtual void setDisableMessageID( bool value ) throw ( cms::CMSException ) {
             producer->setDisableMessageID( value );
         }
 
-        virtual bool getDisableMessageID() const {
+        virtual bool getDisableMessageID() const throw ( cms::CMSException ) {
             return producer->getDisableMessageID();
         }
 
-        virtual void setDisableMessageTimeStamp( bool value ) {
+        virtual void setDisableMessageTimeStamp( bool value ) throw ( cms::CMSException ) {
             producer->setDisableMessageTimeStamp( value );
         }
 
-        virtual bool getDisableMessageTimeStamp() const {
+        virtual bool getDisableMessageTimeStamp() const throw ( cms::CMSException ) {
             return producer->getDisableMessageTimeStamp();
         }
 
-        virtual void setPriority( int priority ) {
+        virtual void setPriority( int priority ) throw ( cms::CMSException ) {
             producer->setPriority( priority );
         }
 
-        virtual int getPriority() const {
+        virtual int getPriority() const throw ( cms::CMSException ) {
             return producer->getPriority();
         }
 
-        virtual void setTimeToLive( long long time ) {
+        virtual void setTimeToLive( long long time ) throw ( cms::CMSException ) {
             producer->setTimeToLive( time );
         }
 
-        virtual long long getTimeToLive() const {
+        virtual long long getTimeToLive() const throw ( cms::CMSException ) {
             return producer->getTimeToLive();
         }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.cpp Mon May 18 15:13:29 2009
@@ -57,6 +57,20 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
+cms::QueueBrowser* PooledSession::createBrowser( const cms::Queue* queue )
+    throw( cms::CMSException ) {
+
+    return session->createBrowser( queue );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+cms::QueueBrowser* PooledSession::createBrowser( const cms::Queue* queue, const std::string& selector )
+    throw( cms::CMSException ) {
+
+    return session->createBrowser( queue, selector );
+}
+
+////////////////////////////////////////////////////////////////////////////////
 cms::MessageProducer* PooledSession::createCachedProducer(
         const cms::Destination* destination )
     throw ( cms::CMSException ) {

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.h Mon May 18 15:13:29 2009
@@ -86,6 +86,10 @@
             session->rollback();
         }
 
+        virtual void recover() throw( cms::CMSException ) {
+            session->recover();
+        }
+
         virtual cms::MessageConsumer* createConsumer(
             const cms::Destination* destination )
                 throw ( cms::CMSException ) {
@@ -153,6 +157,12 @@
         virtual cms::MessageProducer* createCachedProducer( const cms::Destination* destination )
             throw ( cms::CMSException );
 
+        virtual cms::QueueBrowser* createBrowser( const cms::Queue* queue )
+            throw( cms::CMSException );
+
+        virtual cms::QueueBrowser* createBrowser( const cms::Queue* queue, const std::string& selector )
+            throw( cms::CMSException );
+
         virtual cms::Queue* createQueue( const std::string& queueName )
             throw ( cms::CMSException ) {
             return session->createQueue( queueName );
@@ -210,11 +220,11 @@
             return session->createMapMessage();
         }
 
-        virtual cms::Session::AcknowledgeMode getAcknowledgeMode() const {
+        virtual cms::Session::AcknowledgeMode getAcknowledgeMode() const throw ( cms::CMSException ) {
             return session->getAcknowledgeMode();
         }
 
-        virtual bool isTransacted() const {
+        virtual bool isTransacted() const throw ( cms::CMSException ) {
             return session->isTransacted();
         }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.cpp Mon May 18 15:13:29 2009
@@ -90,7 +90,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-const unsigned char* ActiveMQBytesMessage::getBodyBytes() const {
+const unsigned char* ActiveMQBytesMessage::getBodyBytes() const throw ( cms::CMSException ) {
 
     try{
 
@@ -104,7 +104,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-std::size_t ActiveMQBytesMessage::getBodyLength() const {
+std::size_t ActiveMQBytesMessage::getBodyLength() const throw ( cms::CMSException ) {
 
     try{
         return getContent().size();

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQBytesMessage.h Mon May 18 15:13:29 2009
@@ -118,7 +118,7 @@
          * Clears out the body of the message.  This does not clear the
          * headers or properties.
          */
-        virtual void clearBody(){
+        virtual void clearBody() throw( cms::CMSException ) {
 
             // Invoke base class's version.
             ActiveMQMessageTemplate<cms::BytesMessage>::clearBody();
@@ -144,13 +144,13 @@
          * to expect.
          * @return const pointer to a byte buffer
          */
-        virtual const unsigned char* getBodyBytes() const;
+        virtual const unsigned char* getBodyBytes() const throw( cms::CMSException );
 
         /**
          * Returns the number of bytes contained in the body of this message.
          * @return number of bytes.
          */
-        virtual std::size_t getBodyLength() const;
+        virtual std::size_t getBodyLength() const throw( cms::CMSException );
 
         /**
          * Puts the message body in read-only mode and repositions the stream

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.cpp Mon May 18 15:13:29 2009
@@ -154,7 +154,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-std::vector<std::string> ActiveMQMapMessage::getMapNames() const {
+std::vector<std::string> ActiveMQMapMessage::getMapNames() const throw ( cms::CMSException ) {
 
     try{
         return getMap().keySet();
@@ -163,7 +163,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-bool ActiveMQMapMessage::itemExists( const std::string& name ) const {
+bool ActiveMQMapMessage::itemExists( const std::string& name ) const throw ( cms::CMSException ) {
 
     try{
         return getMap().containsKey( name );

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMapMessage.h Mon May 18 15:13:29 2009
@@ -118,14 +118,15 @@
          *         name of an item in the MapMessage
          * @throws CMSException
          */
-        virtual std::vector<std::string> getMapNames() const;
+        virtual std::vector<std::string> getMapNames() const throw( cms::CMSException );
 
         /**
          * Indicates whether an item exists in this MapMessage object.
          * @param name - String name of the Object in question
          * @return boolean value indicating if the name is in the map
+         * @throws CMSException
          */
-        virtual bool itemExists( const std::string& name ) const;
+        virtual bool itemExists( const std::string& name ) const throw( cms::CMSException );
 
         /**
          * Returns the Boolean value of the Specified name

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMessageTemplate.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMessageTemplate.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMessageTemplate.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQMessageTemplate.h Mon May 18 15:13:29 2009
@@ -61,7 +61,7 @@
          * Clears out the body of the message.  This does not clear the
          * headers or properties.
          */
-        virtual void clearBody() {
+        virtual void clearBody() throw( cms::CMSException ) {
             this->setContent( std::vector<unsigned char>() );
             this->setReadOnlyBody( false );
         }
@@ -70,7 +70,7 @@
          * Clears the message properties.  Does not clear the body or
          * header values.
          */
-        virtual void clearProperties() {
+        virtual void clearProperties() throw( cms::CMSException ) {
             this->getMessageProperties().clear();
             this->setReadOnlyProperties( false );
         }
@@ -80,7 +80,7 @@
          * @return The complete set of property names currently in this
          * message.
          */
-        virtual std::vector<std::string> getPropertyNames() const {
+        virtual std::vector<std::string> getPropertyNames() const throw( cms::CMSException ) {
             return getMessageProperties().keySet();
         }
 
@@ -89,7 +89,7 @@
          * @param name The name of the property to look up.
          * @return True if the property exists in this message.
          */
-        virtual bool propertyExists( const std::string& name ) const {
+        virtual bool propertyExists( const std::string& name ) const throw( cms::CMSException ) {
             return getMessageProperties().containsKey( name );
         }
 
@@ -353,7 +353,7 @@
          * Get the Correlation Id for this message
          * @return string representation of the correlation Id
          */
-        virtual std::string getCMSCorrelationID() const {
+        virtual std::string getCMSCorrelationID() const throw( cms::CMSException ) {
             return this->getCorrelationId();
         }
 
@@ -361,7 +361,7 @@
          * Sets the Correlation Id used by this message
          * @param correlationId - String representing the correlation id.
          */
-        virtual void setCMSCorrelationID( const std::string& correlationId ) {
+        virtual void setCMSCorrelationID( const std::string& correlationId ) throw( cms::CMSException ) {
             this->setCorrelationId( correlationId );
         }
 
@@ -369,7 +369,7 @@
          * Gets the DeliveryMode for this message
          * @return DeliveryMode enumerated value.
          */
-        virtual int getCMSDeliveryMode() const {
+        virtual int getCMSDeliveryMode() const throw( cms::CMSException ) {
             return this->isPersistent();
         }
 
@@ -377,7 +377,7 @@
          * Sets the DeliveryMode for this message
          * @param mode - DeliveryMode enumerated value.
          */
-        virtual void setCMSDeliveryMode( int mode ) {
+        virtual void setCMSDeliveryMode( int mode ) throw( cms::CMSException ) {
             this->setPersistent( mode == (int)cms::DeliveryMode::PERSISTENT );
         }
 
@@ -385,7 +385,7 @@
          * Gets the Destination for this Message, returns a
          * @return Destination object
          */
-        virtual const cms::Destination* getCMSDestination() const {
+        virtual const cms::Destination* getCMSDestination() const throw( cms::CMSException ) {
             return dynamic_cast<const cms::Destination*>( this->getDestination().get() );
         }
 
@@ -393,7 +393,8 @@
          * Sets the Destination for this message
          * @param destination - Destination Object
          */
-        virtual void setCMSDestination( const cms::Destination* destination ) {
+        virtual void setCMSDestination( const cms::Destination* destination )
+            throw( cms::CMSException ) {
 
             if( destination != NULL ) {
                 this->setDestination(
@@ -408,7 +409,7 @@
          * Gets the Expiration Time for this Message
          * @return time value
          */
-        virtual long long getCMSExpiration() const {
+        virtual long long getCMSExpiration() const throw( cms::CMSException ) {
             return this->getExpiration();
         }
 
@@ -416,7 +417,7 @@
          * Sets the Expiration Time for this message
          * @param expireTime - time value
          */
-        virtual void setCMSExpiration( long long expireTime ) {
+        virtual void setCMSExpiration( long long expireTime ) throw( cms::CMSException ) {
             this->setExpiration( expireTime );
         }
 
@@ -424,7 +425,7 @@
          * Gets the CMS Message Id for this Message
          * @return time value
          */
-        virtual std::string getCMSMessageID() const {
+        virtual std::string getCMSMessageID() const throw( cms::CMSException ) {
             return wireformat::openwire::marshal::BaseDataStreamMarshaller::toString( this->getMessageId().get() );
         }
 
@@ -432,13 +433,13 @@
          * Sets the CMS Message Id for this message
          * @param id - time value
          */
-        virtual void setCMSMessageID( const std::string& id AMQCPP_UNUSED) {}
+        virtual void setCMSMessageID( const std::string& id AMQCPP_UNUSED ) throw( cms::CMSException )  {}
 
         /**
          * Gets the Priority Value for this Message
          * @return priority value
          */
-        virtual int getCMSPriority() const {
+        virtual int getCMSPriority() const throw( cms::CMSException ) {
             return this->getPriority();
         }
 
@@ -446,7 +447,7 @@
          * Sets the Priority Value for this message
          * @param priority - priority value for this message
          */
-        virtual void setCMSPriority( int priority ) {
+        virtual void setCMSPriority( int priority ) throw( cms::CMSException ) {
             this->setPriority( priority );
         }
 
@@ -454,7 +455,7 @@
          * Gets the Redelivered Flag for this Message
          * @return redelivered value
          */
-        virtual bool getCMSRedelivered() const {
+        virtual bool getCMSRedelivered() const throw( cms::CMSException ) {
             return this->getRedeliveryCounter() != 0;
         }
 
@@ -462,13 +463,13 @@
          * Sets the Redelivered Flag for this message
          * @param redelivered - boolean redelivered value
          */
-        virtual void setCMSRedelivered( bool redelivered AMQCPP_UNUSED) {}
+        virtual void setCMSRedelivered( bool redelivered AMQCPP_UNUSED ) throw( cms::CMSException )  {}
 
         /**
          * Gets the CMS Reply To Address for this Message
          * @return Reply To Value
          */
-        virtual const cms::Destination* getCMSReplyTo() const {
+        virtual const cms::Destination* getCMSReplyTo() const throw( cms::CMSException ) {
             return dynamic_cast< const cms::Destination* >(
                 this->getReplyTo().get() );
         }
@@ -477,7 +478,7 @@
          * Sets the CMS Reply To Address for this message
          * @param id - Reply To value
          */
-        virtual void setCMSReplyTo( const cms::Destination* destination ) {
+        virtual void setCMSReplyTo( const cms::Destination* destination ) throw( cms::CMSException ) {
 
             if( destination != NULL ) {
                 this->setReplyTo(
@@ -492,7 +493,7 @@
          * Gets the Time Stamp for this Message
          * @return time stamp value
          */
-        virtual long long getCMSTimestamp() const {
+        virtual long long getCMSTimestamp() const throw( cms::CMSException ) {
             return this->getTimestamp();
         }
 
@@ -500,7 +501,7 @@
          * Sets the Time Stamp for this message
          * @param timeStamp - integer time stamp value
          */
-        virtual void setCMSTimestamp( long long timeStamp ) {
+        virtual void setCMSTimestamp( long long timeStamp ) throw( cms::CMSException ) {
             this->setTimestamp( timeStamp );
         }
 
@@ -508,7 +509,7 @@
          * Gets the CMS Message Type for this Message
          * @return type value
          */
-        virtual std::string getCMSType() const {
+        virtual std::string getCMSType() const throw( cms::CMSException ) {
             return this->getType();
         }
 
@@ -516,7 +517,7 @@
          * Sets the CMS Message Type for this message
          * @param type - message type value string
          */
-        virtual void setCMSType( const std::string& type ) {
+        virtual void setCMSType( const std::string& type ) throw( cms::CMSException ) {
             this->setType( type );
         }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQStreamMessage.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQStreamMessage.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQStreamMessage.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ActiveMQStreamMessage.h Mon May 18 15:13:29 2009
@@ -121,7 +121,7 @@
          * Clears out the body of the message.  This does not clear the
          * headers or properties.
          */
-        virtual void clearBody(){
+        virtual void clearBody() throw( cms::CMSException ) {
 
             // Invoke base class's version.
             ActiveMQMessageTemplate<cms::StreamMessage>::clearBody();

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerId.cpp Mon May 18 15:13:29 2009
@@ -39,13 +39,13 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-BrokerId::BrokerId() {
+BrokerId::BrokerId() : BaseDataStructure() {
 
     this->value = "";
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-BrokerId::BrokerId( const BrokerId& other ) {
+BrokerId::BrokerId( const BrokerId& other ) : BaseDataStructure() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/BrokerInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-BrokerInfo::BrokerInfo() {
+BrokerInfo::BrokerInfo() : BaseCommand() {
 
     this->brokerURL = "";
     this->brokerName = "";

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionControl.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionControl.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionControl.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionControl.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ConnectionControl::ConnectionControl() {
+ConnectionControl::ConnectionControl() : BaseCommand() {
 
     this->close = false;
     this->exit = false;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionError.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionError.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionError.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionError.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ConnectionError::ConnectionError() {
+ConnectionError::ConnectionError() : BaseCommand() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionId.cpp Mon May 18 15:13:29 2009
@@ -42,13 +42,13 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ConnectionId::ConnectionId() {
+ConnectionId::ConnectionId() : BaseDataStructure() {
 
     this->value = "";
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-ConnectionId::ConnectionId( const ConnectionId& other ) {
+ConnectionId::ConnectionId( const ConnectionId& other ) : BaseDataStructure() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConnectionInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ConnectionInfo::ConnectionInfo() {
+ConnectionInfo::ConnectionInfo() : BaseCommand() {
 
     this->clientId = "";
     this->password = "";

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerControl.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerControl.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerControl.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerControl.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ConsumerControl::ConsumerControl() {
+ConsumerControl::ConsumerControl() : BaseCommand() {
 
     this->close = false;
     this->prefetch = 0;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerId.cpp Mon May 18 15:13:29 2009
@@ -39,7 +39,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ConsumerId::ConsumerId() {
+ConsumerId::ConsumerId() : BaseDataStructure() {
 
     this->connectionId = "";
     this->sessionId = 0;
@@ -47,7 +47,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-ConsumerId::ConsumerId( const ConsumerId& other ) {
+ConsumerId::ConsumerId( const ConsumerId& other ) : BaseDataStructure() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ConsumerInfo::ConsumerInfo() {
+ConsumerInfo::ConsumerInfo() : BaseCommand() {
 
     this->browser = false;
     this->prefetchSize = 0;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ControlCommand.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ControlCommand.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ControlCommand.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ControlCommand.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ControlCommand::ControlCommand() {
+ControlCommand::ControlCommand() : BaseCommand() {
 
     this->command = "";
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataArrayResponse.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataArrayResponse.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataArrayResponse.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataArrayResponse.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-DataArrayResponse::DataArrayResponse() {
+DataArrayResponse::DataArrayResponse() : Response() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataResponse.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataResponse.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataResponse.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DataResponse.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-DataResponse::DataResponse() {
+DataResponse::DataResponse() : Response() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DestinationInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DestinationInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DestinationInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DestinationInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-DestinationInfo::DestinationInfo() {
+DestinationInfo::DestinationInfo() : BaseCommand() {
 
     this->operationType = 0;
     this->timeout = 0;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DiscoveryEvent.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DiscoveryEvent.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DiscoveryEvent.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/DiscoveryEvent.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-DiscoveryEvent::DiscoveryEvent() {
+DiscoveryEvent::DiscoveryEvent() : BaseDataStructure() {
 
     this->serviceName = "";
     this->brokerName = "";

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ExceptionResponse.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ExceptionResponse.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ExceptionResponse.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ExceptionResponse.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ExceptionResponse::ExceptionResponse() {
+ExceptionResponse::ExceptionResponse() : Response() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/FlushCommand.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/FlushCommand.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/FlushCommand.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/FlushCommand.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-FlushCommand::FlushCommand() {
+FlushCommand::FlushCommand() : BaseCommand() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/IntegerResponse.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/IntegerResponse.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/IntegerResponse.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/IntegerResponse.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-IntegerResponse::IntegerResponse() {
+IntegerResponse::IntegerResponse() : Response() {
 
     this->result = 0;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalQueueAck.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalQueueAck.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalQueueAck.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalQueueAck.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-JournalQueueAck::JournalQueueAck() {
+JournalQueueAck::JournalQueueAck() : BaseDataStructure() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTopicAck.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTopicAck.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTopicAck.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTopicAck.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-JournalTopicAck::JournalTopicAck() {
+JournalTopicAck::JournalTopicAck() : BaseDataStructure() {
 
     this->messageSequenceId = 0;
     this->subscritionName = "";

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTrace.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTrace.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTrace.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTrace.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-JournalTrace::JournalTrace() {
+JournalTrace::JournalTrace() : BaseDataStructure() {
 
     this->message = "";
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTransaction.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTransaction.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTransaction.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/JournalTransaction.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-JournalTransaction::JournalTransaction() {
+JournalTransaction::JournalTransaction() : BaseDataStructure() {
 
     this->type = 0;
     this->wasPrepared = false;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/KeepAliveInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/KeepAliveInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/KeepAliveInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/KeepAliveInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-KeepAliveInfo::KeepAliveInfo() {
+KeepAliveInfo::KeepAliveInfo() : BaseCommand() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LastPartialCommand.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LastPartialCommand.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LastPartialCommand.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LastPartialCommand.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-LastPartialCommand::LastPartialCommand() {
+LastPartialCommand::LastPartialCommand() : PartialCommand() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LocalTransactionId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LocalTransactionId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LocalTransactionId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/LocalTransactionId.cpp Mon May 18 15:13:29 2009
@@ -39,13 +39,13 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-LocalTransactionId::LocalTransactionId() {
+LocalTransactionId::LocalTransactionId() : TransactionId() {
 
     this->value = 0;
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-LocalTransactionId::LocalTransactionId( const LocalTransactionId& other ) {
+LocalTransactionId::LocalTransactionId( const LocalTransactionId& other ) : TransactionId() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Message.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Message.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Message.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Message.cpp Mon May 18 15:13:29 2009
@@ -40,7 +40,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-Message::Message() {
+Message::Message() : BaseCommand() {
 
     this->ackHandler = NULL;
     this->readOnlyBody = false;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageAck.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageAck.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageAck.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageAck.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-MessageAck::MessageAck() {
+MessageAck::MessageAck() : BaseCommand() {
 
     this->ackType = 0;
     this->messageCount = 0;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatch.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatch.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatch.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatch.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-MessageDispatch::MessageDispatch() {
+MessageDispatch::MessageDispatch() : BaseCommand() {
 
     this->redeliveryCounter = 0;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatchNotification.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatchNotification.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatchNotification.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageDispatchNotification.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-MessageDispatchNotification::MessageDispatchNotification() {
+MessageDispatchNotification::MessageDispatchNotification() : BaseCommand() {
 
     this->deliverySequenceId = 0;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessageId.cpp Mon May 18 15:13:29 2009
@@ -39,14 +39,14 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-MessageId::MessageId() {
+MessageId::MessageId() : BaseDataStructure() {
 
     this->producerSequenceId = 0;
     this->brokerSequenceId = 0;
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-MessageId::MessageId( const MessageId& other ) {
+MessageId::MessageId( const MessageId& other ) : BaseDataStructure() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessagePull.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessagePull.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessagePull.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/MessagePull.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-MessagePull::MessagePull() {
+MessagePull::MessagePull() : BaseCommand() {
 
     this->timeout = 0;
     this->correlationId = "";

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/NetworkBridgeFilter.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/NetworkBridgeFilter.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/NetworkBridgeFilter.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/NetworkBridgeFilter.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-NetworkBridgeFilter::NetworkBridgeFilter() {
+NetworkBridgeFilter::NetworkBridgeFilter() : BaseDataStructure() {
 
     this->networkTTL = 0;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/PartialCommand.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/PartialCommand.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/PartialCommand.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/PartialCommand.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-PartialCommand::PartialCommand() {
+PartialCommand::PartialCommand() : BaseDataStructure() {
 
     this->commandId = 0;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerAck.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerAck.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerAck.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerAck.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ProducerAck::ProducerAck() {
+ProducerAck::ProducerAck() : BaseCommand() {
 
     this->size = 0;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerId.cpp Mon May 18 15:13:29 2009
@@ -39,7 +39,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ProducerId::ProducerId() {
+ProducerId::ProducerId() : BaseDataStructure() {
 
     this->connectionId = "";
     this->value = 0;
@@ -47,7 +47,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-ProducerId::ProducerId( const ProducerId& other ) {
+ProducerId::ProducerId( const ProducerId& other ) : BaseDataStructure() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ProducerInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ProducerInfo::ProducerInfo() {
+ProducerInfo::ProducerInfo() : BaseCommand() {
 
     this->dispatchAsync = false;
     this->windowSize = 0;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-RemoveInfo::RemoveInfo() {
+RemoveInfo::RemoveInfo() : BaseCommand() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveSubscriptionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveSubscriptionInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveSubscriptionInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/RemoveSubscriptionInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-RemoveSubscriptionInfo::RemoveSubscriptionInfo() {
+RemoveSubscriptionInfo::RemoveSubscriptionInfo() : BaseCommand() {
 
     this->subcriptionName = "";
     this->clientId = "";

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ReplayCommand.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ReplayCommand.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ReplayCommand.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ReplayCommand.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ReplayCommand::ReplayCommand() {
+ReplayCommand::ReplayCommand() : BaseCommand() {
 
     this->firstNakNumber = 0;
     this->lastNakNumber = 0;

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Response.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Response.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Response.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/Response.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-Response::Response() {
+Response::Response() : BaseCommand() {
 
     this->correlationId = 0;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionId.cpp Mon May 18 15:13:29 2009
@@ -42,14 +42,14 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-SessionId::SessionId() {
+SessionId::SessionId() : BaseDataStructure() {
 
     this->connectionId = "";
     this->value = 0;
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-SessionId::SessionId( const SessionId& other ) {
+SessionId::SessionId( const SessionId& other ) : BaseDataStructure() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp Mon May 18 15:13:29 2009
@@ -39,7 +39,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-SessionInfo::SessionInfo() {
+SessionInfo::SessionInfo() : BaseCommand() {
 
     this->ackMode = (unsigned int)cms::Session::AUTO_ACKNOWLEDGE;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ShutdownInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ShutdownInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ShutdownInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ShutdownInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-ShutdownInfo::ShutdownInfo() {
+ShutdownInfo::ShutdownInfo() : BaseCommand() {
 
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SubscriptionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SubscriptionInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SubscriptionInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SubscriptionInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-SubscriptionInfo::SubscriptionInfo() {
+SubscriptionInfo::SubscriptionInfo() : BaseDataStructure() {
 
     this->clientId = "";
     this->selector = "";

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionId.cpp Mon May 18 15:13:29 2009
@@ -39,12 +39,12 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-TransactionId::TransactionId() {
+TransactionId::TransactionId() : BaseDataStructure() {
 
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-TransactionId::TransactionId( const TransactionId& other ) {
+TransactionId::TransactionId( const TransactionId& other ) : BaseDataStructure() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionInfo.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/TransactionInfo.cpp Mon May 18 15:13:29 2009
@@ -38,7 +38,7 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-TransactionInfo::TransactionInfo() {
+TransactionInfo::TransactionInfo() : BaseCommand() {
 
     this->type = 0;
 }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/XATransactionId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/XATransactionId.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/XATransactionId.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/XATransactionId.cpp Mon May 18 15:13:29 2009
@@ -39,13 +39,13 @@
  */
 
 ////////////////////////////////////////////////////////////////////////////////
-XATransactionId::XATransactionId() {
+XATransactionId::XATransactionId() : TransactionId() {
 
     this->formatId = 0;
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-XATransactionId::XATransactionId( const XATransactionId& other ) {
+XATransactionId::XATransactionId( const XATransactionId& other ) : TransactionId() {
     this->copyDataStructure( &other );
 }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp Mon May 18 15:13:29 2009
@@ -407,7 +407,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void ActiveMQConsumer::setMessageListener( cms::MessageListener* listener ) {
+void ActiveMQConsumer::setMessageListener( cms::MessageListener* listener ) throw ( cms::CMSException ) {
 
     try{
 
@@ -444,9 +444,7 @@
             }
         }
     }
-    AMQ_CATCH_RETHROW( ActiveMQException )
-    AMQ_CATCH_EXCEPTION_CONVERT( Exception, ActiveMQException )
-    AMQ_CATCHALL_THROW( ActiveMQException )
+    AMQ_CATCH_ALL_THROW_CMSEXCEPTION()
 }
 
 ////////////////////////////////////////////////////////////////////////////////

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.h Mon May 18 15:13:29 2009
@@ -196,13 +196,13 @@
          * Sets the MessageListener that this class will send notifs on
          * @param listener MessageListener interface pointer
          */
-        virtual void setMessageListener( cms::MessageListener* listener );
+        virtual void setMessageListener( cms::MessageListener* listener ) throw ( cms::CMSException );
 
         /**
          * Gets the MessageListener that this class will send notifs on
          * @param MessageListener interface pointer
          */
-        virtual cms::MessageListener* getMessageListener() const {
+        virtual cms::MessageListener* getMessageListener() const throw ( cms::CMSException ) {
             return this->listener;
         }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQProducer.h Mon May 18 15:13:29 2009
@@ -150,7 +150,7 @@
          * Sets the delivery mode for this Producer
          * @param The DeliveryMode
          */
-        virtual void setDeliveryMode( int mode ) {
+        virtual void setDeliveryMode( int mode ) throw ( cms::CMSException ){
             this->defaultDeliveryMode = mode;
         }
 
@@ -158,7 +158,7 @@
          * Gets the delivery mode for this Producer
          * @return The DeliveryMode
          */
-        virtual int getDeliveryMode() const {
+        virtual int getDeliveryMode() const throw ( cms::CMSException ) {
             return this->defaultDeliveryMode;
         }
 
@@ -166,7 +166,7 @@
          * Sets if Message Ids are disabled for this Producer
          * @param boolean indicating enable / disable (true / false)
          */
-        virtual void setDisableMessageID( bool value ) {
+        virtual void setDisableMessageID( bool value ) throw ( cms::CMSException ) {
             this->disableMessageId = value;
         }
 
@@ -174,7 +174,7 @@
          * Sets if Message Ids are disabled for this Producer
          * @param boolean indicating enable / disable (true / false)
          */
-        virtual bool getDisableMessageID() const {
+        virtual bool getDisableMessageID() const throw ( cms::CMSException ) {
             return this->disableMessageId;
         }
 
@@ -182,7 +182,7 @@
          * Sets if Message Time Stamps are disabled for this Producer
          * @param boolean indicating enable / disable (true / false)
          */
-        virtual void setDisableMessageTimeStamp( bool value ) {
+        virtual void setDisableMessageTimeStamp( bool value ) throw ( cms::CMSException ) {
             this->disableTimestamps = value;
         }
 
@@ -190,7 +190,7 @@
          * Sets if Message Time Stamps are disabled for this Producer
          * @param boolean indicating enable / disable (true / false)
          */
-        virtual bool getDisableMessageTimeStamp() const {
+        virtual bool getDisableMessageTimeStamp() const throw ( cms::CMSException ) {
             return this->disableTimestamps;
         }
 
@@ -198,7 +198,7 @@
          * Sets the Priority that this Producers sends messages at
          * @param int value for Priority level
          */
-        virtual void setPriority( int priority ) {
+        virtual void setPriority( int priority ) throw ( cms::CMSException ) {
             this->defaultPriority = priority;
         }
 
@@ -206,7 +206,7 @@
          * Gets the Priority level that this producer sends messages at
          * @return int based priority level
          */
-        virtual int getPriority() const {
+        virtual int getPriority() const throw ( cms::CMSException ) {
             return this->defaultPriority;
         }
 
@@ -214,7 +214,7 @@
          * Sets the Time to Live that this Producers sends messages with
          * @param time The new default time to live value in milliseconds.
          */
-        virtual void setTimeToLive( long long time ) {
+        virtual void setTimeToLive( long long time ) throw ( cms::CMSException ) {
             this->defaultTimeToLive = time;
         }
 
@@ -222,7 +222,7 @@
          * Gets the Time to Live that this producer sends messages with
          * @return The default time to live value in milliseconds.
          */
-        virtual long long getTimeToLive() const {
+        virtual long long getTimeToLive() const throw ( cms::CMSException ) {
             return this->defaultTimeToLive;
         }
 
@@ -230,7 +230,7 @@
          * Sets the Send Timeout that this Producers sends messages with
          * @param time The new default send timeout value in milliseconds.
          */
-        virtual void setSendTimeout( long long time ) {
+        virtual void setSendTimeout( long long time ) throw ( cms::CMSException ) {
             this->sendTimeout = time;
         }
 
@@ -238,7 +238,7 @@
          * Gets the Send Timeout that this producer sends messages with
          * @return The default send timeout value in milliseconds.
          */
-        virtual long long getSendTimeout() const {
+        virtual long long getSendTimeout() const throw ( cms::CMSException ) {
             return this->sendTimeout;
         }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp?rev=775980&r1=775979&r2=775980&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp Mon May 18 15:13:29 2009
@@ -202,6 +202,18 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
+void ActiveMQSession::recover() throw( cms::CMSException ) {
+
+    try{
+
+        throw UnsupportedOperationException(
+            __FILE__, __LINE__,
+            "Recover Method is not yet supported." );
+    }
+    AMQ_CATCH_ALL_THROW_CMSEXCEPTION()
+}
+
+////////////////////////////////////////////////////////////////////////////////
 void ActiveMQSession::clearMessagesInProgress() {
 
     if( this->executor.get() != NULL ) {
@@ -412,6 +424,33 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
+cms::QueueBrowser* ActiveMQSession::createBrowser( const cms::Queue* queue AMQCPP_UNUSED )
+    throw( cms::CMSException ) {
+
+    try{
+
+        throw UnsupportedOperationException(
+            __FILE__, __LINE__,
+            "createBrowser Method is not yet supported." );
+    }
+    AMQ_CATCH_ALL_THROW_CMSEXCEPTION()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+cms::QueueBrowser* ActiveMQSession::createBrowser( const cms::Queue* queue AMQCPP_UNUSED,
+                                                   const std::string& selector AMQCPP_UNUSED )
+    throw( cms::CMSException ) {
+
+    try{
+
+        throw UnsupportedOperationException(
+            __FILE__, __LINE__,
+            "createBrowser Method is not yet supported." );
+    }
+    AMQ_CATCH_ALL_THROW_CMSEXCEPTION()
+}
+
+////////////////////////////////////////////////////////////////////////////////
 cms::Queue* ActiveMQSession::createQueue( const std::string& queueName )
     throw ( cms::CMSException ) {
 
@@ -576,12 +615,12 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-cms::Session::AcknowledgeMode ActiveMQSession::getAcknowledgeMode() const {
+cms::Session::AcknowledgeMode ActiveMQSession::getAcknowledgeMode() const throw ( cms::CMSException ) {
     return this->ackMode;
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-bool ActiveMQSession::isTransacted() const {
+bool ActiveMQSession::isTransacted() const throw ( cms::CMSException ) {
     return this->ackMode == Session::SESSION_TRANSACTED;
 }
 



Mime
View raw message