activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r377433 [2/4] - in /incubator/activemq/trunk/openwire-cpp: ./ src/ src/command/ src/io/ src/marshal/ src/transport/ src/util/ src/util/ifr/ src/util/ifr/v1/
Date Mon, 13 Feb 2006 17:43:55 GMT
Added: incubator/activemq/trunk/openwire-cpp/src/Session.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/Session.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/Session.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/Session.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,150 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "Session.hpp"
+#include "command/ActiveMQQueue.hpp"
+#include "command/ActiveMQTopic.hpp"
+#include "command/ActiveMQMessage.hpp"
+#include "command/ActiveMQTextMessage.hpp"
+#include "command/ProducerInfo.hpp"
+#include "command/ConsumerInfo.hpp"
+#include "command/MessageAck.hpp"
+#include "MessageConsumer.hpp"
+#include "MessageProducer.hpp"
+#include "Connection.hpp"
+
+using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+Session::Session(p<Connection> connection, p<SessionInfo> info)
+{
+    this->connection  = connection ;
+    this->sessionInfo = info ;
+}
+
+Session::~Session()
+{
+    // De-activate session
+    disposeOf(sessionInfo->getSessionId()) ;  //(IDataStructure*)
+}
+
+p<IMessageProducer> Session::createProducer()
+{
+    return createProducer(NULL) ; 
+}
+
+p<IMessageProducer> Session::createProducer(p<IDestination> destination)
+{
+    p<ProducerInfo> command = createProducerInfo(destination) ;
+    connection->syncRequest(command) ;  //(ICommand*)
+    p<IMessageProducer> messageProducer = new MessageProducer(this, command) ;
+    return messageProducer ;
+}
+
+void Session::acknowledge(p<IMessage> message)
+{
+    if( ackMode == ClientMode )
+    {
+        p<MessageAck> msgAck = new MessageAck() ;
+        // TODO complete packet
+        connection->syncRequest(msgAck) ;  //(ICommand*)
+    } 
+}
+
+p<IMessageConsumer> Session::createConsumer(p<IDestination> destination)
+{
+    return createConsumer(destination, NULL) ; 
+}
+
+p<IMessageConsumer> Session::createConsumer(p<IDestination> destination, const char* selector)
+{
+    p<ConsumerInfo> command = createConsumerInfo(destination, selector) ;
+    connection->syncRequest(command) ;  //(ICommand*)
+    p<IMessageConsumer> messageConsumer = new MessageConsumer(this, command) ; 
+    return messageConsumer ;
+}
+
+p<IQueue> Session::getQueue(const char* name)
+{
+    p<IQueue> queue = (IQueue*)new ActiveMQQueue(name) ;
+    return queue ;
+}
+
+p<ITopic> Session::getTopic(const char* name)
+{
+    p<ITopic> topic = (ITopic*)new ActiveMQTopic(name) ;
+    return topic ;
+}
+
+p<IMessage> Session::createMessage()
+{
+    p<IMessage> message = (IMessage*)new ActiveMQMessage() ;
+    return message ;
+}
+
+p<ITextMessage> Session::createTextMessage()
+{
+    p<ITextMessage> message = (ITextMessage*)new ActiveMQTextMessage() ;
+    return message ;
+}
+
+p<ITextMessage> Session::createTextMessage(const char* text)
+{
+    p<ITextMessage> message = (ITextMessage*)new ActiveMQTextMessage(text) ;
+    return message ;
+}
+
+void Session::doSend(p<IDestination> destination, p<IMessage> message)
+{
+    p<ActiveMQMessage> command = ActiveMQMessage::transform(message) ;
+    // TODO complete packet
+    connection->syncRequest(command) ; //(ICommand*)
+}
+
+void Session::disposeOf(p<IDataStructure> objectId)
+{
+    p<RemoveInfo> command = new RemoveInfo() ;
+    command->setObjectId( objectId ) ;
+
+    connection->syncRequest(command) ;  //(ICommand*)
+}
+
+// Implementation methods ------------------------------------------
+
+p<ConsumerInfo> Session::createConsumerInfo(p<IDestination> destination, const char* selector)
+{
+    p<ConsumerInfo> consumerInfo = new ConsumerInfo() ;
+    p<ConsumerId> consumerId = new ConsumerId() ;
+    consumerId->setSessionId( sessionInfo->getSessionId()->getValue() ) ;
+
+    mutex.lock() ;
+    consumerId->setValue( ++consumerCounter ) ;
+    mutex.unlock() ;
+
+    // TODO complete packet
+    consumerInfo->setConsumerId( consumerId ) ;
+
+    return consumerInfo ;
+}
+
+p<ProducerInfo> Session::createProducerInfo(p<IDestination> destination)
+{
+    p<ProducerInfo> producerInfo = new ProducerInfo() ;
+    // TODO complete packet
+    return producerInfo ;
+} 

