svn commit: r397654 [6/12] - in /incubator/activemq/trunk/openwire-cpp: ./ src/ src/command/ src/gram/ src/gram/java/ src/gram/java/org/ src/gram/java/org/apache/ src/gram/java/org/apache/activemq/ src/gram/java/org/apache/activemq/openwire/ src/gram/j...

[nm...@apache.org]

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.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_KeepAliveInfo_hpp_
+#define ActiveMQ_KeepAliveInfo_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 KeepAliveInfo
+ *
+ *
+ *  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 KeepAliveInfo : public AbstractCommand
+{
+protected:
+
+public:
+    const static unsigned char TYPE = 10;
+
+public:
+    KeepAliveInfo() ;
+    virtual ~KeepAliveInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    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_KeepAliveInfo_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.cpp Thu Apr 27 14:59:28 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.
+*/
+#include "activemq/command/LocalTransactionId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for LocalTransactionId
+ *
+ *
+ *  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
+ *
+ */
+LocalTransactionId::LocalTransactionId()
+{
+    this->value = 0 ;
+    this->connectionId = NULL ;
+}
+
+LocalTransactionId::~LocalTransactionId()
+{
+}
+
+unsigned char LocalTransactionId::getDataStructureType()
+{
+    return LocalTransactionId::TYPE ; 
+}
+
+        
+long long LocalTransactionId::getValue()
+{
+    return value ;
+}
+
+void LocalTransactionId::setValue(long long value)
+{
+    this->value = value ;
+}
+
+        
+p<ConnectionId> LocalTransactionId::getConnectionId()
+{
+    return connectionId ;
+}
+
+void LocalTransactionId::setConnectionId(p<ConnectionId> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+int LocalTransactionId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
+{
+    int size = 0 ;
+
+    size += marshaller->marshalLong(value, mode, writer) ; 
+    size += marshaller->marshalObject(connectionId, mode, writer) ; 
+    return size ;
+}
+
+void LocalTransactionId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    value = (marshaller->unmarshalLong(mode, reader)) ; 
+    connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,87 @@
+/*
+* 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_LocalTransactionId_hpp_
+#define ActiveMQ_LocalTransactionId_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/TransactionId.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 LocalTransactionId
+ *
+ *
+ *  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 LocalTransactionId : public TransactionId
+{
+protected:
+    long long value ;
+    p<ConnectionId> connectionId ;
+
+public:
+    const static unsigned char TYPE = 111;
+
+public:
+    LocalTransactionId() ;
+    virtual ~LocalTransactionId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual long long getValue() ;
+    virtual void setValue(long long value) ;
+
+    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_LocalTransactionId_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,407 @@
+/*
+* 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/Message.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for Message
+ *
+ *
+ *  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
+ *
+ */
+Message::Message()
+{
+    this->producerId = NULL ;
+    this->destination = NULL ;
+    this->transactionId = NULL ;
+    this->originalDestination = NULL ;
+    this->messageId = NULL ;
+    this->originalTransactionId = NULL ;
+    this->groupID = NULL ;
+    this->groupSequence = 0 ;
+    this->correlationId = NULL ;
+    this->persistent = false ;
+    this->expiration = 0 ;
+    this->priority = 0 ;
+    this->replyTo = NULL ;
+    this->timestamp = 0 ;
+    this->type = NULL ;
+    this->content = NULL ;
+    this->marshalledProperties = NULL ;
+    this->dataStructure = NULL ;
+    this->targetConsumerId = NULL ;
+    this->compressed = false ;
+    this->redeliveryCounter = 0 ;
+    this->brokerPath = NULL ;
+    this->arrival = 0 ;
+    this->userID = NULL ;
+    this->recievedByDFBridge = false ;
+}
+
+Message::~Message()
+{
+}
+
+unsigned char Message::getDataStructureType()
+{
+    return Message::TYPE ; 
+}
+
+        
+p<ProducerId> Message::getProducerId()
+{
+    return producerId ;
+}
+
+void Message::setProducerId(p<ProducerId> producerId)
+{
+    this->producerId = producerId ;
+}
+
+        
+p<ActiveMQDestination> Message::getDestination()
+{
+    return destination ;
+}
+
+void Message::setDestination(p<ActiveMQDestination> destination)
+{
+    this->destination = destination ;
+}
+
+        
+p<TransactionId> Message::getTransactionId()
+{
+    return transactionId ;
+}
+
+void Message::setTransactionId(p<TransactionId> transactionId)
+{
+    this->transactionId = transactionId ;
+}
+
+        
+p<ActiveMQDestination> Message::getOriginalDestination()
+{
+    return originalDestination ;
+}
+
+void Message::setOriginalDestination(p<ActiveMQDestination> originalDestination)
+{
+    this->originalDestination = originalDestination ;
+}
+
+        
+p<MessageId> Message::getMessageId()
+{
+    return messageId ;
+}
+
+void Message::setMessageId(p<MessageId> messageId)
+{
+    this->messageId = messageId ;
+}
+
+        
+p<TransactionId> Message::getOriginalTransactionId()
+{
+    return originalTransactionId ;
+}
+
+void Message::setOriginalTransactionId(p<TransactionId> originalTransactionId)
+{
+    this->originalTransactionId = originalTransactionId ;
+}
+
+        
+p<string> Message::getGroupID()
+{
+    return groupID ;
+}
+
+void Message::setGroupID(p<string> groupID)
+{
+    this->groupID = groupID ;
+}
+
+        
+int Message::getGroupSequence()
+{
+    return groupSequence ;
+}
+
+void Message::setGroupSequence(int groupSequence)
+{
+    this->groupSequence = groupSequence ;
+}
+
+        
+p<string> Message::getCorrelationId()
+{
+    return correlationId ;
+}
+
+void Message::setCorrelationId(p<string> correlationId)
+{
+    this->correlationId = correlationId ;
+}
+
+        
+bool Message::getPersistent()
+{
+    return persistent ;
+}
+
+void Message::setPersistent(bool persistent)
+{
+    this->persistent = persistent ;
+}
+
+        
+long long Message::getExpiration()
+{
+    return expiration ;
+}
+
+void Message::setExpiration(long long expiration)
+{
+    this->expiration = expiration ;
+}
+
+        
+char Message::getPriority()
+{
+    return priority ;
+}
+
+void Message::setPriority(char priority)
+{
+    this->priority = priority ;
+}
+
+        
+p<ActiveMQDestination> Message::getReplyTo()
+{
+    return replyTo ;
+}
+
+void Message::setReplyTo(p<ActiveMQDestination> replyTo)
+{
+    this->replyTo = replyTo ;
+}
+
+        
+long long Message::getTimestamp()
+{
+    return timestamp ;
+}
+
+void Message::setTimestamp(long long timestamp)
+{
+    this->timestamp = timestamp ;
+}
+
+        
+p<string> Message::getType()
+{
+    return type ;
+}
+
+void Message::setType(p<string> type)
+{
+    this->type = type ;
+}
+
+        
+array<char> Message::getContent()
+{
+    return content ;
+}
+
+void Message::setContent(array<char> content)
+{
+    this->content = content ;
+}
+
+        
+array<char> Message::getMarshalledProperties()
+{
+    return marshalledProperties ;
+}
+
+void Message::setMarshalledProperties(array<char> marshalledProperties)
+{
+    this->marshalledProperties = marshalledProperties ;
+}
+
+        
+p<IDataStructure> Message::getDataStructure()
+{
+    return dataStructure ;
+}
+
+void Message::setDataStructure(p<IDataStructure> dataStructure)
+{
+    this->dataStructure = dataStructure ;
+}
+
+        
+p<ConsumerId> Message::getTargetConsumerId()
+{
+    return targetConsumerId ;
+}
+
+void Message::setTargetConsumerId(p<ConsumerId> targetConsumerId)
+{
+    this->targetConsumerId = targetConsumerId ;
+}
+
+        
+bool Message::getCompressed()
+{
+    return compressed ;
+}
+
+void Message::setCompressed(bool compressed)
+{
+    this->compressed = compressed ;
+}
+
+        
+int Message::getRedeliveryCounter()
+{
+    return redeliveryCounter ;
+}
+
+void Message::setRedeliveryCounter(int redeliveryCounter)
+{
+    this->redeliveryCounter = redeliveryCounter ;
+}
+
+        
+array<BrokerId> Message::getBrokerPath()
+{
+    return brokerPath ;
+}
+
+void Message::setBrokerPath(array<BrokerId> brokerPath)
+{
+    this->brokerPath = brokerPath ;
+}
+
+        
+long long Message::getArrival()
+{
+    return arrival ;
+}
+
+void Message::setArrival(long long arrival)
+{
+    this->arrival = arrival ;
+}
+
+        
+p<string> Message::getUserID()
+{
+    return userID ;
+}
+
+void Message::setUserID(p<string> userID)
+{
+    this->userID = userID ;
+}
+
+        
+bool Message::getRecievedByDFBridge()
+{
+    return recievedByDFBridge ;
+}
+
+void Message::setRecievedByDFBridge(bool recievedByDFBridge)
+{
+    this->recievedByDFBridge = recievedByDFBridge ;
+}
+
+int Message::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(producerId, mode, writer) ; 
+    size += marshaller->marshalObject(destination, mode, writer) ; 
+    size += marshaller->marshalObject(transactionId, mode, writer) ; 
+    size += marshaller->marshalObject(originalDestination, mode, writer) ; 
+    size += marshaller->marshalObject(messageId, mode, writer) ; 
+    size += marshaller->marshalObject(originalTransactionId, mode, writer) ; 
+    size += marshaller->marshalString(groupID, mode, writer) ; 
+    size += marshaller->marshalInt(groupSequence, mode, writer) ; 
+    size += marshaller->marshalString(correlationId, mode, writer) ; 
+    size += marshaller->marshalBoolean(persistent, mode, writer) ; 
+    size += marshaller->marshalLong(expiration, mode, writer) ; 
+    size += marshaller->marshalByte(priority, mode, writer) ; 
+    size += marshaller->marshalObject(replyTo, mode, writer) ; 
+    size += marshaller->marshalLong(timestamp, mode, writer) ; 
+    size += marshaller->marshalString(type, mode, writer) ; 
+    size += marshaller->marshalByteArray(content, mode, writer) ; 
+    size += marshaller->marshalByteArray(marshalledProperties, mode, writer) ; 
+    size += marshaller->marshalObject(dataStructure, mode, writer) ; 
+    size += marshaller->marshalObject(targetConsumerId, mode, writer) ; 
+    size += marshaller->marshalBoolean(compressed, mode, writer) ; 
+    size += marshaller->marshalInt(redeliveryCounter, mode, writer) ; 
+    size += marshaller->marshalObjectArray(brokerPath, mode, writer) ; 
+    size += marshaller->marshalLong(arrival, mode, writer) ; 
+    size += marshaller->marshalString(userID, mode, writer) ; 
+    size += marshaller->marshalBoolean(recievedByDFBridge, mode, writer) ; 
+    return size ;
+}
+
+void Message::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    producerId = p_cast<ProducerId>(marshaller->unmarshalObject(mode, reader)) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ; 
+    transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, reader)) ; 
+    originalDestination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ; 
+    messageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, reader)) ; 
+    originalTransactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, reader)) ; 
+    groupID = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    groupSequence = (marshaller->unmarshalInt(mode, reader)) ; 
+    correlationId = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    persistent = (marshaller->unmarshalBoolean(mode, reader)) ; 
+    expiration = (marshaller->unmarshalLong(mode, reader)) ; 
+    priority = (marshaller->unmarshalByte(mode, reader)) ; 
+    replyTo = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ; 
+    timestamp = (marshaller->unmarshalLong(mode, reader)) ; 
+    type = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    content = (marshaller->unmarshalByteArray(mode, reader)) ; 
+    marshalledProperties = (marshaller->unmarshalByteArray(mode, reader)) ; 
+    dataStructure = p_cast<IDataStructure>(marshaller->unmarshalObject(mode, reader)) ; 
+    targetConsumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, reader)) ; 
+    compressed = (marshaller->unmarshalBoolean(mode, reader)) ; 
+    redeliveryCounter = (marshaller->unmarshalInt(mode, reader)) ; 
+    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, reader)) ; 
+    arrival = (marshaller->unmarshalLong(mode, reader)) ; 
+    userID = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    recievedByDFBridge = (marshaller->unmarshalBoolean(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,188 @@
+/*
+* 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_Message_hpp_
+#define ActiveMQ_Message_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/IDataStructure.hpp"
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/ProducerId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/TransactionId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/MessageId.hpp"
+#include "activemq/command/TransactionId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/ConsumerId.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 Message
+ *
+ *
+ *  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 Message : public BaseCommand
+{
+protected:
+    p<ProducerId> producerId ;
+    p<ActiveMQDestination> destination ;
+    p<TransactionId> transactionId ;
+    p<ActiveMQDestination> originalDestination ;
+    p<MessageId> messageId ;
+    p<TransactionId> originalTransactionId ;
+    p<string> groupID ;
+    int groupSequence ;
+    p<string> correlationId ;
+    bool persistent ;
+    long long expiration ;
+    char priority ;
+    p<ActiveMQDestination> replyTo ;
+    long long timestamp ;
+    p<string> type ;
+    array<char> content ;
+    array<char> marshalledProperties ;
+    p<IDataStructure> dataStructure ;
+    p<ConsumerId> targetConsumerId ;
+    bool compressed ;
+    int redeliveryCounter ;
+    array<BrokerId> brokerPath ;
+    long long arrival ;
+    p<string> userID ;
+    bool recievedByDFBridge ;
+
+public:
+    const static unsigned char TYPE = 0;
+
+public:
+    Message() ;
+    virtual ~Message() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ProducerId> getProducerId() ;
+    virtual void setProducerId(p<ProducerId> producerId) ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    virtual p<TransactionId> getTransactionId() ;
+    virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+    virtual p<ActiveMQDestination> getOriginalDestination() ;
+    virtual void setOriginalDestination(p<ActiveMQDestination> originalDestination) ;
+
+    virtual p<MessageId> getMessageId() ;
+    virtual void setMessageId(p<MessageId> messageId) ;
+
+    virtual p<TransactionId> getOriginalTransactionId() ;
+    virtual void setOriginalTransactionId(p<TransactionId> originalTransactionId) ;
+
+    virtual p<string> getGroupID() ;
+    virtual void setGroupID(p<string> groupID) ;
+
+    virtual int getGroupSequence() ;
+    virtual void setGroupSequence(int groupSequence) ;
+
+    virtual p<string> getCorrelationId() ;
+    virtual void setCorrelationId(p<string> correlationId) ;
+
+    virtual bool getPersistent() ;
+    virtual void setPersistent(bool persistent) ;
+
+    virtual long long getExpiration() ;
+    virtual void setExpiration(long long expiration) ;
+
+    virtual char getPriority() ;
+    virtual void setPriority(char priority) ;
+
+    virtual p<ActiveMQDestination> getReplyTo() ;
+    virtual void setReplyTo(p<ActiveMQDestination> replyTo) ;
+
+    virtual long long getTimestamp() ;
+    virtual void setTimestamp(long long timestamp) ;
+
+    virtual p<string> getType() ;
+    virtual void setType(p<string> type) ;
+
+    virtual array<char> getContent() ;
+    virtual void setContent(array<char> content) ;
+
+    virtual array<char> getMarshalledProperties() ;
+    virtual void setMarshalledProperties(array<char> marshalledProperties) ;
+
+    virtual p<IDataStructure> getDataStructure() ;
+    virtual void setDataStructure(p<IDataStructure> dataStructure) ;
+
+    virtual p<ConsumerId> getTargetConsumerId() ;
+    virtual void setTargetConsumerId(p<ConsumerId> targetConsumerId) ;
+
+    virtual bool getCompressed() ;
+    virtual void setCompressed(bool compressed) ;
+
+    virtual int getRedeliveryCounter() ;
+    virtual void setRedeliveryCounter(int redeliveryCounter) ;
+
+    virtual array<BrokerId> getBrokerPath() ;
+    virtual void setBrokerPath(array<BrokerId> brokerPath) ;
+
+    virtual long long getArrival() ;
+    virtual void setArrival(long long arrival) ;
+
+    virtual p<string> getUserID() ;
+    virtual void setUserID(p<string> userID) ;
+
+    virtual bool getRecievedByDFBridge() ;
+    virtual void setRecievedByDFBridge(bool recievedByDFBridge) ;
+
+    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_Message_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,155 @@
+/*
+* 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/MessageAck.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for MessageAck
+ *
+ *
+ *  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
+ *
+ */
+MessageAck::MessageAck()
+{
+    this->destination = NULL ;
+    this->transactionId = NULL ;
+    this->consumerId = NULL ;
+    this->ackType = 0 ;
+    this->firstMessageId = NULL ;
+    this->lastMessageId = NULL ;
+    this->messageCount = 0 ;
+}
+
+MessageAck::~MessageAck()
+{
+}
+
+unsigned char MessageAck::getDataStructureType()
+{
+    return MessageAck::TYPE ; 
+}
+
+        
+p<ActiveMQDestination> MessageAck::getDestination()
+{
+    return destination ;
+}
+
+void MessageAck::setDestination(p<ActiveMQDestination> destination)
+{
+    this->destination = destination ;
+}
+
+        
+p<TransactionId> MessageAck::getTransactionId()
+{
+    return transactionId ;
+}
+
+void MessageAck::setTransactionId(p<TransactionId> transactionId)
+{
+    this->transactionId = transactionId ;
+}
+
+        
+p<ConsumerId> MessageAck::getConsumerId()
+{
+    return consumerId ;
+}
+
+void MessageAck::setConsumerId(p<ConsumerId> consumerId)
+{
+    this->consumerId = consumerId ;
+}
+
+        
+char MessageAck::getAckType()
+{
+    return ackType ;
+}
+
+void MessageAck::setAckType(char ackType)
+{
+    this->ackType = ackType ;
+}
+
+        
+p<MessageId> MessageAck::getFirstMessageId()
+{
+    return firstMessageId ;
+}
+
+void MessageAck::setFirstMessageId(p<MessageId> firstMessageId)
+{
+    this->firstMessageId = firstMessageId ;
+}
+
+        
+p<MessageId> MessageAck::getLastMessageId()
+{
+    return lastMessageId ;
+}
+
+void MessageAck::setLastMessageId(p<MessageId> lastMessageId)
+{
+    this->lastMessageId = lastMessageId ;
+}
+
+        
+int MessageAck::getMessageCount()
+{
+    return messageCount ;
+}
+
+void MessageAck::setMessageCount(int messageCount)
+{
+    this->messageCount = messageCount ;
+}
+
+int MessageAck::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(destination, mode, writer) ; 
+    size += marshaller->marshalObject(transactionId, mode, writer) ; 
+    size += marshaller->marshalObject(consumerId, mode, writer) ; 
+    size += marshaller->marshalByte(ackType, mode, writer) ; 
+    size += marshaller->marshalObject(firstMessageId, mode, writer) ; 
+    size += marshaller->marshalObject(lastMessageId, mode, writer) ; 
+    size += marshaller->marshalInt(messageCount, mode, writer) ; 
+    return size ;
+}
+
+void MessageAck::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ; 
+    transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, reader)) ; 
+    consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, reader)) ; 
+    ackType = (marshaller->unmarshalByte(mode, reader)) ; 
+    firstMessageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, reader)) ; 
+    lastMessageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, reader)) ; 
+    messageCount = (marshaller->unmarshalInt(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,111 @@
+/*
+* 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_MessageAck_hpp_
+#define ActiveMQ_MessageAck_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/ActiveMQDestination.hpp"
+#include "activemq/command/TransactionId.hpp"
+#include "activemq/command/ConsumerId.hpp"
+#include "activemq/command/MessageId.hpp"
+#include "activemq/command/MessageId.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 MessageAck
+ *
+ *
+ *  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 MessageAck : public BaseCommand
+{
+protected:
+    p<ActiveMQDestination> destination ;
+    p<TransactionId> transactionId ;
+    p<ConsumerId> consumerId ;
+    char ackType ;
+    p<MessageId> firstMessageId ;
+    p<MessageId> lastMessageId ;
+    int messageCount ;
+
+public:
+    const static unsigned char TYPE = 22;
+
+public:
+    MessageAck() ;
+    virtual ~MessageAck() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    virtual p<TransactionId> getTransactionId() ;
+    virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+    virtual p<ConsumerId> getConsumerId() ;
+    virtual void setConsumerId(p<ConsumerId> consumerId) ;
+
+    virtual char getAckType() ;
+    virtual void setAckType(char ackType) ;
+
+    virtual p<MessageId> getFirstMessageId() ;
+    virtual void setFirstMessageId(p<MessageId> firstMessageId) ;
+
+    virtual p<MessageId> getLastMessageId() ;
+    virtual void setLastMessageId(p<MessageId> lastMessageId) ;
+
+    virtual int getMessageCount() ;
+    virtual void setMessageCount(int messageCount) ;
+
+    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_MessageAck_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatch.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatch.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatch.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatch.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,113 @@
+/*
+* 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/MessageDispatch.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for MessageDispatch
+ *
+ *
+ *  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
+ *
+ */
+MessageDispatch::MessageDispatch()
+{
+    this->consumerId = NULL ;
+    this->destination = NULL ;
+    this->message = NULL ;
+    this->redeliveryCounter = 0 ;
+}
+
+MessageDispatch::~MessageDispatch()
+{
+}
+
+unsigned char MessageDispatch::getDataStructureType()
+{
+    return MessageDispatch::TYPE ; 
+}
+
+        
+p<ConsumerId> MessageDispatch::getConsumerId()
+{
+    return consumerId ;
+}
+
+void MessageDispatch::setConsumerId(p<ConsumerId> consumerId)
+{
+    this->consumerId = consumerId ;
+}
+
+        
+p<ActiveMQDestination> MessageDispatch::getDestination()
+{
+    return destination ;
+}
+
+void MessageDispatch::setDestination(p<ActiveMQDestination> destination)
+{
+    this->destination = destination ;
+}
+
+        
+p<Message> MessageDispatch::getMessage()
+{
+    return message ;
+}
+
+void MessageDispatch::setMessage(p<Message> message)
+{
+    this->message = message ;
+}
+
+        
+int MessageDispatch::getRedeliveryCounter()
+{
+    return redeliveryCounter ;
+}
+
+void MessageDispatch::setRedeliveryCounter(int redeliveryCounter)
+{
+    this->redeliveryCounter = redeliveryCounter ;
+}
+
+int MessageDispatch::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(consumerId, mode, writer) ; 
+    size += marshaller->marshalObject(destination, mode, writer) ; 
+    size += marshaller->marshalObject(message, mode, writer) ; 
+    size += marshaller->marshalInt(redeliveryCounter, mode, writer) ; 
+    return size ;
+}
+
+void MessageDispatch::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, reader)) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ; 
+    message = p_cast<Message>(marshaller->unmarshalObject(mode, reader)) ; 
+    redeliveryCounter = (marshaller->unmarshalInt(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatch.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatch.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatch.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatch.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,97 @@
+/*
+* 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_MessageDispatch_hpp_
+#define ActiveMQ_MessageDispatch_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/ConsumerId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/Message.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 MessageDispatch
+ *
+ *
+ *  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 MessageDispatch : public BaseCommand
+{
+protected:
+    p<ConsumerId> consumerId ;
+    p<ActiveMQDestination> destination ;
+    p<Message> message ;
+    int redeliveryCounter ;
+
+public:
+    const static unsigned char TYPE = 21;
+
+public:
+    MessageDispatch() ;
+    virtual ~MessageDispatch() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ConsumerId> getConsumerId() ;
+    virtual void setConsumerId(p<ConsumerId> consumerId) ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    virtual p<Message> getMessage() ;
+    virtual void setMessage(p<Message> message) ;
+
+    virtual int getRedeliveryCounter() ;
+    virtual void setRedeliveryCounter(int redeliveryCounter) ;
+
+    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_MessageDispatch_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatchNotification.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatchNotification.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatchNotification.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatchNotification.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,113 @@
+/*
+* 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/MessageDispatchNotification.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for MessageDispatchNotification
+ *
+ *
+ *  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
+ *
+ */
+MessageDispatchNotification::MessageDispatchNotification()
+{
+    this->consumerId = NULL ;
+    this->destination = NULL ;
+    this->deliverySequenceId = 0 ;
+    this->messageId = NULL ;
+}
+
+MessageDispatchNotification::~MessageDispatchNotification()
+{
+}
+
+unsigned char MessageDispatchNotification::getDataStructureType()
+{
+    return MessageDispatchNotification::TYPE ; 
+}
+
+        
+p<ConsumerId> MessageDispatchNotification::getConsumerId()
+{
+    return consumerId ;
+}
+
+void MessageDispatchNotification::setConsumerId(p<ConsumerId> consumerId)
+{
+    this->consumerId = consumerId ;
+}
+
+        
+p<ActiveMQDestination> MessageDispatchNotification::getDestination()
+{
+    return destination ;
+}
+
+void MessageDispatchNotification::setDestination(p<ActiveMQDestination> destination)
+{
+    this->destination = destination ;
+}
+
+        
+long long MessageDispatchNotification::getDeliverySequenceId()
+{
+    return deliverySequenceId ;
+}
+
+void MessageDispatchNotification::setDeliverySequenceId(long long deliverySequenceId)
+{
+    this->deliverySequenceId = deliverySequenceId ;
+}
+
+        
+p<MessageId> MessageDispatchNotification::getMessageId()
+{
+    return messageId ;
+}
+
+void MessageDispatchNotification::setMessageId(p<MessageId> messageId)
+{
+    this->messageId = messageId ;
+}
+
+int MessageDispatchNotification::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(consumerId, mode, writer) ; 
+    size += marshaller->marshalObject(destination, mode, writer) ; 
+    size += marshaller->marshalLong(deliverySequenceId, mode, writer) ; 
+    size += marshaller->marshalObject(messageId, mode, writer) ; 
+    return size ;
+}
+
+void MessageDispatchNotification::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, reader)) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ; 
+    deliverySequenceId = (marshaller->unmarshalLong(mode, reader)) ; 
+    messageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatchNotification.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatchNotification.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatchNotification.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageDispatchNotification.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,97 @@
+/*
+* 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_MessageDispatchNotification_hpp_
+#define ActiveMQ_MessageDispatchNotification_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/ConsumerId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/MessageId.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 MessageDispatchNotification
+ *
+ *
+ *  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 MessageDispatchNotification : public BaseCommand
+{
+protected:
+    p<ConsumerId> consumerId ;
+    p<ActiveMQDestination> destination ;
+    long long deliverySequenceId ;
+    p<MessageId> messageId ;
+
+public:
+    const static unsigned char TYPE = 90;
+
+public:
+    MessageDispatchNotification() ;
+    virtual ~MessageDispatchNotification() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ConsumerId> getConsumerId() ;
+    virtual void setConsumerId(p<ConsumerId> consumerId) ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    virtual long long getDeliverySequenceId() ;
+    virtual void setDeliverySequenceId(long long deliverySequenceId) ;
+
+    virtual p<MessageId> getMessageId() ;
+    virtual void setMessageId(p<MessageId> messageId) ;
+
+    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_MessageDispatchNotification_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageId.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageId.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageId.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/MessageId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for MessageId
+ *
+ *
+ *  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
+ *
+ */
+MessageId::MessageId()
+{
+    this->producerId = NULL ;
+    this->producerSequenceId = 0 ;
+    this->brokerSequenceId = 0 ;
+}
+
+MessageId::~MessageId()
+{
+}
+
+unsigned char MessageId::getDataStructureType()
+{
+    return MessageId::TYPE ; 
+}
+
+        
+p<ProducerId> MessageId::getProducerId()
+{
+    return producerId ;
+}
+
+void MessageId::setProducerId(p<ProducerId> producerId)
+{
+    this->producerId = producerId ;
+}
+
+        
+long long MessageId::getProducerSequenceId()
+{
+    return producerSequenceId ;
+}
+
+void MessageId::setProducerSequenceId(long long producerSequenceId)
+{
+    this->producerSequenceId = producerSequenceId ;
+}
+
+        
+long long MessageId::getBrokerSequenceId()
+{
+    return brokerSequenceId ;
+}
+
+void MessageId::setBrokerSequenceId(long long brokerSequenceId)
+{
+    this->brokerSequenceId = brokerSequenceId ;
+}
+
+int MessageId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
+{
+    int size = 0 ;
+
+    size += marshaller->marshalObject(producerId, mode, writer) ; 
+    size += marshaller->marshalLong(producerSequenceId, mode, writer) ; 
+    size += marshaller->marshalLong(brokerSequenceId, mode, writer) ; 
+    return size ;
+}
+
+void MessageId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    producerId = p_cast<ProducerId>(marshaller->unmarshalObject(mode, reader)) ; 
+    producerSequenceId = (marshaller->unmarshalLong(mode, reader)) ; 
+    brokerSequenceId = (marshaller->unmarshalLong(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageId.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageId.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageId.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,91 @@
+/*
+* 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_MessageId_hpp_
+#define ActiveMQ_MessageId_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/command/ProducerId.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 MessageId
+ *
+ *
+ *  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 MessageId : public AbstractCommand
+{
+protected:
+    p<ProducerId> producerId ;
+    long long producerSequenceId ;
+    long long brokerSequenceId ;
+
+public:
+    const static unsigned char TYPE = 110;
+
+public:
+    MessageId() ;
+    virtual ~MessageId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ProducerId> getProducerId() ;
+    virtual void setProducerId(p<ProducerId> producerId) ;
+
+    virtual long long getProducerSequenceId() ;
+    virtual void setProducerSequenceId(long long producerSequenceId) ;
+
+    virtual long long getBrokerSequenceId() ;
+    virtual void setBrokerSequenceId(long long brokerSequenceId) ;
+
+    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_MessageId_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerId.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerId.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerId.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/ProducerId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ProducerId
+ *
+ *
+ *  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
+ *
+ */
+ProducerId::ProducerId()
+{
+    this->connectionId = NULL ;
+    this->value = 0 ;
+    this->sessionId = 0 ;
+}
+
+ProducerId::~ProducerId()
+{
+}
+
+unsigned char ProducerId::getDataStructureType()
+{
+    return ProducerId::TYPE ; 
+}
+
+        
+p<string> ProducerId::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ProducerId::setConnectionId(p<string> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+        
+long long ProducerId::getValue()
+{
+    return value ;
+}
+
+void ProducerId::setValue(long long value)
+{
+    this->value = value ;
+}
+
+        
+long long ProducerId::getSessionId()
+{
+    return sessionId ;
+}
+
+void ProducerId::setSessionId(long long sessionId)
+{
+    this->sessionId = sessionId ;
+}
+
+int ProducerId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
+{
+    int size = 0 ;
+
+    size += marshaller->marshalString(connectionId, mode, writer) ; 
+    size += marshaller->marshalLong(value, mode, writer) ; 
+    size += marshaller->marshalLong(sessionId, mode, writer) ; 
+    return size ;
+}
+
+void ProducerId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    connectionId = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    value = (marshaller->unmarshalLong(mode, reader)) ; 
+    sessionId = (marshaller->unmarshalLong(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerId.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerId.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerId.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_ProducerId_hpp_
+#define ActiveMQ_ProducerId_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 ProducerId
+ *
+ *
+ *  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 ProducerId : public AbstractCommand
+{
+protected:
+    p<string> connectionId ;
+    long long value ;
+    long long sessionId ;
+
+public:
+    const static unsigned char TYPE = 123;
+
+public:
+    ProducerId() ;
+    virtual ~ProducerId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<string> getConnectionId() ;
+    virtual void setConnectionId(p<string> connectionId) ;
+
+    virtual long long getValue() ;
+    virtual void setValue(long long value) ;
+
+    virtual long long getSessionId() ;
+    virtual void setSessionId(long long sessionId) ;
+
+    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_ProducerId_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerInfo.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerInfo.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,99 @@
+/*
+* 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/ProducerInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ProducerInfo
+ *
+ *
+ *  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
+ *
+ */
+ProducerInfo::ProducerInfo()
+{
+    this->producerId = NULL ;
+    this->destination = NULL ;
+    this->brokerPath = NULL ;
+}
+
+ProducerInfo::~ProducerInfo()
+{
+}
+
+unsigned char ProducerInfo::getDataStructureType()
+{
+    return ProducerInfo::TYPE ; 
+}
+
+        
+p<ProducerId> ProducerInfo::getProducerId()
+{
+    return producerId ;
+}
+
+void ProducerInfo::setProducerId(p<ProducerId> producerId)
+{
+    this->producerId = producerId ;
+}
+
+        
+p<ActiveMQDestination> ProducerInfo::getDestination()
+{
+    return destination ;
+}
+
+void ProducerInfo::setDestination(p<ActiveMQDestination> destination)
+{
+    this->destination = destination ;
+}
+
+        
+array<BrokerId> ProducerInfo::getBrokerPath()
+{
+    return brokerPath ;
+}
+
+void ProducerInfo::setBrokerPath(array<BrokerId> brokerPath)
+{
+    this->brokerPath = brokerPath ;
+}
+
+int ProducerInfo::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(producerId, mode, writer) ; 
+    size += marshaller->marshalObject(destination, mode, writer) ; 
+    size += marshaller->marshalObjectArray(brokerPath, mode, writer) ; 
+    return size ;
+}
+
+void ProducerInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    producerId = p_cast<ProducerId>(marshaller->unmarshalObject(mode, reader)) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ; 
+    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerInfo.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ProducerInfo.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,93 @@
+/*
+* 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_ProducerInfo_hpp_
+#define ActiveMQ_ProducerInfo_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/ProducerId.hpp"
+#include "activemq/command/ActiveMQDestination.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 ProducerInfo
+ *
+ *
+ *  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 ProducerInfo : public BaseCommand
+{
+protected:
+    p<ProducerId> producerId ;
+    p<ActiveMQDestination> destination ;
+    array<BrokerId> brokerPath ;
+
+public:
+    const static unsigned char TYPE = 6;
+
+public:
+    ProducerInfo() ;
+    virtual ~ProducerInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ProducerId> getProducerId() ;
+    virtual void setProducerId(p<ProducerId> producerId) ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    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_ProducerInfo_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveInfo.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveInfo.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,71 @@
+/*
+* 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/RemoveInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for RemoveInfo
+ *
+ *
+ *  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
+ *
+ */
+RemoveInfo::RemoveInfo()
+{
+    this->objectId = NULL ;
+}
+
+RemoveInfo::~RemoveInfo()
+{
+}
+
+unsigned char RemoveInfo::getDataStructureType()
+{
+    return RemoveInfo::TYPE ; 
+}
+
+        
+p<IDataStructure> RemoveInfo::getObjectId()
+{
+    return objectId ;
+}
+
+void RemoveInfo::setObjectId(p<IDataStructure> objectId)
+{
+    this->objectId = objectId ;
+}
+
+int RemoveInfo::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(objectId, mode, writer) ; 
+    return size ;
+}
+
+void RemoveInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    objectId = p_cast<IDataStructure>(marshaller->unmarshalObject(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveInfo.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveInfo.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,83 @@
+/*
+* 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_RemoveInfo_hpp_
+#define ActiveMQ_RemoveInfo_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/IDataStructure.hpp"
+#include "activemq/command/BaseCommand.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 RemoveInfo
+ *
+ *
+ *  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 RemoveInfo : public BaseCommand
+{
+protected:
+    p<IDataStructure> objectId ;
+
+public:
+    const static unsigned char TYPE = 12;
+
+public:
+    RemoveInfo() ;
+    virtual ~RemoveInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<IDataStructure> getObjectId() ;
+    virtual void setObjectId(p<IDataStructure> objectId) ;
+
+    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_RemoveInfo_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveSubscriptionInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveSubscriptionInfo.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveSubscriptionInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveSubscriptionInfo.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,99 @@
+/*
+* 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/RemoveSubscriptionInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for RemoveSubscriptionInfo
+ *
+ *
+ *  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
+ *
+ */
+RemoveSubscriptionInfo::RemoveSubscriptionInfo()
+{
+    this->connectionId = NULL ;
+    this->subcriptionName = NULL ;
+    this->clientId = NULL ;
+}
+
+RemoveSubscriptionInfo::~RemoveSubscriptionInfo()
+{
+}
+
+unsigned char RemoveSubscriptionInfo::getDataStructureType()
+{
+    return RemoveSubscriptionInfo::TYPE ; 
+}
+
+        
+p<ConnectionId> RemoveSubscriptionInfo::getConnectionId()
+{
+    return connectionId ;
+}
+
+void RemoveSubscriptionInfo::setConnectionId(p<ConnectionId> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+        
+p<string> RemoveSubscriptionInfo::getSubcriptionName()
+{
+    return subcriptionName ;
+}
+
+void RemoveSubscriptionInfo::setSubcriptionName(p<string> subcriptionName)
+{
+    this->subcriptionName = subcriptionName ;
+}
+
+        
+p<string> RemoveSubscriptionInfo::getClientId()
+{
+    return clientId ;
+}
+
+void RemoveSubscriptionInfo::setClientId(p<string> clientId)
+{
+    this->clientId = clientId ;
+}
+
+int RemoveSubscriptionInfo::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(subcriptionName, mode, writer) ; 
+    size += marshaller->marshalString(clientId, mode, writer) ; 
+    return size ;
+}
+
+void RemoveSubscriptionInfo::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)) ; 
+    subcriptionName = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    clientId = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveSubscriptionInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveSubscriptionInfo.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveSubscriptionInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/RemoveSubscriptionInfo.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,91 @@
+/*
+* 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_RemoveSubscriptionInfo_hpp_
+#define ActiveMQ_RemoveSubscriptionInfo_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/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 RemoveSubscriptionInfo
+ *
+ *
+ *  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 RemoveSubscriptionInfo : public BaseCommand
+{
+protected:
+    p<ConnectionId> connectionId ;
+    p<string> subcriptionName ;
+    p<string> clientId ;
+
+public:
+    const static unsigned char TYPE = 0;
+
+public:
+    RemoveSubscriptionInfo() ;
+    virtual ~RemoveSubscriptionInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ConnectionId> getConnectionId() ;
+    virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+    virtual p<string> getSubcriptionName() ;
+    virtual void setSubcriptionName(p<string> subcriptionName) ;
+
+    virtual p<string> getClientId() ;
+    virtual void setClientId(p<string> clientId) ;
+
+    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_RemoveSubscriptionInfo_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,70 @@
+/*
+* 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/Response.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for Response
+ *
+ *
+ *  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
+ *
+ */
+Response::Response()
+{
+    this->correlationId = 0 ;
+}
+
+Response::~Response()
+{
+}
+
+unsigned char Response::getDataStructureType()
+{
+    return Response::TYPE ; 
+}
+
+int Response::getCorrelationId()
+{
+    return correlationId ;
+}
+
+void Response::setCorrelationId(int correlationId)
+{
+    this->correlationId = correlationId ;
+}
+
+int Response::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->marshalInt(correlationId, mode, writer) ; 
+    return size ;
+}
+
+void Response::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    commandId = marshaller->unmarshalInt(mode, reader) ;
+    responseRequired = marshaller->unmarshalBoolean(mode, reader) ; 
+    correlationId = (marshaller->unmarshalInt(mode, reader)) ; 
+}

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.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_Response_hpp_
+#define ActiveMQ_Response_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/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 Response
+ *
+ *
+ *  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 Response : public BaseCommand
+{
+protected:
+    int correlationId ;
+
+public:
+    const static unsigned char TYPE = 30;
+
+public:
+    Response() ;
+    virtual ~Response() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual int getCorrelationId() ;
+    virtual void setCorrelationId(int correlationId) ;
+
+    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_Response_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.cpp Thu Apr 27 14:59:28 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.
+*/
+#include "activemq/command/SessionId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for SessionId
+ *
+ *
+ *  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
+ *
+ */
+SessionId::SessionId()
+{
+    this->connectionId = NULL ;
+    this->value = 0 ;
+}
+
+SessionId::~SessionId()
+{
+}
+
+unsigned char SessionId::getDataStructureType()
+{
+    return SessionId::TYPE ; 
+}
+
+        
+p<string> SessionId::getConnectionId()
+{
+    return connectionId ;
+}
+
+void SessionId::setConnectionId(p<string> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+        
+long long SessionId::getValue()
+{
+    return value ;
+}
+
+void SessionId::setValue(long long value)
+{
+    this->value = value ;
+}
+
+int SessionId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
+{
+    int size = 0 ;
+
+    size += marshaller->marshalString(connectionId, mode, writer) ; 
+    size += marshaller->marshalLong(value, mode, writer) ; 
+    return size ;
+}
+
+void SessionId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    connectionId = p_cast<string>(marshaller->unmarshalString(mode, reader)) ; 
+    value = (marshaller->unmarshalLong(mode, reader)) ; 
+}