activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r618045 - in /activemq/activemq-cpp/trunk/src/main/activemq/connector: Connector.h openwire/OpenWireConnector.cpp openwire/OpenWireConnector.h stomp/StompConnector.cpp stomp/StompConnector.h
Date Sun, 03 Feb 2008 17:48:10 GMT
Author: tabish
Date: Sun Feb  3 09:47:49 2008
New Revision: 618045

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

Making a few interface changes for the pull support

Modified:
    activemq/activemq-cpp/trunk/src/main/activemq/connector/Connector.h
    activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
    activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.h
    activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.cpp
    activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.h

Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/Connector.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/Connector.h?rev=618045&r1=618044&r2=618045&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/Connector.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/Connector.h Sun Feb  3 09:47:49
2008
@@ -374,7 +374,7 @@
          * @throw ConnectorException if a communications error occurs
          * @throw UnsupportedOperationException if the connector can't pull
          */
-        virtual void pullMessage( connector::ConsumerInfo* info, long long timeout )
+        virtual void pullMessage( const connector::ConsumerInfo* info, long long timeout
)
             throw ( ConnectorException, decaf::lang::exceptions::UnsupportedOperationException
) = 0;
 
     };

Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp?rev=618045&r1=618044&r2=618045&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
(original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Sun Feb  3 09:47:49 2008
@@ -1207,13 +1207,13 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void OpenWireConnector::pullMessage( connector::ConsumerInfo* info, long long timeout )
+void OpenWireConnector::pullMessage( const connector::ConsumerInfo* info, long long timeout
)
     throw ( ConnectorException, decaf::lang::exceptions::UnsupportedOperationException )
{
 
     try {
 
-        OpenWireConsumerInfo* consumer =
-             dynamic_cast<OpenWireConsumerInfo*>( info );
+        const OpenWireConsumerInfo* consumer =
+             dynamic_cast<const OpenWireConsumerInfo*>( info );
 
          if( consumer->getConsumerInfo()->getPrefetchSize() == 0 ) {
 

Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.h?rev=618045&r1=618044&r2=618045&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.h Sun
Feb  3 09:47:49 2008
@@ -578,7 +578,7 @@
          * @throw ConnectorException if a communications error occurs
          * @throw UnsupportedOperationException if the connector can't pull
          */
-        virtual void pullMessage( connector::ConsumerInfo* info, long long timeout )
+        virtual void pullMessage( const connector::ConsumerInfo* info, long long timeout
)
             throw ( ConnectorException, decaf::lang::exceptions::UnsupportedOperationException
);
 
     public: // transport::CommandListener

Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.cpp?rev=618045&r1=618044&r2=618045&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.cpp Sun Feb
 3 09:47:49 2008
@@ -714,7 +714,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void StompConnector::pullMessage( connector::ConsumerInfo* info AMQCPP_UNUSED, long long
timeout AMQCPP_UNUSED )
+void StompConnector::pullMessage( const connector::ConsumerInfo* info AMQCPP_UNUSED, long
long timeout AMQCPP_UNUSED )
     throw ( ConnectorException, decaf::lang::exceptions::UnsupportedOperationException )
{
 
     try {

Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.h?rev=618045&r1=618044&r2=618045&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/stomp/StompConnector.h Sun Feb
 3 09:47:49 2008
@@ -497,7 +497,7 @@
          * @throw ConnectorException if a communications error occurs
          * @throw UnsupportedOperationException if the connector can't pull
          */
-        virtual void pullMessage( connector::ConsumerInfo* info, long long timeout )
+        virtual void pullMessage( const connector::ConsumerInfo* info, long long timeout
)
             throw ( ConnectorException, decaf::lang::exceptions::UnsupportedOperationException
);
 
     public: // transport::CommandListener



Mime
View raw message