Propchange: incubator/activemq/trunk/openwire-cpp/src/Session.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/Session.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/Session.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/Session.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/Session.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,81 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef Session_hpp_
+#define Session_hpp_
+
+#include <string>
+#include "IMessage.hpp"
+#include "ISession.hpp"
+#include "command/IDataStructure.hpp"
+#include "command/ConsumerInfo.hpp"
+#include "command/ProducerInfo.hpp"
+#include "command/RemoveInfo.hpp"
+#include "command/SessionInfo.hpp"
+#include "util/SimpleMutex.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+        using namespace ifr;
+        using namespace apache::activemq::client::util;
+        class Connection;
+        enum  AcknowledgementMode;
+
+/*
+ * 
+ */
+class Session : public ISession
+{
+private:
+    p<Connection>       connection ;
+    p<SessionInfo>      sessionInfo ;
+    AcknowledgementMode ackMode ;
+    long                consumerCounter ;
+    SimpleMutex         mutex ;
+
+public:
+    Session(p<Connection> connection, p<SessionInfo> sessionInfo) ;
+    ~Session() ;
+    
+    virtual p<IMessageProducer> createProducer() ;
+    virtual p<IMessageProducer> createProducer(p<IDestination> destination) ;
+    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination) ;
+    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination, const char* selector) ;
+    virtual p<IQueue> getQueue(const char* name) ;
+    virtual p<ITopic> getTopic(const char* name) ;
+    virtual p<IMessage> createMessage() ;
+    virtual p<ITextMessage> createTextMessage() ;
+    virtual p<ITextMessage> createTextMessage(const char* text) ;
+    virtual void acknowledge(p<IMessage> message) ;
+    virtual void doSend(p<IDestination> destination, p<IMessage> message) ;
+    virtual void disposeOf(p<IDataStructure> objectId) ;
+
+protected:
+    p<ConsumerInfo> createConsumerInfo(p<IDestination> destination, const char* selector) ;
+    p<ProducerInfo> createProducerInfo(p<IDestination> destination) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*Session_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/Session.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,61 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "TraceException.hpp"
+
+using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+TraceException::TraceException()
+   : exception()
+{
+    // no-op
+} ;
+
+/*
+ * 
+ */
+TraceException::TraceException(const char* msg)
+   : exception(msg)
+{
+    // no-op
+} ;
+
+/*
+ * 
+ */
+TraceException::TraceException(const char* fileName, int lineNo, const char* message)
+    : exception(message)
+{
+    char buf[10] ;
+
+    trace = new string() ;
+    trace->append(fileName) ;
+    trace->append(" at ") ;
+    trace->append( itoa(lineNo, buf, 10) ) ;
+}
+
+TraceException::~TraceException()
+{
+    // no-op
+}
+
+p<string> TraceException::where()
+{
+    return trace ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,54 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef TraceException_hpp_
+#define TraceException_hpp_
+
+#include <exception>
+#include <string>
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace std ;
+      using namespace ifr ;
+
+/*
+ * Base class for all exceptions containing trace information.
+ */
+class TraceException : public exception
+{
+    p<string> trace ;
+
+public:
+    TraceException() ;
+    TraceException(const char* msg) ;
+    TraceException(const char* fileName, int lineNo, const char* msg) ;
+    virtual ~TraceException() ;
+
+    p<string> where() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*TraceException_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,116 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <string.h>
+#include "command/AbstractCommand.hpp"
+#include "command/ActiveMQMessage.hpp"
+#include "command/ActiveMQTextMessage.hpp"
+#include "command/MessageAck.hpp"
+#include "command/Response.hpp"
+#include "command/ConsumerInfo.hpp"
+#include "command/ProducerInfo.hpp"
+#include "command/BrokerInfo.hpp"
+#include "command/ConnectionInfo.hpp"
+#include "command/RemoveInfo.hpp"
+#include "command/SessionInfo.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * 
+ */
+AbstractCommand::AbstractCommand()
+{
+}
+
+AbstractCommand::~AbstractCommand()
+{
+}
+
+int AbstractCommand::getCommandType()
+{
+    return 0 ; 
+}
+
+p<string> AbstractCommand::getCommandTypeAsString(int type)
+{
+    p<string> packetType = new string() ;
+
+    switch( type )
+    {
+        case ActiveMQMessage::TYPE:
+            packetType->assign("ACTIVEMQ_MESSAGE") ;
+            break ;
+        case ActiveMQTextMessage::TYPE:
+            packetType->assign("ACTIVEMQ_TEXT_MESSAGE") ;
+            break ;
+//        case ActiveMQObjectMessage::TYPE:
+//            packetType->assign("ACTIVEMQ_OBJECT_MESSAGE") ;
+//            break ;
+//        case ActiveMQBytesMessage::TYPE:
+//            packetType->assign("ACTIVEMQ_BYTES_MESSAGE") ;
+//            break ;
+//        case ActiveMQStreamMessage::TYPE:
+//            packetType->assign("ACTIVEMQ_STREAM_MESSAGE") ;
+//            break ;
+//        case ActiveMQMapMessage::TYPE:
+//            packetType->assign("ACTIVEMQ_MAP_MESSAGE") ;
+//            break ;
+        case MessageAck::TYPE:
+            packetType->assign("ACTIVEMQ_MSG_ACK") ;
+            break ;
+        case Response::TYPE:
+            packetType->assign("RESPONSE") ;
+            break ;
+        case ConsumerInfo::TYPE:
+            packetType->assign("CONSUMER_INFO") ;
+            break ;
+        case ProducerInfo::TYPE:
+            packetType->assign("PRODUCER_INFO") ;
+            break;
+//        case TransactionInfo::TYPE:
+//            packetType->assign("TRANSACTION_INFO") ;
+//            break ;
+        case BrokerInfo::TYPE:
+            packetType->assign("BROKER_INFO") ;
+            break ;
+        case ConnectionInfo::TYPE:
+            packetType->assign("CONNECTION_INFO") ;
+            break ;
+        case SessionInfo::TYPE:
+            packetType->assign("SESSION_INFO") ;
+            break ;
+//        case RemoveSubscriptionInfo::TYPE:
+//            packetType->assign("DURABLE_UNSUBSCRIBE") ;
+//            break ;
+//        case IntegerResponse::TYPE:
+//            packetType->assign("INT_RESPONSE_RECEIPT_INFO") ;
+//            break ;
+//        case WireFormatInfo::TYPE:
+//            packetType->assign("WIRE_FORMAT_INFO") ;
+//            break ;
+        case RemoveInfo::TYPE:
+            packetType->assign("REMOVE_INFO") ;
+            break ;
+//        case KeepAliveInfo::TYPE:
+//            packetType->assign("KEEP_ALIVE") ;
+//            break ;
+        default:
+            packetType->assign("UNDEFINED") ;
+            break ;
+    }
+    return packetType ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,57 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef AbstractCommand_hpp_
+#define AbstractCommand_hpp_
+
+#include <string>
+#include "command/ICommand.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+
+/*
+ * 
+ */
+class AbstractCommand : public ICommand
+{
+protected:
+    AbstractCommand() ;
+
+public:
+    ~AbstractCommand() ;
+
+    virtual int getCommandType() ;
+
+    static p<string> getCommandTypeAsString(int type) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*AbstractCommand_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/AbstractCommand.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,30 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ActiveMQDestination.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ActiveMQDestination::ActiveMQDestination()
+{
+}
+
+ActiveMQDestination::~ActiveMQDestination()
+{
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,49 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQDestination_hpp_
+#define ActiveMQDestination_hpp_
+
+#include "IDestination.hpp"
+#include "command/AbstractCommand.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace apache::activemq::client;
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ActiveMQDestination : public AbstractCommand, IDestination
+{
+public:
+    ActiveMQDestination() ;
+    virtual ~ActiveMQDestination() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ActiveMQDestination_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQDestination.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,50 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ActiveMQMessage.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ActiveMQMessage::ActiveMQMessage()
+{
+    destination = NULL ;
+}
+
+ActiveMQMessage::ActiveMQMessage(const char* name)
+{
+}
+
+ActiveMQMessage::~ActiveMQMessage()
+{
+}
+
+p<IDestination> ActiveMQMessage::getFromDestination()
+{
+    return destination ;
+}
+
+void ActiveMQMessage::setFromDestination(p<IDestination> destination)
+{
+    this->destination = destination ;
+}
+
+p<ActiveMQMessage> ActiveMQMessage::transform(p<IMessage> message)
+{
+    return (p<ActiveMQMessage>&)message ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,65 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQMessage_hpp_
+#define ActiveMQMessage_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+#include "IMessage.hpp"
+#include "command/Message.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace apache::activemq::client;
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ActiveMQMessage : public Message, IMessage
+{
+private:
+    p<IDestination> destination ;
+
+public:
+    const static int TYPE = 23 ;
+
+public:
+    ActiveMQMessage() ;
+    ActiveMQMessage(const char* name) ;
+    virtual ~ActiveMQMessage() ;
+
+    virtual p<IDestination> getFromDestination() ;
+    virtual void setFromDestination(p<IDestination> destination) ;
+
+    static p<ActiveMQMessage> transform(p<IMessage> message) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ActiveMQMessage_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQMessage.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,34 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ActiveMQQueue.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ActiveMQQueue::ActiveMQQueue()
+{
+}
+
+ActiveMQQueue::ActiveMQQueue(const char* name)
+{
+}
+
+ActiveMQQueue::~ActiveMQQueue()
+{
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,48 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQQueue_hpp_
+#define ActiveMQQueue_hpp_
+
+#include "command/ActiveMQDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ActiveMQQueue : public ActiveMQDestination
+{
+public:
+    ActiveMQQueue() ;
+    ActiveMQQueue(const char* name) ;
+    virtual ~ActiveMQQueue() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ActiveMQQueue_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQQueue.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ActiveMQTextMessage.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ActiveMQTextMessage::ActiveMQTextMessage()
+{
+}
+
+ActiveMQTextMessage::ActiveMQTextMessage(const char* name)
+   : ActiveMQMessage(name)
+{
+}
+
+ActiveMQTextMessage::~ActiveMQTextMessage()
+{
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,51 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQTextMessage_hpp_
+#define ActiveMQTextMessage_hpp_
+
+#include "ActiveMQMessage.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ActiveMQTextMessage : public ActiveMQMessage
+{
+public:
+    const static int TYPE = 28 ;
+
+public:
+    ActiveMQTextMessage() ;
+    ActiveMQTextMessage(const char* name) ;
+    virtual ~ActiveMQTextMessage() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ActiveMQTextMessage_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTextMessage.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,34 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ActiveMQTopic.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ActiveMQTopic::ActiveMQTopic()
+{
+}
+
+ActiveMQTopic::ActiveMQTopic(const char* name)
+{
+}
+
+ActiveMQTopic::~ActiveMQTopic()
+{
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,48 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQTopic_hpp_
+#define ActiveMQTopic_hpp_
+
+#include "command/ActiveMQDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ActiveMQTopic : public ActiveMQDestination
+{
+public:
+    ActiveMQTopic() ;
+    ActiveMQTopic(const char* name) ;
+    virtual ~ActiveMQTopic() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ActiveMQTopic_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQTopic.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,95 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/BaseCommand.hpp"
+
+using namespace apache::activemq::client::command;
+
+// Constructors -----------------------------------------------------
+
+/*
+ * 
+ */
+BaseCommand::BaseCommand()
+{
+}
+
+BaseCommand::~BaseCommand()
+{
+}
+
+
+// Attribute methods ------------------------------------------------
+
+int BaseCommand::getHashCode()
+{
+    return commandId ;
+}
+
+int BaseCommand::getCommandType()
+{
+    return BaseCommand::TYPE ;
+}
+
+int BaseCommand::getCommandId()
+{
+    return commandId ;
+}
+
+void BaseCommand::setCommandId(int id)
+{
+    commandId = id ;
+}
+
+bool BaseCommand::isResponseRequired()
+{
+    return responseRequired ;
+}
+
+void BaseCommand::setResponseRequired(bool required)
+{
+    responseRequired = required ;
+}
+
+
+// Operation methods ------------------------------------------------
+
+bool BaseCommand::operator== (BaseCommand& other)
+{
+    if( getCommandType() == other.getCommandType() &&
+        commandId == other.commandId &&
+        responseRequired == other.responseRequired )
+    {
+        return true ;
+    }
+    return false ;
+}
+
+p<string> BaseCommand::toString()
+{
+    p<string> str = new string() ;
+    char      buffer[5] ;
+    
+    str->assign( getCommandTypeAsString( getCommandType() )->c_str() ) ;
+
+    if( str->length() == 0 )
+        str->assign("") ;
+
+    str->append(": id = ") ;
+    str->append( itoa(getCommandId(), buffer, 10) ) ;
+
+    return str ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,69 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef BaseCommand_hpp_
+#define BaseCommand_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+
+/*
+ * 
+ */
+class BaseCommand : public AbstractCommand
+{
+private:
+    int  commandId ;
+    bool responseRequired ;
+
+public:
+    const static int TYPE = 0 ;
+
+public:
+    BaseCommand() ;
+    virtual ~BaseCommand() ;
+
+    // Equals operator
+    bool operator== (BaseCommand& other) ;
+
+    virtual int getHashCode() ;
+    virtual int getCommandType() ;
+    virtual int getCommandId() ;
+    virtual void setCommandId(int id) ;
+    virtual bool isResponseRequired() ;
+    virtual void setResponseRequired(bool required) ;
+    virtual p<string> toString() ;
+};
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*BaseCommand_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/BaseCommand.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,47 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/BrokerId.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ *
+ */
+BrokerId::BrokerId()
+{
+    value = new string() ;
+}
+
+BrokerId::~BrokerId()
+{
+    // no-op
+}
+
+int BrokerId::getCommandType()
+{
+    return BrokerId::TYPE ;
+}
+
+p<string> BrokerId::getValue()
+{
+    return value ;
+}
+
+void BrokerId::setValue(const char* brokerId)
+{
+    this->value->assign( brokerId ) ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,61 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef BrokerId_hpp_
+#define BrokerId_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std ;
+
+/*
+ *
+ */
+class BrokerId : public AbstractCommand
+{
+private:
+    p<string> value ;
+
+public:
+    const static char TYPE = 124 ;
+
+public:
+    BrokerId() ;
+    virtual ~BrokerId() ;
+
+    virtual int getCommandType() ;
+    virtual p<string> getValue() ;
+    virtual void setValue(const char* brokerId) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*BrokerId_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/BrokerId.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,80 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/BrokerInfo.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ *
+ */
+BrokerInfo::BrokerInfo()
+{
+    brokerId   = NULL ;
+    brokerURL  = new string() ;
+    brokerName = new string() ;
+    peerInfos  = NULL ;
+}
+
+BrokerInfo::~BrokerInfo()
+{
+    // no-op
+}
+
+int BrokerInfo::getCommandType()
+{
+    return BrokerInfo::TYPE ;
+}
+
+p<string> BrokerInfo::getBrokerName()
+{
+    return brokerName ;
+}
+
+void BrokerInfo::setBrokerName(const char* name)
+{
+    brokerName->assign(name) ;
+}
+
+p<BrokerId> BrokerInfo::getBrokerId()
+{
+    return brokerId ;
+}
+
+void BrokerInfo::setBrokerId(p<BrokerId> brokerId)
+{
+    this->brokerId = brokerId ;
+}
+
+p<string> BrokerInfo::getBrokerURL()
+{
+    return brokerURL ;
+}
+
+void BrokerInfo::setBrokerURL(const char* url)
+{
+    this->brokerURL->assign(url) ;
+}
+
+ap<BrokerInfo> BrokerInfo::getPeerBrokerInfo()
+{
+    return peerInfos ;
+}
+
+void BrokerInfo::setPeerBrokerInfo(ap<BrokerInfo> info)
+{
+    peerInfos = info ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,72 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef BrokerInfo_hpp_
+#define BrokerInfo_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+#include "command/BrokerId.hpp"
+#include "util/ifr/ap"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+
+/*
+ *
+ */
+class BrokerInfo : public BaseCommand
+{
+private:
+    p<BrokerId>    brokerId ;
+    p<string>      brokerURL,
+                   brokerName ;
+    ap<BrokerInfo> peerInfos ;
+
+public:
+    const static char TYPE = 2 ;
+
+public:
+    BrokerInfo() ;
+    virtual ~BrokerInfo() ;
+
+    virtual int getCommandType() ;
+    virtual p<string> getBrokerName() ;
+    virtual void setBrokerName(const char* name) ;
+    virtual p<BrokerId> getBrokerId() ;
+    virtual void setBrokerId(p<BrokerId> id) ;
+    virtual p<string> getBrokerURL() ;
+    virtual void setBrokerURL(const char* url) ;
+    virtual ap<BrokerInfo> getPeerBrokerInfo() ;
+    virtual void setPeerBrokerInfo(ap<BrokerInfo> info) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*BrokerInfo_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/BrokerInfo.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,46 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ConnectionId.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ConnectionId::ConnectionId()
+{
+    value = new string() ;
+}
+
+ConnectionId::~ConnectionId()
+{
+}
+
+int ConnectionId::getCommandType()
+{
+    return ConnectionId::TYPE ;
+}
+
+void ConnectionId::setValue(const char* value)
+{
+    this->value->assign(value) ;
+}
+
+p<string> ConnectionId::getValue()
+{
+    return value ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,60 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ConnectionId_hpp_
+#define ConnectionId_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ConnectionId : public AbstractCommand
+{
+private:
+    p<string> value ;
+
+    const static int TYPE = 120 ;
+
+public:
+    ConnectionId() ;
+    virtual ~ConnectionId() ;
+
+    virtual int getCommandType() ;
+    virtual void setValue(const char* value) ;
+    virtual p<string> getValue() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ConnectionId_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionId.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,85 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ConnectionInfo.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ConnectionInfo::ConnectionInfo()
+{
+    connectionId = NULL ;
+    brokerPath   = NULL ;
+    username     = new string() ;
+    password     = new string() ;
+    clientId     = new string() ;
+}
+
+ConnectionInfo::~ConnectionInfo()
+{
+}
+
+p<ConnectionId> ConnectionInfo::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ConnectionInfo::setConnectionId(p<ConnectionId> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+p<string> ConnectionInfo::getUsername()
+{
+    return this->username ;
+}
+
+void ConnectionInfo::setUsername(const char* username)
+{
+    this->username->assign( username ) ;
+}
+
+p<string> ConnectionInfo::getPassword()
+{
+    return this->password ;
+}
+
+void ConnectionInfo::setPassword(const char* password)
+{
+    this->password->assign( password ) ;
+}
+
+p<string> ConnectionInfo::getClientId()
+{
+    return this->clientId ;
+}
+
+void ConnectionInfo::setClientId(const char* clientId)
+{
+    this->clientId->assign( clientId ) ;
+}
+
+p<BrokerId*> ConnectionInfo::getBrokerPath()
+{
+    return this->brokerPath ;
+}
+
+void ConnectionInfo::setBrokerPath(p<BrokerId*> brokerPath)
+{
+    this->brokerPath = brokerPath ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,73 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ConnectionInfo_hpp_
+#define ConnectionInfo_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ConnectionInfo : public BaseCommand
+{
+private:
+    p<ConnectionId> connectionId ;
+    p<BrokerId*>    brokerPath ;
+    p<string>       username,
+                    password,
+                    clientId ;
+public:
+    const static int TYPE = 3 ;
+
+public:
+    ConnectionInfo() ;
+    virtual ~ConnectionInfo() ;
+
+    virtual p<ConnectionId> getConnectionId() ;
+    virtual void setConnectionId(p<ConnectionId> connectionId) ;
+    virtual p<string> getUsername() ;
+    virtual void setUsername(const char* username) ;
+    virtual p<string> getPassword() ;
+    virtual void setPassword(const char* password) ;
+    virtual p<string> getClientId() ;
+    virtual void setClientId(const char* clientId) ;
+    virtual p<BrokerId*> getBrokerPath() ;
+    virtual void setBrokerPath(p<BrokerId*> brokerPath) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ConnectionInfo_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionInfo.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,66 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ConsumerId.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ConsumerId::ConsumerId()
+{
+    connectionId = new string() ;
+}
+
+ConsumerId::~ConsumerId()
+{
+}
+
+int ConsumerId::getCommandType()
+{
+    return ConsumerId::TYPE ;
+}
+
+void ConsumerId::setValue(long consumerId)
+{
+    this->consumerId = consumerId ;
+}
+
+long ConsumerId::getValue()
+{
+    return consumerId ;
+}
+
+void ConsumerId::setSessionId(long sessionId)
+{
+    this->sessionId = sessionId ;
+}
+
+long ConsumerId::getSessionId()
+{
+    return sessionId ;
+}
+
+void ConsumerId::setConnectionId(const char* connectionId)
+{
+    this->connectionId->assign( connectionId ) ;
+}
+
+p<string> ConsumerId::getConnectionId()
+{
+    return connectionId ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,66 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ConsumerId_hpp_
+#define ConsumerId_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ConsumerId : public AbstractCommand
+{
+private:
+    p<string> connectionId ;
+    long      sessionId,
+              consumerId ;
+
+    const static int TYPE = 122 ;
+
+public:
+    ConsumerId() ;
+    virtual ~ConsumerId() ;
+
+    virtual int getCommandType() ;
+    virtual void setValue(long consumerId) ;
+    virtual long getValue() ;
+    virtual void setSessionId(long sessionId) ;
+    virtual long getSessionId() ;
+    virtual void setConnectionId(const char* connectionId) ;
+    virtual p<string> getConnectionId() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ConsumerId_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerId.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,46 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ConsumerInfo.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ConsumerInfo::ConsumerInfo()
+{
+    consumerId = NULL ;
+}
+
+ConsumerInfo::ConsumerInfo(const char* name)
+{
+    consumerId = NULL ;
+}
+
+ConsumerInfo::~ConsumerInfo()
+{
+}
+
+p<ConsumerId> ConsumerInfo::getConsumerId()
+{
+    return consumerId ;
+}
+
+void ConsumerInfo::setConsumerId(p<ConsumerId> consumerId)
+{
+    this->consumerId = consumerId ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,60 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ConsumerInfo_hpp_
+#define ConsumerInfo_hpp_
+
+#include "command/BaseCommand.hpp"
+#include "command/ConsumerId.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ConsumerInfo : public BaseCommand
+{
+private:
+    p<ConsumerId> consumerId ;
+
+public:
+    const static int TYPE = 5 ;
+
+public:
+    ConsumerInfo() ;
+    ConsumerInfo(const char* name) ;
+    virtual ~ConsumerInfo() ;
+
+    virtual p<ConsumerId> getConsumerId() ;
+    virtual void setConsumerId(p<ConsumerId> consumerId) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ConsumerInfo_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ExceptionResponse.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * 
+ */
+ExceptionResponse::ExceptionResponse()
+{
+}
+
+ExceptionResponse::~ExceptionResponse()
+{
+}
+
+int ExceptionResponse::getCommandType()
+{
+    return ExceptionResponse::TYPE ;
+}
+
+p<BrokerError> ExceptionResponse::getException()
+{
+    return exception ;
+}
+
+void ExceptionResponse::setException(p<BrokerError> exception)
+{
+    this->exception = exception ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,61 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ExceptionResponse_hpp_
+#define ExceptionResponse_hpp_
+
+#include "BrokerError.hpp"
+#include "command/Response.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+class ExceptionResponse : public Response
+{
+private:
+    p<BrokerError> exception ;
+
+public:
+    static const int TYPE = 31 ;
+
+public:
+    ExceptionResponse() ;
+    ~ExceptionResponse() ;
+
+    virtual int getCommandType() ;
+    p<BrokerError> getException() ;
+    void setException(p<BrokerError> exception) ;
+};
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ExceptionResponse_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ExceptionResponse.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ICommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ICommand.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ICommand.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ICommand.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ICommand_hpp_
+#define ICommand_hpp_
+
+#include "command/IDataStructure.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+
+/*
+ * Interface for commands.
+ */
+struct ICommand : IDataStructure
+{
+ //   virtual char getCommandType() = 0 ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ICommand_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ICommand.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/IDataStructure.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/IDataStructure.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/IDataStructure.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/IDataStructure.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,43 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef IDataStructure_hpp_
+#define IDataStructure_hpp_
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+
+/*
+ * Mockup interface for writing to streams.
+ */
+struct IDataStructure
+{
+    virtual int getCommandType() = 0 ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*IDataStructure_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/IDataStructure.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/Message.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/Message.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/Message.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/Message.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/Message.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+Message::Message()
+{
+}
+
+Message::~Message()
+{
+}
+
+p<ActiveMQDestination> Message::getDestination()
+{
+    return destination ;
+}
+
+void Message::setDestination(p<ActiveMQDestination> destination)
+{
+    this->destination = destination ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/Message.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/Message.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/Message.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/Message.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/Message.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,58 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef Message_hpp_
+#define Message_hpp_
+
+#include <string>
+#include "IMessage.hpp"
+#include "command/BaseCommand.hpp"
+#include "command/ActiveMQDestination.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class Message : public BaseCommand
+{
+private:
+    p<ActiveMQDestination> destination ;
+
+public:
+    Message() ;
+    virtual ~Message() ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*Message_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/Message.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,30 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/MessageAck.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+MessageAck::MessageAck()
+{
+}
+
+MessageAck::~MessageAck()
+{
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,50 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef MessageAck_hpp_
+#define MessageAck_hpp_
+
+#include "command/BaseCommand.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class MessageAck : public BaseCommand
+{
+public:
+    const static int TYPE = 22 ;
+
+public:
+    MessageAck() ;
+    virtual ~MessageAck() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*MessageAck_hpp_*/
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/MessageAck.hpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.cpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.cpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,66 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "command/ProducerId.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ * Dummy, should be auto-generated
+ */
+ProducerId::ProducerId()
+{
+    connectionId = new string() ;
+}
+
+ProducerId::~ProducerId()
+{
+}
+
+int ProducerId::getCommandType()
+{
+    return ProducerId::TYPE ;
+}
+
+void ProducerId::setValue(long producerId)
+{
+    this->producerId = producerId ;
+}
+
+long ProducerId::getValue()
+{
+    return producerId ;
+}
+
+long ProducerId::getSessionId()
+{
+    return sessionId ;
+}
+
+void ProducerId::setSessionId(long sessionId)
+{
+    this->sessionId = sessionId ;
+}
+
+p<string> ProducerId::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ProducerId::setConnectionId(const char* connectionId)
+{
+    this->connectionId->assign( connectionId ) ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.cpp
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.hpp?rev=377433&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.hpp Mon Feb 13 09:43:48 2006
@@ -0,0 +1,66 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ProducerId_hpp_
+#define ProducerId_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+
+/*
+ * Dummy, should be auto-generated.
+ */
+class ProducerId : public AbstractCommand
+{
+private:
+    p<string> connectionId ;
+    long      sessionId,
+              producerId ;
+
+    const static int TYPE = 123 ;
+
+public:
+    ProducerId() ;
+    virtual ~ProducerId() ;
+
+    virtual int getCommandType() ;
+    virtual void setValue(long producerId) ;
+    virtual long getValue() ;
+    virtual void setSessionId(long sessionId) ;
+    virtual long getSessionId() ;
+    virtual void setConnectionId(const char* connectionId) ;
+    virtual p<string> getConnectionId() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ProducerId_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/ProducerId.hpp
------------------------------------------------------------------------------
    svn:executable = *



Mime
View raw message