[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-commits
Subject:    svn commit: r397654 [4/12] - in /incubator/activemq/trunk/openwire-cpp: ./
From:       nmittler () apache ! org
Date:       2006-04-27 21:59:44
Message-ID: 20060427220041.43007.qmail () minotaur ! apache ! org
[Download RAW message or body]

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQMessage.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQMessage.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQMessage.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQMessage.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,104 @@
+/*
+ * 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 ActiveMQ_ActiveMQMessage_hpp_
+#define ActiveMQ_ActiveMQMessage_hpp_
+
+#include <string>
+#include "cms/IDestination.hpp"
+#include "cms/IMessage.hpp"
+#include "activemq/IAcknowledger.hpp"
+#include "activemq/command/Message.hpp"
+#include "activemq/command/LocalTransactionId.hpp"
+#include "activemq/command/XATransactionId.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/Hex.hpp"
+#include "ppr/util/MapItemHolder.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace apache::activemq;
+      using namespace apache::cms;
+      using namespace apache::ppr::io;
+      using namespace apache::ppr::util;
+
+/*
+ * 
+ */
+class ActiveMQMessage : public Message, public IMessage
+{
+private:
+    p<IAcknowledger> acknowledger ;
+    p<PropertyMap>   properties ;
+
+public:
+    const static unsigned char TYPE = 23 ;
+
+public:
+    // Attributes
+    virtual unsigned char getDataStructureType() ;
+    virtual p<IDestination> getFromDestination() ;
+    virtual void setFromDestination(p<IDestination> destination) ;
+    virtual void setAcknowledger(p<IAcknowledger> acknowledger) ;
+    virtual p<PropertyMap> getProperties() ;
+    virtual p<string> getJMSCorrelationID() ;
+    virtual void setJMSCorrelationID(const char* correlationId) ;
+    virtual p<IDestination> getJMSDestination() ;
+    virtual long long getJMSExpiration() ;
+    virtual void setJMSExpiration(long long time) ;
+    virtual p<string> getJMSMessageID() ;
+    virtual bool getJMSPersistent() ;
+    virtual void setJMSPersistent(bool persistent) ;
+    virtual unsigned char getJMSPriority() ;
+    virtual void setJMSPriority(unsigned char priority) ;
+    virtual bool getJMSRedelivered() ;
+    virtual p<IDestination> getJMSReplyTo() ;
+    virtual void setJMSReplyTo(p<IDestination> destination) ;
+    virtual long long getJMSTimestamp() ;
+    virtual p<string> getJMSType() ;
+    virtual void setJMSType(const char* type) ;
+    virtual int getJMSXDeliveryCount() ;
+    virtual p<string> getJMSXGroupID() ;
+    virtual void setJMSXGroupID(const char* groupId) ;
+    virtual int getJMSXGroupSeq() ;
+    virtual void setJMSXGroupSeq(int sequence) ;
+    virtual p<string> getJMSXProducerTxID() ;
+
+    // Operations
+    virtual void acknowledge() ;
+
+protected:
+    // Implementation
+    int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) \
throw(IOException) ; +    void unmarshal(p<IMarshaller> marshaller, int mode, \
p<IInputStream> reader) throw(IOException) ; +
+public:
+    // Static methods
+    //static p<ActiveMQMessage> transform(p<IMessage> message) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQMessage_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.cpp \
Thu Apr 27 14:59:28 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 "activemq/command/ActiveMQObjectMessage.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQObjectMessage::ActiveMQObjectMessage()
+{
+}
+
+ActiveMQObjectMessage::~ActiveMQObjectMessage()
+{
+}
+
+unsigned char ActiveMQObjectMessage::getDataStructureType()
+{
+    return ActiveMQObjectMessage::TYPE ;
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,53 @@
+/*
+ * 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 ActiveMQ_ActiveMQObjectMessage_hpp_
+#define ActiveMQ_ActiveMQObjectMessage_hpp_
+
+#include <string>
+#include "activemq/command/ActiveMQMessage.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+
+/*
+ * 
+ */
+class ActiveMQObjectMessage : public ActiveMQMessage
+{
+public:
+    const static unsigned char TYPE = 26 ;
+
+public:
+    ActiveMQObjectMessage() ;
+    virtual ~ActiveMQObjectMessage() ;
+
+    virtual unsigned char getDataStructureType() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQObjectMessage_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,75 @@
+/*
+ * 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 "activemq/command/ActiveMQQueue.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQQueue::ActiveMQQueue()
+   : ActiveMQDestination()
+{
+}
+
+/*
+ * 
+ */
+ActiveMQQueue::ActiveMQQueue(const char* name)
+   : ActiveMQDestination(name)
+{
+}
+
+/*
+ * 
+ */
+ActiveMQQueue::~ActiveMQQueue()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQQueue::getDataStructureType()
+{
+    return ActiveMQQueue::TYPE ; 
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQQueue::getQueueName()
+{
+    return this->getPhysicalName() ;
+}
+
+/*
+ * 
+ */
+int ActiveMQQueue::getDestinationType()
+{
+    return ActiveMQDestination::ACTIVEMQ_QUEUE ;
+}
+
+/*
+ * 
+ */
+p<ActiveMQDestination> ActiveMQQueue::createDestination(const char* name)
+{
+    p<ActiveMQQueue> queue = new ActiveMQQueue(name) ;
+    return queue ;
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,55 @@
+/*
+ * 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 ActiveMQ_ActiveMQQueue_hpp_
+#define ActiveMQ_ActiveMQQueue_hpp_
+
+#include "cms/IQueue.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+        using namespace apache::cms;
+
+/*
+ * 
+ */
+class ActiveMQQueue : public ActiveMQDestination, public IQueue
+{
+public:
+    const static unsigned char TYPE = 100 ;
+
+public:
+    ActiveMQQueue() ;
+    ActiveMQQueue(const char* name) ;
+    virtual ~ActiveMQQueue() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getQueueName() ;
+    virtual int getDestinationType() ;
+    virtual p<ActiveMQDestination> createDestination(const char* name) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQQueue_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.cpp \
Thu Apr 27 14:59:28 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 "activemq/command/ActiveMQStreamMessage.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQStreamMessage::ActiveMQStreamMessage()
+{
+}
+
+ActiveMQStreamMessage::~ActiveMQStreamMessage()
+{
+}
+
+unsigned char ActiveMQStreamMessage::getDataStructureType()
+{
+    return ActiveMQStreamMessage::TYPE ;
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,53 @@
+/*
+ * 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 ActiveMQ_ActiveMQStreamMessage_hpp_
+#define ActiveMQ_ActiveMQStreamMessage_hpp_
+
+#include <string>
+#include "activemq/command/ActiveMQMessage.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+
+/*
+ * 
+ */
+class ActiveMQStreamMessage : public ActiveMQMessage
+{
+public:
+    const static unsigned char TYPE = 27 ;
+
+public:
+    ActiveMQStreamMessage() ;
+    virtual ~ActiveMQStreamMessage() ;
+
+    virtual unsigned char getDataStructureType() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQStreamMessage_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,53 @@
+/*
+ * 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 "activemq/command/ActiveMQTempDestination.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTempDestination::ActiveMQTempDestination()
+   : ActiveMQDestination()
+{
+    // no-op
+}
+
+/*
+ * 
+ */
+ActiveMQTempDestination::ActiveMQTempDestination(const char* name)
+   : ActiveMQDestination(name)
+{
+    // no-op
+}
+
+/*
+ * 
+ */
+ActiveMQTempDestination::~ActiveMQTempDestination()
+{
+    // no-op
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTempDestination::getDataStructureType()
+{
+    return ActiveMQTempDestination::TYPE ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp \
Thu Apr 27 14:59:28 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 ActiveMQ_ActiveMQTempDestination_hpp_
+#define ActiveMQ_ActiveMQTempDestination_hpp_
+
+#include "activemq/command/ActiveMQDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+
+/*
+ * 
+ */
+class ActiveMQTempDestination : public ActiveMQDestination
+{
+public:
+    const static unsigned char TYPE = 0 ;
+
+public:
+    ActiveMQTempDestination() ;
+    ActiveMQTempDestination(const char* name) ;
+    virtual ~ActiveMQTempDestination() ;
+
+    virtual unsigned char getDataStructureType() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTempDestination_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,75 @@
+/*
+ * 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 "activemq/command/ActiveMQTempQueue.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTempQueue::ActiveMQTempQueue()
+   : ActiveMQTempDestination()
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTempQueue::ActiveMQTempQueue(const char* name)
+   : ActiveMQTempDestination(name)
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTempQueue::~ActiveMQTempQueue()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTempQueue::getDataStructureType()
+{
+    return ActiveMQTempQueue::TYPE ; 
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQTempQueue::getQueueName()
+{
+    return this->getPhysicalName() ;
+}
+
+/*
+ * 
+ */
+int ActiveMQTempQueue::getDestinationType()
+{
+    return ActiveMQDestination::ACTIVEMQ_QUEUE ;
+}
+
+/*
+ * 
+ */
+p<ActiveMQDestination> ActiveMQTempQueue::createDestination(const char* name)
+{
+    p<ActiveMQTempQueue> tempQueue = new ActiveMQTempQueue(name) ;
+    return tempQueue ;
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,55 @@
+/*
+ * 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 ActiveMQ_ActiveMQTempQueue_hpp_
+#define ActiveMQ_ActiveMQTempQueue_hpp_
+
+#include "cms/ITemporaryQueue.hpp"
+#include "activemq/command/ActiveMQTempDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+        using namespace apache::cms;
+
+/*
+ * 
+ */
+class ActiveMQTempQueue : public ActiveMQTempDestination, public ITemporaryQueue
+{
+public:
+    const static unsigned char TYPE = 102 ;
+
+public:
+    ActiveMQTempQueue() ;
+    ActiveMQTempQueue(const char* name) ;
+    virtual ~ActiveMQTempQueue() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getQueueName() ;
+    virtual int getDestinationType() ;
+    virtual p<ActiveMQDestination> createDestination(const char* name) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTempQueue_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,75 @@
+/*
+ * 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 "activemq/command/ActiveMQTempTopic.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTempTopic::ActiveMQTempTopic()
+   : ActiveMQTempDestination()
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTempTopic::ActiveMQTempTopic(const char* name)
+   : ActiveMQTempDestination(name)
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTempTopic::~ActiveMQTempTopic()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTempTopic::getDataStructureType()
+{
+    return ActiveMQTempTopic::TYPE ; 
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQTempTopic::getTopicName()
+{
+    return this->getPhysicalName() ;
+}
+
+/*
+ * 
+ */
+int ActiveMQTempTopic::getDestinationType()
+{
+    return ActiveMQDestination::ACTIVEMQ_TOPIC ;
+}
+
+/*
+ * 
+ */
+p<ActiveMQDestination> ActiveMQTempTopic::createDestination(const char* name)
+{
+    p<ActiveMQTempTopic> tempTopic = new ActiveMQTempTopic(name) ;
+    return tempTopic ;
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,55 @@
+/*
+ * 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 ActiveMQ_ActiveMQTempTopic_hpp_
+#define ActiveMQ_ActiveMQTempTopic_hpp_
+
+#include "cms/ITemporaryTopic.hpp"
+#include "activemq/command/ActiveMQTempDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+        using namespace apache::cms;
+
+/*
+ * 
+ */
+class ActiveMQTempTopic : public ActiveMQTempDestination, public ITemporaryTopic
+{
+public:
+    const static unsigned char TYPE = 103 ;
+
+public:
+    ActiveMQTempTopic() ;
+    ActiveMQTempTopic(const char* name) ;
+    virtual ~ActiveMQTempTopic() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getTopicName() ;
+    virtual int getDestinationType() ;
+    virtual p<ActiveMQDestination> createDestination(const char* name) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTempTopic_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,98 @@
+/*
+ * 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 "activemq/command/ActiveMQTextMessage.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTextMessage::ActiveMQTextMessage()
+{
+    setText(NULL) ;
+}
+
+/*
+ * 
+ */
+ActiveMQTextMessage::ActiveMQTextMessage(const char* text)
+{
+    setText(text) ;
+}
+
+/*
+ * 
+ */
+ActiveMQTextMessage::~ActiveMQTextMessage()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTextMessage::getDataStructureType()
+{
+    return ActiveMQTextMessage::TYPE ;
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQTextMessage::getText()
+{
+    // Extract text from message content
+    if( this->content.size() > 0 )
+    {
+        int utflen = 0 ;
+        char* buffer = this->content.c_array() ;
+
+        // TODO: assuming that the text is ASCII
+        utflen |= (char) ((buffer[0] << 24) & 0xFF) ;
+        utflen |= (char) ((buffer[1] >> 16) & 0xFF);
+        utflen |= (char) ((buffer[2] >> 8) & 0xFF);
+        utflen |= (char) ((buffer[3] >> 0) & 0xFF);
+
+        p<string> text = new string( buffer + 4, this->content.size() - 4 ) ;
+        return text ;
+    }
+    return NULL ;
+}
+
+/*
+ * 
+ */
+void ActiveMQTextMessage::setText(const char* text)
+{
+    if( text != NULL )
+    {
+        int length = (int)strlen(text) ;
+        int utflen = length ;
+
+        // TODO: assuming that the text is ASCII
+        this->content = array<char> (length + 4) ;
+
+        this->content[0] = (char) ((utflen >> 24) & 0xFF) ;
+        this->content[1] = (char) ((utflen >> 16) & 0xFF);
+        this->content[2] = (char) ((utflen >> 8) & 0xFF);
+        this->content[3] = (char) ((utflen >> 0) & 0xFF);
+
+        for( int i = 0 ; i < length ; i++ )
+            this->content[4+i] = text[i] ;
+    }
+    else
+        this->content = NULL ;
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,135 @@
+/*
+ * 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 ActiveMQ_ActiveMQTextMessage_hpp_
+#define ActiveMQ_ActiveMQTextMessage_hpp_
+
+#include <string>
+#include "cms/ITextMessage.hpp"
+#include "activemq/command/ActiveMQMessage.hpp"
+#include "ppr/util/MapItemHolder.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace apache::cms;
+      using namespace apache::ppr::util;
+
+/*
+ * 
+ */
+class ActiveMQTextMessage : public ActiveMQMessage, public ITextMessage
+{
+public:
+    const static unsigned char TYPE = 28 ;
+
+public:
+    ActiveMQTextMessage() ;
+    ActiveMQTextMessage(const char* text) ;
+    virtual ~ActiveMQTextMessage() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getText() ;
+    virtual void setText(const char* text) ;
+
+    //
+    // The methods below are needed to resolve the multiple
+    // inheritance of IMessage.
+    virtual void acknowledge() {
+        ActiveMQMessage::acknowledge() ;
+    } ;
+    virtual p<PropertyMap> getProperties() {
+        return ActiveMQMessage::getProperties() ;
+    } ;
+    virtual p<string> getJMSCorrelationID() {
+        return ActiveMQMessage::getJMSCorrelationID() ;
+    } ;
+    virtual void setJMSCorrelationID(const char* correlationId) {
+        return ActiveMQMessage::setJMSCorrelationID(correlationId) ;
+    } ;
+    virtual p<IDestination> getJMSDestination() {
+        return ActiveMQMessage::getJMSDestination() ;
+    } ;
+    virtual long long getJMSExpiration() {
+        return ActiveMQMessage::getJMSExpiration() ;
+    } ;
+    virtual void setJMSExpiration(long long time) {
+        return ActiveMQMessage::setJMSExpiration(time) ;
+    } ;
+    virtual p<string> getJMSMessageID() {
+        return ActiveMQMessage::getJMSMessageID() ;
+    } ;
+    virtual bool getJMSPersistent() {
+        return ActiveMQMessage::getJMSPersistent() ;
+    } ;
+    virtual void setJMSPersistent(bool persistent) {
+        return ActiveMQMessage::setJMSPersistent(persistent) ;
+    } ;
+    virtual unsigned char getJMSPriority() {
+        return ActiveMQMessage::getJMSPriority() ;
+    } ;
+    virtual void setJMSPriority(unsigned char priority) {
+        return ActiveMQMessage::setJMSPriority(priority) ;
+    } ;
+    virtual bool getJMSRedelivered() {
+        return ActiveMQMessage::getJMSRedelivered() ;
+    } ;
+    virtual p<IDestination> getJMSReplyTo() {
+        return ActiveMQMessage::getJMSReplyTo() ;
+    } ;
+    virtual void setJMSReplyTo(p<IDestination> destination) {
+        return ActiveMQMessage::setJMSReplyTo(destination) ;
+    } ;
+    virtual long long getJMSTimestamp() {
+        return ActiveMQMessage::getJMSTimestamp() ;
+    } ;
+    virtual p<string> getJMSType() {
+        return ActiveMQMessage::getJMSType() ;
+    } ;
+    virtual void setJMSType(const char* type) {
+        return ActiveMQMessage::setJMSType(type) ;
+    } ;
+    virtual int getJMSXDeliveryCount() {
+        return ActiveMQMessage::getJMSXDeliveryCount() ;
+    } ;
+    virtual p<string> getJMSXGroupID() {
+        return ActiveMQMessage::getJMSXGroupID() ;
+    } ;
+    virtual void setJMSXGroupID(const char* groupId) {
+        return ActiveMQMessage::setJMSXGroupID(groupId) ;
+    } ;
+    virtual int getJMSXGroupSeq() {
+        return ActiveMQMessage::getJMSXGroupSeq() ;
+    } ;
+    virtual void setJMSXGroupSeq(int sequence) {
+        return ActiveMQMessage::setJMSXGroupSeq(sequence) ;
+    } ;
+    virtual p<string> getJMSXProducerTxID() {
+        return ActiveMQMessage::getJMSXProducerTxID() ;
+    } ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTextMessage_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,75 @@
+/*
+ * 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 "activemq/command/ActiveMQTopic.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTopic::ActiveMQTopic()
+   : ActiveMQDestination()
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTopic::ActiveMQTopic(const char* name)
+   : ActiveMQDestination(name)
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTopic::~ActiveMQTopic()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTopic::getDataStructureType()
+{
+    return ActiveMQTopic::TYPE ; 
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQTopic::getTopicName()
+{
+    return this->getPhysicalName() ;
+}
+
+/*
+ * 
+ */
+int ActiveMQTopic::getDestinationType()
+{
+    return ActiveMQDestination::ACTIVEMQ_TOPIC ;
+}
+
+/*
+ * 
+ */
+p<ActiveMQDestination> ActiveMQTopic::createDestination(const char* name)
+{
+    p<ActiveMQTopic> topic = new ActiveMQTopic(name) ;
+    return topic ;
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,55 @@
+/*
+ * 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 ActiveMQ_ActiveMQTopic_hpp_
+#define ActiveMQ_ActiveMQTopic_hpp_
+
+#include "cms/ITopic.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace apache::cms;
+
+/*
+ * 
+ */
+class ActiveMQTopic : public ActiveMQDestination, public ITopic
+{
+public:
+    const static unsigned char TYPE = 101 ;
+
+public:
+    ActiveMQTopic() ;
+    ActiveMQTopic(const char* name) ;
+    virtual ~ActiveMQTopic() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getTopicName() ;
+    virtual int getDestinationType() ;
+    virtual p<ActiveMQDestination> createDestination(const char* name) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTopic_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp \
Thu Apr 27 14:59:28 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.
+ */
+#include "activemq/command/BaseCommand.hpp"
+
+using namespace apache::activemq::command;
+
+
+// Attribute methods ------------------------------------------------
+
+int BaseCommand::getHashCode()
+{
+    return ( commandId * 38 ) + getDataStructureType() ;
+}
+
+
+// Operation methods ------------------------------------------------
+
+bool BaseCommand::operator== (BaseCommand& that)
+{
+    if( this->getDataStructureType() == that.getDataStructureType() &&
+        this->commandId == that.commandId )
+    {
+        return true ;
+    }
+    return false ;
+}
+
+p<string> BaseCommand::toString()
+{
+    p<string> str = new string() ;
+    char      buffer[10] ;
+    
+    str->assign( getDataStructureTypeAsString( getDataStructureType() )->c_str() ) ;
+
+    if( str->length() == 0 )
+        str->assign("") ;
+
+    str->append(": id = ") ;
+	sprintf(buffer, "%d", commandId) ;
+    str->append( buffer ) ;
+
+    return str ;
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp \
Thu Apr 27 14:59:28 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 ActiveMQ_BaseCommand_hpp_
+#define ActiveMQ_BaseCommand_hpp_
+
+#include <string>
+#include "activemq/command/AbstractCommand.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+
+/*
+ * 
+ */
+class BaseCommand : public AbstractCommand
+{
+public:
+    // Equals operator
+    bool operator== (BaseCommand& other) ;
+
+    virtual int getHashCode() ;
+    virtual p<string> toString() ;
+};
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_BaseCommand_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp \
Thu Apr 27 14:59:28 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 ActiveMQ_BooleanExpression_hpp_
+#define ActiveMQ_BooleanExpression_hpp_
+
+#include "activemq/command/BaseCommand.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+
+/*
+ * 
+ */
+class BooleanExpression : public BaseCommand
+{
+protected:
+
+protected:
+    BooleanExpression() {}
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_BooleanExpression_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,126 @@
+/*
+ * 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 "activemq/command/BrokerError.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+BrokerError::BrokerError()
+{
+    message            = new string() ;
+    exceptionClass     = new string() ;
+    stackTraceElements = NULL ;
+    cause              = NULL ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getMessage()
+{
+    return message ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setMessage(const char* msg)
+{
+    this->message->assign(msg) ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getExceptionClass()
+{
+    return exceptionClass ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setExceptionClass(const char* exClass)
+{
+    this->exceptionClass->assign(exClass) ;
+}
+
+/*
+ * 
+ */
+array<StackTraceElement> BrokerError::getStackTraceElements()
+{
+    return stackTraceElements ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setStackTraceElements(array<StackTraceElement> elements)
+{
+    this->stackTraceElements = elements ;
+}
+
+/*
+ * 
+ */
+p<BrokerError> BrokerError::getCause()
+{
+    return cause ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setCause(p<BrokerError> cause)
+{
+    this->cause = cause ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getStackTrace()
+{
+    ostringstream sstream ;
+    p<string> trace ;
+    printStackTrace(sstream) ;
+    trace = new string (sstream.str());
+    return trace ;
+}
+
+/*
+ * 
+ */
+void BrokerError::printStackTrace(ostream& out)
+{
+    out << getptr(exceptionClass) << ": " << getptr(message) << endl ;
+
+    for( size_t i = 0; i < sizeof(stackTraceElements)/sizeof(stackTraceElements[0]); \
i++ ) +    {
+        p<StackTraceElement> element = stackTraceElements[i] ;
+        out << "    at " << getptr(element->className) << "." << \
getptr(element->methodName) << "(" << getptr(element->fileName) << ":" << \
element->lineNumber << ")" << endl ; +    }
+    // Dump any nested exceptions
+    if( cause != NULL )
+    {
+        out << "Nested Exception:" << endl ;
+        cause->printStackTrace(out) ;
+    }
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,78 @@
+/*
+ * 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 ActiveMQ_BrokerError_hpp_
+#define ActiveMQ_BrokerError_hpp_
+
+#include <string>
+#include <ostream>
+#include <sstream>
+#include "activemq/command/AbstractCommand.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr ;
+      using namespace std ;
+
+/*
+ * 
+ */
+struct StackTraceElement
+{
+    p<string> className ;
+    p<string> fileName ;
+    p<string> methodName ;
+    int lineNumber ;
+} ;
+
+/*
+ * Represents an exception on the broker.
+ */
+class BrokerError : public AbstractCommand
+{
+private:
+    p<string>             message ;
+    p<string>             exceptionClass ;
+    array<StackTraceElement> stackTraceElements ;
+    p<BrokerError>        cause ;
+
+public:
+    BrokerError() ;
+
+    virtual p<string> getMessage() ;
+    virtual void setMessage(const char* msg) ;
+    virtual p<string> getExceptionClass() ;
+    virtual void setExceptionClass(const char* exClass) ;
+    virtual array<StackTraceElement> getStackTraceElements() ;
+    virtual void setStackTraceElements(array<StackTraceElement> elements) ;
+    virtual p<BrokerError> getCause() ;
+    virtual void setCause(p<BrokerError> cause) ;
+    virtual p<string> getStackTrace() ;
+    virtual void printStackTrace(ostream& out) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_BrokerError_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,67 @@
+/*
+* 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 "activemq/command/BrokerId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for BrokerId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+BrokerId::BrokerId()
+{
+    this->value = NULL ;
+}
+
+BrokerId::~BrokerId()
+{
+}
+
+unsigned char BrokerId::getDataStructureType()
+{
+    return BrokerId::TYPE ; 
+}
+
+        
+p<string> BrokerId::getValue()
+{
+    return value ;
+}
+
+void BrokerId::setValue(p<string> value)
+{
+    this->value = value ;
+}
+
+int BrokerId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) \
throw (IOException) +{
+    int size = 0 ;
+
+    size += marshaller->marshalString(value, mode, writer) ; 
+    return size ;
+}
+
+void BrokerId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> \
reader) throw (IOException) +{
+    value = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,82 @@
+/*
+* 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 ActiveMQ_BrokerId_hpp_
+#define ActiveMQ_BrokerId_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/AbstractCommand.hpp"
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for BrokerId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class BrokerId : public AbstractCommand
+{
+protected:
+    p<string> value ;
+
+public:
+    const static unsigned char TYPE = 124;
+
+public:
+    BrokerId() ;
+    virtual ~BrokerId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<string> getValue() ;
+    virtual void setValue(p<string> value) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) ; +    virtual void unmarshal(p<IMarshaller> marshaller, \
int mode, p<IInputStream> reader) throw (IOException) ; +} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_BrokerId_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,127 @@
+/*
+* 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 "activemq/command/BrokerInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for BrokerInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+BrokerInfo::BrokerInfo()
+{
+    this->brokerId = NULL ;
+    this->brokerURL = NULL ;
+    this->peerBrokerInfos = NULL ;
+    this->brokerName = NULL ;
+    this->slaveBroker = false ;
+}
+
+BrokerInfo::~BrokerInfo()
+{
+}
+
+unsigned char BrokerInfo::getDataStructureType()
+{
+    return BrokerInfo::TYPE ; 
+}
+
+        
+p<BrokerId> BrokerInfo::getBrokerId()
+{
+    return brokerId ;
+}
+
+void BrokerInfo::setBrokerId(p<BrokerId> brokerId)
+{
+    this->brokerId = brokerId ;
+}
+
+        
+p<string> BrokerInfo::getBrokerURL()
+{
+    return brokerURL ;
+}
+
+void BrokerInfo::setBrokerURL(p<string> brokerURL)
+{
+    this->brokerURL = brokerURL ;
+}
+
+        
+array<BrokerInfo> BrokerInfo::getPeerBrokerInfos()
+{
+    return peerBrokerInfos ;
+}
+
+void BrokerInfo::setPeerBrokerInfos(array<BrokerInfo> peerBrokerInfos)
+{
+    this->peerBrokerInfos = peerBrokerInfos ;
+}
+
+        
+p<string> BrokerInfo::getBrokerName()
+{
+    return brokerName ;
+}
+
+void BrokerInfo::setBrokerName(p<string> brokerName)
+{
+    this->brokerName = brokerName ;
+}
+
+        
+bool BrokerInfo::getSlaveBroker()
+{
+    return slaveBroker ;
+}
+
+void BrokerInfo::setSlaveBroker(bool slaveBroker)
+{
+    this->slaveBroker = slaveBroker ;
+}
+
+int BrokerInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) +{
+    int size = 0 ;
+
+    size += marshaller->marshalInt(commandId, mode, writer) ;
+    size += marshaller->marshalBoolean(responseRequired, mode, writer) ; 
+    size += marshaller->marshalObject(brokerId, mode, writer) ; 
+    size += marshaller->marshalString(brokerURL, mode, writer) ; 
+    size += marshaller->marshalObjectArray(peerBrokerInfos, mode, writer) ; 
+    size += marshaller->marshalString(brokerName, mode, writer) ; 
+    size += marshaller->marshalBoolean(slaveBroker, mode, writer) ; 
+    return size ;
+}
+
+void BrokerInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> \
reader) throw (IOException) +{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    brokerId = p_cast<BrokerId>(marshaller->unmarshalObject(mode, reader)) ; 
+    brokerURL = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    peerBrokerInfos = array_cast<BrokerInfo>(marshaller->unmarshalObjectArray(mode, \
reader)) ;  +    brokerName = p_cast<string>(marshaller->unmarshalString(mode, \
reader)) ;  +    slaveBroker = (marshaller->unmarshalBoolean(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,100 @@
+/*
+* 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 ActiveMQ_BrokerInfo_hpp_
+#define ActiveMQ_BrokerInfo_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/BrokerId.hpp"
+#include "activemq/command/BrokerInfo.hpp"
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for BrokerInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class BrokerInfo : public BaseCommand
+{
+protected:
+    p<BrokerId> brokerId ;
+    p<string> brokerURL ;
+    array<BrokerInfo> peerBrokerInfos ;
+    p<string> brokerName ;
+    bool slaveBroker ;
+
+public:
+    const static unsigned char TYPE = 2;
+
+public:
+    BrokerInfo() ;
+    virtual ~BrokerInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<BrokerId> getBrokerId() ;
+    virtual void setBrokerId(p<BrokerId> brokerId) ;
+
+    virtual p<string> getBrokerURL() ;
+    virtual void setBrokerURL(p<string> brokerURL) ;
+
+    virtual array<BrokerInfo> getPeerBrokerInfos() ;
+    virtual void setPeerBrokerInfos(array<BrokerInfo> peerBrokerInfos) ;
+
+    virtual p<string> getBrokerName() ;
+    virtual void setBrokerName(p<string> brokerName) ;
+
+    virtual bool getSlaveBroker() ;
+    virtual void setSlaveBroker(bool slaveBroker) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) ; +    virtual void unmarshal(p<IMarshaller> marshaller, \
int mode, p<IInputStream> reader) throw (IOException) ; +} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_BrokerInfo_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.cpp \
Thu Apr 27 14:59:28 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 "activemq/command/ConnectionError.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionError
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+ConnectionError::ConnectionError()
+{
+    this->exception = NULL ;
+    this->connectionId = NULL ;
+}
+
+ConnectionError::~ConnectionError()
+{
+}
+
+unsigned char ConnectionError::getDataStructureType()
+{
+    return ConnectionError::TYPE ; 
+}
+
+        
+p<BrokerError> ConnectionError::getException()
+{
+    return exception ;
+}
+
+void ConnectionError::setException(p<BrokerError> exception)
+{
+    this->exception = exception ;
+}
+
+        
+p<ConnectionId> ConnectionError::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ConnectionError::setConnectionId(p<ConnectionId> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+int ConnectionError::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) +{
+    int size = 0 ;
+
+    size += marshaller->marshalInt(commandId, mode, writer) ;
+    size += marshaller->marshalBoolean(responseRequired, mode, writer) ; 
+    size += marshaller->marshalObject(exception, mode, writer) ; 
+    size += marshaller->marshalObject(connectionId, mode, writer) ; 
+    return size ;
+}
+
+void ConnectionError::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> \
reader) throw (IOException) +{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    exception = p_cast<BrokerError>(marshaller->unmarshalObject(mode, reader)) ; 
+    connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, reader)) ; \
 +}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,88 @@
+/*
+* 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 ActiveMQ_ConnectionError_hpp_
+#define ActiveMQ_ConnectionError_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/BrokerError.hpp"
+#include "activemq/command/ConnectionId.hpp"
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionError
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ConnectionError : public BaseCommand
+{
+protected:
+    p<BrokerError> exception ;
+    p<ConnectionId> connectionId ;
+
+public:
+    const static unsigned char TYPE = 16;
+
+public:
+    ConnectionError() ;
+    virtual ~ConnectionError() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<BrokerError> getException() ;
+    virtual void setException(p<BrokerError> exception) ;
+
+    virtual p<ConnectionId> getConnectionId() ;
+    virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) ; +    virtual void unmarshal(p<IMarshaller> marshaller, \
int mode, p<IInputStream> reader) throw (IOException) ; +} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ConnectionError_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,67 @@
+/*
+* 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 "activemq/command/ConnectionId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+ConnectionId::ConnectionId()
+{
+    this->value = NULL ;
+}
+
+ConnectionId::~ConnectionId()
+{
+}
+
+unsigned char ConnectionId::getDataStructureType()
+{
+    return ConnectionId::TYPE ; 
+}
+
+        
+p<string> ConnectionId::getValue()
+{
+    return value ;
+}
+
+void ConnectionId::setValue(p<string> value)
+{
+    this->value = value ;
+}
+
+int ConnectionId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) +{
+    int size = 0 ;
+
+    size += marshaller->marshalString(value, mode, writer) ; 
+    return size ;
+}
+
+void ConnectionId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> \
reader) throw (IOException) +{
+    value = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,82 @@
+/*
+* 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 ActiveMQ_ConnectionId_hpp_
+#define ActiveMQ_ConnectionId_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/AbstractCommand.hpp"
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ConnectionId : public AbstractCommand
+{
+protected:
+    p<string> value ;
+
+public:
+    const static unsigned char TYPE = 120;
+
+public:
+    ConnectionId() ;
+    virtual ~ConnectionId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<string> getValue() ;
+    virtual void setValue(p<string> value) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) ; +    virtual void unmarshal(p<IMarshaller> marshaller, \
int mode, p<IInputStream> reader) throw (IOException) ; +} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ConnectionId_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.cpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,127 @@
+/*
+* 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 "activemq/command/ConnectionInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+ConnectionInfo::ConnectionInfo()
+{
+    this->connectionId = NULL ;
+    this->clientId = NULL ;
+    this->password = NULL ;
+    this->userName = NULL ;
+    this->brokerPath = NULL ;
+}
+
+ConnectionInfo::~ConnectionInfo()
+{
+}
+
+unsigned char ConnectionInfo::getDataStructureType()
+{
+    return ConnectionInfo::TYPE ; 
+}
+
+        
+p<ConnectionId> ConnectionInfo::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ConnectionInfo::setConnectionId(p<ConnectionId> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+        
+p<string> ConnectionInfo::getClientId()
+{
+    return clientId ;
+}
+
+void ConnectionInfo::setClientId(p<string> clientId)
+{
+    this->clientId = clientId ;
+}
+
+        
+p<string> ConnectionInfo::getPassword()
+{
+    return password ;
+}
+
+void ConnectionInfo::setPassword(p<string> password)
+{
+    this->password = password ;
+}
+
+        
+p<string> ConnectionInfo::getUserName()
+{
+    return userName ;
+}
+
+void ConnectionInfo::setUserName(p<string> userName)
+{
+    this->userName = userName ;
+}
+
+        
+array<BrokerId> ConnectionInfo::getBrokerPath()
+{
+    return brokerPath ;
+}
+
+void ConnectionInfo::setBrokerPath(array<BrokerId> brokerPath)
+{
+    this->brokerPath = brokerPath ;
+}
+
+int ConnectionInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) +{
+    int size = 0 ;
+
+    size += marshaller->marshalInt(commandId, mode, writer) ;
+    size += marshaller->marshalBoolean(responseRequired, mode, writer) ; 
+    size += marshaller->marshalObject(connectionId, mode, writer) ; 
+    size += marshaller->marshalString(clientId, mode, writer) ; 
+    size += marshaller->marshalString(password, mode, writer) ; 
+    size += marshaller->marshalString(userName, mode, writer) ; 
+    size += marshaller->marshalObjectArray(brokerPath, mode, writer) ; 
+    return size ;
+}
+
+void ConnectionInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> \
reader) throw (IOException) +{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, reader)) ; \
 +    clientId = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    password = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    userName = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, \
reader)) ;  +}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,100 @@
+/*
+* 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 ActiveMQ_ConnectionInfo_hpp_
+#define ActiveMQ_ConnectionInfo_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/ConnectionId.hpp"
+#include "activemq/command/BrokerId.hpp"
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ConnectionInfo : public BaseCommand
+{
+protected:
+    p<ConnectionId> connectionId ;
+    p<string> clientId ;
+    p<string> password ;
+    p<string> userName ;
+    array<BrokerId> brokerPath ;
+
+public:
+    const static unsigned char TYPE = 3;
+
+public:
+    ConnectionInfo() ;
+    virtual ~ConnectionInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ConnectionId> getConnectionId() ;
+    virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+    virtual p<string> getClientId() ;
+    virtual void setClientId(p<string> clientId) ;
+
+    virtual p<string> getPassword() ;
+    virtual void setPassword(p<string> password) ;
+
+    virtual p<string> getUserName() ;
+    virtual void setUserName(p<string> userName) ;
+
+    virtual array<BrokerId> getBrokerPath() ;
+    virtual void setBrokerPath(array<BrokerId> brokerPath) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) ; +    virtual void unmarshal(p<IMarshaller> marshaller, \
int mode, p<IInputStream> reader) throw (IOException) ; +} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ConnectionInfo_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.cpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.cpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.cpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.cpp \
Thu Apr 27 14:59:28 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 "activemq/command/ConsumerId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConsumerId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+ConsumerId::ConsumerId()
+{
+    this->connectionId = NULL ;
+    this->sessionId = 0 ;
+    this->value = 0 ;
+}
+
+ConsumerId::~ConsumerId()
+{
+}
+
+unsigned char ConsumerId::getDataStructureType()
+{
+    return ConsumerId::TYPE ; 
+}
+
+        
+p<string> ConsumerId::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ConsumerId::setConnectionId(p<string> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+        
+long long ConsumerId::getSessionId()
+{
+    return sessionId ;
+}
+
+void ConsumerId::setSessionId(long long sessionId)
+{
+    this->sessionId = sessionId ;
+}
+
+        
+long long ConsumerId::getValue()
+{
+    return value ;
+}
+
+void ConsumerId::setValue(long long value)
+{
+    this->value = value ;
+}
+
+int ConsumerId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) +{
+    int size = 0 ;
+
+    size += marshaller->marshalString(connectionId, mode, writer) ; 
+    size += marshaller->marshalLong(sessionId, mode, writer) ; 
+    size += marshaller->marshalLong(value, mode, writer) ; 
+    return size ;
+}
+
+void ConsumerId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> \
reader) throw (IOException) +{
+    connectionId = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    sessionId = (marshaller->unmarshalLong(mode, reader)) ; 
+    value = (marshaller->unmarshalLong(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.hpp
                
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.hpp?rev=397654&view=auto
 ==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.hpp \
                (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.hpp \
Thu Apr 27 14:59:28 2006 @@ -0,0 +1,90 @@
+/*
+* 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 ActiveMQ_ConsumerId_hpp_
+#define ActiveMQ_ConsumerId_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/AbstractCommand.hpp"
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConsumerId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ConsumerId : public AbstractCommand
+{
+protected:
+    p<string> connectionId ;
+    long long sessionId ;
+    long long value ;
+
+public:
+    const static unsigned char TYPE = 122;
+
+public:
+    ConsumerId() ;
+    virtual ~ConsumerId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<string> getConnectionId() ;
+    virtual void setConnectionId(p<string> connectionId) ;
+
+    virtual long long getSessionId() ;
+    virtual void setSessionId(long long sessionId) ;
+
+    virtual long long getValue() ;
+    virtual void setValue(long long value) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> \
writer) throw (IOException) ; +    virtual void unmarshal(p<IMarshaller> marshaller, \
int mode, p<IInputStream> reader) throw (IOException) ; +} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ConsumerId_hpp_*/


[prev in list] [next in list] [prev in thread] [next in thread]