activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r508063 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire: OpenWireConsumerInfo.h OpenWireProducerInfo.h OpenWireTransactionInfo.h
Date Thu, 15 Feb 2007 18:22:05 GMT
Author: tabish
Date: Thu Feb 15 10:22:04 2007
New Revision: 508063

URL: http://svn.apache.org/viewvc?view=rev&rev=508063
Log:
http://issues.apache.org/activemq/browse/AMQCPP-30

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConsumerInfo.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireProducerInfo.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireTransactionInfo.h

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConsumerInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConsumerInfo.h?view=diff&rev=508063&r1=508062&r2=508063
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConsumerInfo.h
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConsumerInfo.h
Thu Feb 15 10:22:04 2007
@@ -19,6 +19,7 @@
 #define _ACTIVEMQ_CONNECTOR_OPENWIRE_OPENWIRECONSUMERINFO_H_
 
 #include <activemq/connector/ConsumerInfo.h>
+#include <activemq/connector/openwire/commands/ConsumerInfo.h>
 #include <cms/Destination.h>
 
 namespace activemq{
@@ -29,6 +30,9 @@
 
     private:
 
+        // OpenWire's Consumer Info Command
+        commands::ConsumerInfo* consumerInfo;
+
         // Message Selector for this Consumer
         std::string selector;
 
@@ -114,6 +118,27 @@
          */
         virtual void setSessionInfo( const SessionInfo* session ) {
             this->session = session;
+        }
+
+        /**
+         * Gets the OpenWire Consumer Info object that was used to create
+         * this Consumer.
+         * @returns The ConsumerInfo for this Session or NULL if not set.
+         */
+        virtual const commands::ConsumerInfo* getConsumerInfo() const {
+            return this->consumerInfo;
+        }
+        virtual commands::ConsumerInfo* getConsumerInfo() {
+            return this->consumerInfo;
+        }
+
+        /**
+         * Sets the ConsumerInfo from OpenWire that was used to create this
+         * Consumer
+         * @param consumerInfo - the ConsumerInfo for this Session.
+         */
+        virtual void setConsumerInfo( commands::ConsumerInfo* consumerInfo ) {
+            this->consumerInfo = consumerInfo;
         }
 
     };

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireProducerInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireProducerInfo.h?view=diff&rev=508063&r1=508062&r2=508063
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireProducerInfo.h
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireProducerInfo.h
Thu Feb 15 10:22:04 2007
@@ -19,6 +19,7 @@
 #define _ACTIVEMQ_CONNECTOR_OPENWIRE_OPENWIREPRODUCERINFO_H_
 
 #include <activemq/connector/ProducerInfo.h>
+#include <activemq/connector/openwire/commands/ProducerInfo.h>
 #include <cms/Destination.h>
 
 namespace activemq{
@@ -29,6 +30,9 @@
 
     private:
 
+        // OpenWire ProducerInfo Command
+        commands::ProducerInfo* producerInfo;
+
         // Producer Id
         unsigned int producerId;
 
@@ -97,6 +101,27 @@
          */
         virtual void setSessionInfo( const SessionInfo* session ) {
             this->session = session;
+        }
+
+        /**
+         * Gets the OpenWire ProducerInfo object that was used to create
+         * this session.
+         * @returns The ProducerInfo for this Session or NULL if not set.
+         */
+        virtual const commands::ProducerInfo* getProducerInfo() const {
+            return this->producerInfo;
+        }
+        virtual commands::ProducerInfo* getProducerInfo() {
+            return this->producerInfo;
+        }
+
+        /**
+         * Sets the ProducerInfo from OpenWire that was used to create this
+         * Session
+         * @param producerInfo - the ProducerInfo for this Session.
+         */
+        virtual void setProducerInfo( commands::ProducerInfo* producerInfo ) {
+            this->producerInfo = producerInfo;
         }
 
     };

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireTransactionInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireTransactionInfo.h?view=diff&rev=508063&r1=508062&r2=508063
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireTransactionInfo.h
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireTransactionInfo.h
Thu Feb 15 10:22:04 2007
@@ -19,6 +19,7 @@
 #define _ACTIVEMQ_CONNECTOR_OPENWIRE_OPENWIRETRANSACTIONINFO_H_
 
 #include <activemq/connector/TransactionInfo.h>
+#include <activemq/connector/openwire/commands/TransactionInfo.h>
 #include <activemq/connector/SessionInfo.h>
 
 namespace activemq{
@@ -29,6 +30,9 @@
 
     private:
 
+        // OpenWire Tramsaction Info Command
+        commands::TransactionInfo* transactionInfo;
+
         // Transaction Id
         unsigned int transactionId;
 
@@ -74,6 +78,27 @@
          */
         virtual void setSessionInfo( const SessionInfo* session ) {
             this->session = session;
+        }
+
+        /**
+         * Gets the OpenWire TransactionInfo object that was used to create
+         * this session.
+         * @returns The TransactionInfo for this Session or NULL if not set.
+         */
+        virtual const commands::TransactionInfo* getTransactionInfo() const {
+            return this->transactionInfo;
+        }
+        virtual commands::TransactionInfo* getTransactionInfo() {
+            return this->transactionInfo;
+        }
+
+        /**
+         * Sets the TransactionInfo from OpenWire that was used to create this
+         * Session
+         * @param transactionInfo - the TransactionInfo for this Session.
+         */
+        virtual void setTransactionInfo( commands::TransactionInfo* transactionInfo ) {
+            this->transactionInfo = transactionInfo;
         }
 
     };



Mime
View raw message