activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nmitt...@apache.org
Subject svn commit: r508906 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Date Sun, 18 Feb 2007 15:07:47 GMT
Author: nmittler
Date: Sun Feb 18 07:07:47 2007
New Revision: 508906

URL: http://svn.apache.org/viewvc?view=rev&rev=508906
Log:
[AMQCPP-30] adding proper dataStructure to RemoveInfo for session, consumer, and producer

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp?view=diff&rev=508906&r1=508905&r2=508906
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Sun Feb 18 07:07:47 2007
@@ -1130,11 +1130,11 @@
                     consumer->getConsumerInfo()->getConsumerId()->getValue() );
             }
             
-            dataStructure = consumer->getConsumerInfo();
+            dataStructure = consumer->getConsumerInfo()->getConsumerId();
         } else if( producer != NULL ) {
-            dataStructure = producer->getProducerInfo();
+            dataStructure = producer->getProducerInfo()->getProducerId();
         } else if( session != NULL ) {
-            dataStructure = session->getSessionInfo();
+            dataStructure = session->getSessionInfo()->getSessionId();
         } else if( tempDestination != NULL ) {
             // User deletes these
             destroyTemporaryDestination( tempDestination );
@@ -1289,7 +1289,7 @@
     throw ( ConnectorException )
 {
     try
-    {
+    {   
         Response* response = transport->request(command);
 
         commands::ExceptionResponse* exceptionResponse = dynamic_cast<commands::ExceptionResponse*>(response);



Mime
View raw message