activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r508184 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Date Thu, 15 Feb 2007 21:57:27 GMT
Author: tabish
Date: Thu Feb 15 13:57:26 2007
New Revision: 508184

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

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=508184&r1=508183&r2=508184
==============================================================================
--- 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
Thu Feb 15 13:57:26 2007
@@ -40,6 +40,8 @@
 #include <activemq/connector/openwire/commands/WireFormatInfo.h>
 #include <activemq/connector/openwire/commands/BrokerInfo.h>
 #include <activemq/connector/openwire/commands/BrokerError.h>
+#include <activemq/connector/openwire/commands/ActiveMQTopic.h>
+#include <activemq/connector/openwire/commands/ActiveMQQueue.h>
 
 using namespace std;
 using namespace activemq;
@@ -435,15 +437,14 @@
 
 ////////////////////////////////////////////////////////////////////////////////
 cms::Topic* OpenWireConnector::createTopic( const std::string& name,
-                                            connector::SessionInfo* session )
+                                            connector::SessionInfo* session AMQCPP_UNUSED
)
     throw ( ConnectorException )
 {
     try
     {
         enforceConnected();
 
-        // TODO
-        return NULL;
+        return new commands::ActiveMQTopic( name );
     }
     AMQ_CATCH_RETHROW( ConnectorException )
     AMQ_CATCHALL_THROW( ConnectorException )
@@ -451,15 +452,14 @@
 
 ////////////////////////////////////////////////////////////////////////////////
 cms::Queue* OpenWireConnector::createQueue( const std::string& name,
-                                            connector::SessionInfo* session )
+                                            connector::SessionInfo* session AMQCPP_UNUSED
)
     throw ( ConnectorException )
 {
     try
     {
         enforceConnected();
 
-        // TODO
-        return NULL;
+        return new commands::ActiveMQQueue( name );
     }
     AMQ_CATCH_RETHROW( ConnectorException )
     AMQ_CATCHALL_THROW( ConnectorException )



Mime
View raw message