activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1094010 - in /activemq/activemq-cpp/trunk/activemq-cpp/src: main/activemq/cmsutil/ main/activemq/core/ main/cms/ test/activemq/cmsutil/
Date Sat, 16 Apr 2011 15:47:07 GMT
Author: tabish
Date: Sat Apr 16 15:47:06 2011
New Revision: 1094010

URL: http://svn.apache.org/viewvc?rev=1094010&view=rev
Log: (empty)

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/CachedConsumer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/cmsutil/PooledSession.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageConsumer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Session.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummyConsumer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummySession.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=1094010&r1=1094009&r2=1094010&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 Sat
Apr 16 15:47:06 2011
@@ -52,6 +52,14 @@ namespace cmsutil {
             // Do nothing.
         }
 
+        virtual void start() {
+            consumer->start();
+        }
+
+        virtual void stop() {
+            consumer->stop();
+        }
+
         virtual cms::Message* receive() {
             return consumer->receive();
         }

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=1094010&r1=1094009&r2=1094010&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 Sat
Apr 16 15:47:06 2011
@@ -85,6 +85,14 @@ namespace cmsutil {
          */
         virtual void close();
 
+        virtual void start() {
+            session->start();
+        }
+
+        virtual void stop() {
+            session->stop();
+        }
+
         virtual void commit() {
             session->commit();
         }

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.h?rev=1094010&r1=1094009&r2=1094010&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.h Sat
Apr 16 15:47:06 2011
@@ -151,12 +151,12 @@ namespace core{
         /**
          * Stops asynchronous message delivery.
          */
-        void start();
+        virtual void start();
 
         /**
          * Starts asynchronous message delivery.
          */
-        void stop();
+        virtual void stop();
 
         /**
          * Indicates whether or not the session is currently in the started

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageConsumer.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageConsumer.h?rev=1094010&r1=1094009&r2=1094010&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageConsumer.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/MessageConsumer.h Sat Apr 16 15:47:06
2011
@@ -22,6 +22,8 @@
 #include <cms/MessageListener.h>
 #include <cms/Message.h>
 #include <cms/Closeable.h>
+#include <cms/Startable.h>
+#include <cms/Stoppable.h>
 
 namespace cms{
 
@@ -47,11 +49,15 @@ namespace cms{
      * operation completes.  A blocked consumer in a <code>receive</code> call
will
      * return a Null when the close method is called.
      *
+     * While the MessageConsumer implements the Startable and Stoppable interfaces it is
+     * not required to implement these methods and can throw an UnsupportedOperation
+     * exception if they are not available for the given CMS provider.
+     *
      * @see MessageListener
      *
      * @since 1.0
      */
-    class CMS_API MessageConsumer : public Closeable {
+    class CMS_API MessageConsumer : public Closeable, public Startable, public Stoppable
{
     public:
 
         virtual ~MessageConsumer() throw();

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Session.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Session.h?rev=1094010&r1=1094009&r2=1094010&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Session.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/cms/Session.h Sat Apr 16 15:47:06 2011
@@ -19,6 +19,8 @@
 
 #include <cms/Config.h>
 #include <cms/Closeable.h>
+#include <cms/Startable.h>
+#include <cms/Stoppable.h>
 #include <cms/Message.h>
 #include <cms/TextMessage.h>
 #include <cms/BytesMessage.h>
@@ -92,9 +94,13 @@ namespace cms{
      * being redelivered to the client, the Provider may allow configuration that limits
the
      * Maximum number of redeliveries for a Message.
      *
+     * While the Session interface implements the Startable and Stoppable interfaces it is
+     * not required to implement these methods and can throw an UnsupportedOperation
+     * exception if they are not available for the given CMS provider.
+     *
      * @since 1.0
      */
-    class CMS_API Session : public Closeable {
+    class CMS_API Session : public Closeable, public Startable, public Stoppable {
     public:
 
         enum AcknowledgeMode {

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummyConsumer.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummyConsumer.h?rev=1094010&r1=1094009&r2=1094010&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummyConsumer.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummyConsumer.h Sat
Apr 16 15:47:06 2011
@@ -43,7 +43,11 @@ namespace cmsutil {
         }
         virtual ~DummyConsumer() throw() {}
 
-        virtual void close() throw( cms::CMSException ){}
+        virtual void close() {}
+
+        virtual void start() {}
+
+        virtual void stop() {}
 
         virtual cms::Message* receive() throw ( cms::CMSException ) {
             return messageContext->receive(dest, selector, noLocal, 0);

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummySession.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummySession.h?rev=1094010&r1=1094009&r2=1094010&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummySession.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/cmsutil/DummySession.h Sat
Apr 16 15:47:06 2011
@@ -45,13 +45,17 @@ namespace cmsutil {
 
         virtual ~DummySession() throw() {}
 
-        virtual void close() throw( cms::CMSException ){}
+        virtual void close() {}
 
-        virtual void commit() throw ( cms::CMSException ) {}
+        virtual void start() {}
 
-        virtual void rollback() throw ( cms::CMSException ) {}
+        virtual void stop() {}
 
-        virtual void recover() throw ( cms::CMSException ) {}
+        virtual void commit() {}
+
+        virtual void rollback() {}
+
+        virtual void recover() {}
 
         virtual cms::MessageConsumer* createConsumer(
             const cms::Destination* destination )



Mime
View raw message