activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r382091 [3/6] - in /incubator/activemq/trunk/openwire-cpp: ./ src/command/ src/marshal/
Date Wed, 01 Mar 2006 17:34:38 GMT
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.cpp Wed Mar  1 09:34:23 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.
+ */
+#include "marshal/ActiveMQStreamMessageMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ActiveMQStreamMessage
+ *
+ * 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
+ */
+
+ActiveMQStreamMessageMarshaller::ActiveMQStreamMessageMarshaller()
+{
+    // no-op
+}
+
+ActiveMQStreamMessageMarshaller::~ActiveMQStreamMessageMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ActiveMQStreamMessageMarshaller::createObject() 
+{
+    return new ActiveMQStreamMessage();
+}
+
+byte ActiveMQStreamMessageMarshaller::getDataStructureType() 
+{
+    return ActiveMQStreamMessage.ID_ActiveMQStreamMessage;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ActiveMQStreamMessageMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ActiveMQStreamMessageMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ActiveMQStreamMessage& info = (ActiveMQStreamMessage&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ActiveMQStreamMessageMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ActiveMQStreamMessageMarshaller_hpp_
+#define ActiveMQStreamMessageMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/ActiveMQMessageMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ActiveMQStreamMessageMarshaller : public ActiveMQMessageMarshaller
+{
+public:
+    ActiveMQStreamMessageMarshaller() ;
+    virtual ~ActiveMQStreamMessageMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ActiveMQStreamMessageMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.cpp Wed Mar  1 09:34:23 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 "marshal/ActiveMQTempDestinationMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ActiveMQTempDestination
+ *
+ * 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
+ */
+
+ActiveMQTempDestinationMarshaller::ActiveMQTempDestinationMarshaller()
+{
+    // no-op
+}
+
+ActiveMQTempDestinationMarshaller::~ActiveMQTempDestinationMarshaller()
+{
+    // no-op
+}
+
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ActiveMQTempDestinationMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ActiveMQTempDestinationMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ActiveMQTempDestination& info = (ActiveMQTempDestination&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ActiveMQTempDestinationMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ActiveMQTempDestinationMarshaller_hpp_
+#define ActiveMQTempDestinationMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/ActiveMQDestinationMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ActiveMQTempDestinationMarshaller : public ActiveMQDestinationMarshaller
+{
+public:
+    ActiveMQTempDestinationMarshaller() ;
+    virtual ~ActiveMQTempDestinationMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ActiveMQTempDestinationMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.cpp Wed Mar  1 09:34:23 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.
+ */
+#include "marshal/ActiveMQTempQueueMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ActiveMQTempQueue
+ *
+ * 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
+ */
+
+ActiveMQTempQueueMarshaller::ActiveMQTempQueueMarshaller()
+{
+    // no-op
+}
+
+ActiveMQTempQueueMarshaller::~ActiveMQTempQueueMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ActiveMQTempQueueMarshaller::createObject() 
+{
+    return new ActiveMQTempQueue();
+}
+
+byte ActiveMQTempQueueMarshaller::getDataStructureType() 
+{
+    return ActiveMQTempQueue.ID_ActiveMQTempQueue;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ActiveMQTempQueueMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ActiveMQTempQueueMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ActiveMQTempQueue& info = (ActiveMQTempQueue&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ActiveMQTempQueueMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ActiveMQTempQueueMarshaller_hpp_
+#define ActiveMQTempQueueMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/ActiveMQTempDestinationMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ActiveMQTempQueueMarshaller : public ActiveMQTempDestinationMarshaller
+{
+public:
+    ActiveMQTempQueueMarshaller() ;
+    virtual ~ActiveMQTempQueueMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ActiveMQTempQueueMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.cpp Wed Mar  1 09:34:23 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.
+ */
+#include "marshal/ActiveMQTempTopicMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ActiveMQTempTopic
+ *
+ * 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
+ */
+
+ActiveMQTempTopicMarshaller::ActiveMQTempTopicMarshaller()
+{
+    // no-op
+}
+
+ActiveMQTempTopicMarshaller::~ActiveMQTempTopicMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ActiveMQTempTopicMarshaller::createObject() 
+{
+    return new ActiveMQTempTopic();
+}
+
+byte ActiveMQTempTopicMarshaller::getDataStructureType() 
+{
+    return ActiveMQTempTopic.ID_ActiveMQTempTopic;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ActiveMQTempTopicMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ActiveMQTempTopicMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ActiveMQTempTopic& info = (ActiveMQTempTopic&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ActiveMQTempTopicMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ActiveMQTempTopicMarshaller_hpp_
+#define ActiveMQTempTopicMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/ActiveMQTempDestinationMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ActiveMQTempTopicMarshaller : public ActiveMQTempDestinationMarshaller
+{
+public:
+    ActiveMQTempTopicMarshaller() ;
+    virtual ~ActiveMQTempTopicMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ActiveMQTempTopicMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.cpp Wed Mar  1 09:34:23 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.
+ */
+#include "marshal/ActiveMQTextMessageMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ActiveMQTextMessage
+ *
+ * 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
+ */
+
+ActiveMQTextMessageMarshaller::ActiveMQTextMessageMarshaller()
+{
+    // no-op
+}
+
+ActiveMQTextMessageMarshaller::~ActiveMQTextMessageMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ActiveMQTextMessageMarshaller::createObject() 
+{
+    return new ActiveMQTextMessage();
+}
+
+byte ActiveMQTextMessageMarshaller::getDataStructureType() 
+{
+    return ActiveMQTextMessage.ID_ActiveMQTextMessage;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ActiveMQTextMessageMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ActiveMQTextMessageMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ActiveMQTextMessage& info = (ActiveMQTextMessage&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ActiveMQTextMessageMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ActiveMQTextMessageMarshaller_hpp_
+#define ActiveMQTextMessageMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/ActiveMQMessageMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ActiveMQTextMessageMarshaller : public ActiveMQMessageMarshaller
+{
+public:
+    ActiveMQTextMessageMarshaller() ;
+    virtual ~ActiveMQTextMessageMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ActiveMQTextMessageMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.cpp Wed Mar  1 09:34:23 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.
+ */
+#include "marshal/ActiveMQTopicMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ActiveMQTopic
+ *
+ * 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
+ */
+
+ActiveMQTopicMarshaller::ActiveMQTopicMarshaller()
+{
+    // no-op
+}
+
+ActiveMQTopicMarshaller::~ActiveMQTopicMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ActiveMQTopicMarshaller::createObject() 
+{
+    return new ActiveMQTopic();
+}
+
+byte ActiveMQTopicMarshaller::getDataStructureType() 
+{
+    return ActiveMQTopic.ID_ActiveMQTopic;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ActiveMQTopicMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ActiveMQTopicMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ActiveMQTopic& info = (ActiveMQTopic&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ActiveMQTopicMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ActiveMQTopicMarshaller_hpp_
+#define ActiveMQTopicMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/ActiveMQDestinationMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ActiveMQTopicMarshaller : public ActiveMQDestinationMarshaller
+{
+public:
+    ActiveMQTopicMarshaller() ;
+    virtual ~ActiveMQTopicMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ActiveMQTopicMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.cpp Wed Mar  1 09:34:23 2006
@@ -0,0 +1,76 @@
+/*
+ * 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 "marshal/BaseCommandMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for BaseCommand
+ *
+ * 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
+ */
+
+BaseCommandMarshaller::BaseCommandMarshaller()
+{
+    // no-op
+}
+
+BaseCommandMarshaller::~BaseCommandMarshaller()
+{
+    // no-op
+}
+
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void BaseCommandMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    BaseCommand& info = (BaseCommand&) o;
+        info.setCommandId(dataIn.readShort());
+        info.setResponseRequired(bs.readBoolean());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int BaseCommandMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    BaseCommand& info = (BaseCommand&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+        bs.writeBoolean(info.isResponseRequired());
+
+    return rc + 1;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void BaseCommandMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    BaseCommand& info = (BaseCommand&) o;
+    DataStreamMarshaller.writeShort(info.getCommandId(), dataOut);
+    bs.readBoolean();
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef BaseCommandMarshaller_hpp_
+#define BaseCommandMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class BaseCommandMarshaller : public BaseDataStreamMarshaller
+{
+public:
+    BaseCommandMarshaller() ;
+    virtual ~BaseCommandMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*BaseCommandMarshaller_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerIdMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerIdMarshaller.cpp?rev=382091&r1=382090&r2=382091&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerIdMarshaller.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerIdMarshaller.cpp Wed Mar  1 09:34:23 2006
@@ -19,8 +19,13 @@
 using namespace apache::activemq::client::marshal;
 
 /*
+ *  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
  */
+
 BrokerIdMarshaller::BrokerIdMarshaller()
 {
     // no-op
@@ -31,23 +36,50 @@
     // no-op
 }
 
-p<ICommand> BrokerIdMarshaller::createCommand()
+
+
+DataStructure* BrokerIdMarshaller::createObject() 
 {
-    return new BrokerId() ;
+    return new BrokerId();
 }
 
-void BrokerIdMarshaller::buildCommand(p<ICommand> command, p<BinaryReader> reader)
+byte BrokerIdMarshaller::getDataStructureType() 
 {
-    //AbstractCommandMarshaller::buildCommand(command, reader) ;
-
-    p<BrokerId> brokerId = (p<BrokerId>&)command ;
-    brokerId->setValue( reader->readString()->c_str() ) ;
+    return BrokerId.ID_BrokerId;
 }
 
-void BrokerIdMarshaller::writeCommand(p<ICommand> command, p<BinaryWriter> writer)
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void BrokerIdMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
 {
-    //AbstractCommandMarshaller::writeCommand(command, writer) ;
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    BrokerId& info = (BrokerId&) o;
+        info.setValue(tightUnmarshalString(dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int BrokerIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    BrokerId& info = (BrokerId&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += writeString(info.getValue(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void BrokerIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    BrokerId& info = (BrokerId&) o;
+    writeString(info.getValue(), dataOut, bs);
 
-    p<BrokerId> brokerId = (p<BrokerId>&)command ;
-    writer->writeString( brokerId->getValue() ) ;
 }

Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerIdMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerIdMarshaller.hpp?rev=382091&r1=382090&r2=382091&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerIdMarshaller.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerIdMarshaller.hpp Wed Mar  1 09:34:23 2006
@@ -1,27 +1,37 @@
 /*
- * 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.
- */
+* 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 BrokerIdMarshaller_hpp_
 #define BrokerIdMarshaller_hpp_
 
-#include "command/ICommand.hpp"
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
 #include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
 #include "io/BinaryReader.hpp"
 #include "io/BinaryWriter.hpp"
-#include "marshal/AbstractCommandMarshaller.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
 #include "util/ifr/p"
 
 namespace apache
@@ -39,21 +49,23 @@
 /*
  *
  */
-class BrokerIdMarshaller : public AbstractCommandMarshaller
+class BrokerIdMarshaller : public BaseDataStreamMarshaller
 {
 public:
     BrokerIdMarshaller() ;
     virtual ~BrokerIdMarshaller() ;
 
-    virtual p<ICommand> createCommand() ;
-    virtual void buildCommand(p<ICommand> command, p<BinaryReader> reader) ;
-    virtual void writeCommand(p<ICommand> command, p<BinaryWriter> writer) ;
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
 } ;
 
 /* namespace */
-      }
+     }
     }
   }
 }
-
-#endif /*BrokerIdMarshaller_hpp_*/
\ No newline at end of file
+#endif /*BrokerIdMarshaller_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerInfoMarshaller.cpp?rev=382091&r1=382090&r2=382091&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerInfoMarshaller.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerInfoMarshaller.cpp Wed Mar  1 09:34:23 2006
@@ -19,8 +19,13 @@
 using namespace apache::activemq::client::marshal;
 
 /*
+ *  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
  */
+
 BrokerInfoMarshaller::BrokerInfoMarshaller()
 {
     // no-op
@@ -31,29 +36,73 @@
     // no-op
 }
 
-p<ICommand> BrokerInfoMarshaller::createCommand()
+
+
+DataStructure* BrokerInfoMarshaller::createObject() 
 {
-    return new BrokerInfo() ;
+    return new BrokerInfo();
 }
 
-void BrokerInfoMarshaller::buildCommand(p<ICommand> command, p<BinaryReader> reader)
+byte BrokerInfoMarshaller::getDataStructureType() 
 {
-    //AbstractCommandMarshaller::buildCommand(command, reader) ;
-
-    p<BrokerInfo> brokerInfo = (p<BrokerInfo>&)command ;
-    brokerInfo->setBrokerId( (p<BrokerId>&)CommandMarshallerRegistry::getBrokerInfoMarshaller()->readCommand(reader) ) ;
-    brokerInfo->setBrokerURL( reader->readString()->c_str() ) ;
-    brokerInfo->setPeerBrokerInfo( AbstractCommandMarshaller::readBrokerInfos(reader) ) ;
-    brokerInfo->setBrokerName( reader->readString()->c_str() ) ;
+    return BrokerInfo.ID_BrokerInfo;
 }
 
-void BrokerInfoMarshaller::writeCommand(p<ICommand> command, p<BinaryWriter> writer)
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void BrokerInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
 {
-    //AbstractCommandMarshaller::writeCommand(command, writer) ;
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    BrokerInfo& info = (BrokerInfo&) o;
+        info.setBrokerId((BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setBrokerURL(tightUnmarshalString(dataIn, bs));
+
+        if (bs.readBoolean()) {
+            short size = dataIn.readShort();
+            BrokerInfo value[] = new BrokerInfo[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (BrokerInfo) tightUnmarsalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.setPeerBrokerInfos(value);
+        }
+        else {
+            info.setPeerBrokerInfos(null);
+        }
+        info.setBrokerName(tightUnmarshalString(dataIn, bs));
+        info.setSlaveBroker(bs.readBoolean());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int BrokerInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    BrokerInfo& info = (BrokerInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getBrokerId(), bs);
+    rc += writeString(info.getBrokerURL(), bs);
+    rc += marshalObjectArray(wireFormat, info.getPeerBrokerInfos(), bs);
+    rc += writeString(info.getBrokerName(), bs);
+    bs.writeBoolean(info.isSlaveBroker());
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void BrokerInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    BrokerInfo& info = (BrokerInfo&) o;
+    marshal2CachedObject(wireFormat, info.getBrokerId(), dataOut, bs);
+    writeString(info.getBrokerURL(), dataOut, bs);
+    marshalObjectArray(wireFormat, info.getPeerBrokerInfos(), dataOut, bs);
+    writeString(info.getBrokerName(), dataOut, bs);
+    bs.readBoolean();
 
-    p<BrokerInfo> brokerInfo = (p<BrokerInfo>&)command ;
-    CommandMarshallerRegistry::getBrokerInfoMarshaller()->writeCommand(brokerInfo->getBrokerId(), writer) ;
-    writer->writeString( brokerInfo->getBrokerURL() ) ;
-    AbstractCommandMarshaller::writeBrokerInfos( brokerInfo->getPeerBrokerInfo(), writer) ;
-    writer->writeString( brokerInfo->getBrokerName() ) ;
 }

Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerInfoMarshaller.hpp?rev=382091&r1=382090&r2=382091&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerInfoMarshaller.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/BrokerInfoMarshaller.hpp Wed Mar  1 09:34:23 2006
@@ -1,28 +1,37 @@
 /*
- * 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.
- */
+* 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 BrokerInfoMarshaller_hpp_
 #define BrokerInfoMarshaller_hpp_
 
 #include <string>
-#include "command/ICommand.hpp"
-#include "command/BrokerInfo.hpp"
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
 #include "io/BinaryReader.hpp"
 #include "io/BinaryWriter.hpp"
-#include "marshal/AbstractCommandMarshaller.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
 #include "util/ifr/p"
 
 namespace apache
@@ -40,21 +49,23 @@
 /*
  *
  */
-class BrokerInfoMarshaller : public AbstractCommandMarshaller
+class BrokerInfoMarshaller : public BaseCommandMarshaller
 {
 public:
     BrokerInfoMarshaller() ;
     virtual ~BrokerInfoMarshaller() ;
 
-    virtual p<ICommand> createCommand() ;
-    virtual void buildCommand(p<ICommand> command, p<BinaryReader> reader) ;
-    virtual void writeCommand(p<ICommand> command, p<BinaryWriter> writer) ;
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
 } ;
 
 /* namespace */
-      }
+     }
     }
   }
 }
-
-#endif /*BrokerInfoMarshaller_hpp_*/
\ No newline at end of file
+#endif /*BrokerInfoMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.cpp Wed Mar  1 09:34:23 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.
+ */
+#include "marshal/ConnectionErrorMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  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
+ */
+
+ConnectionErrorMarshaller::ConnectionErrorMarshaller()
+{
+    // no-op
+}
+
+ConnectionErrorMarshaller::~ConnectionErrorMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ConnectionErrorMarshaller::createObject() 
+{
+    return new ConnectionError();
+}
+
+byte ConnectionErrorMarshaller::getDataStructureType() 
+{
+    return ConnectionError.ID_ConnectionError;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ConnectionErrorMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    ConnectionError& info = (ConnectionError&) o;
+        info.setException((Throwable) tightUnmarsalThrowable(wireFormat, dataIn, bs));
+        info.setConnectionId((ConnectionId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ConnectionErrorMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ConnectionError& info = (ConnectionError&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshalBrokerError(wireFormat, info.getException(), bs);
+    rc += marshal1NestedObject(wireFormat, info.getConnectionId(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ConnectionErrorMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    ConnectionError& info = (ConnectionError&) o;
+    marshalBrokerError(wireFormat, info.getException(), dataOut, bs);
+    marshal2NestedObject(wireFormat, info.getConnectionId(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ConnectionErrorMarshaller_hpp_
+#define ConnectionErrorMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ConnectionErrorMarshaller : public BaseCommandMarshaller
+{
+public:
+    ConnectionErrorMarshaller() ;
+    virtual ~ConnectionErrorMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ConnectionErrorMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.cpp Wed Mar  1 09:34:23 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 "marshal/ConnectionIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  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
+ */
+
+ConnectionIdMarshaller::ConnectionIdMarshaller()
+{
+    // no-op
+}
+
+ConnectionIdMarshaller::~ConnectionIdMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ConnectionIdMarshaller::createObject() 
+{
+    return new ConnectionId();
+}
+
+byte ConnectionIdMarshaller::getDataStructureType() 
+{
+    return ConnectionId.ID_ConnectionId;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ConnectionIdMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    ConnectionId& info = (ConnectionId&) o;
+        info.setValue(tightUnmarshalString(dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ConnectionIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ConnectionId& info = (ConnectionId&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += writeString(info.getValue(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ConnectionIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    ConnectionId& info = (ConnectionId&) o;
+    writeString(info.getValue(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ConnectionIdMarshaller_hpp_
+#define ConnectionIdMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ConnectionIdMarshaller : public BaseDataStreamMarshaller
+{
+public:
+    ConnectionIdMarshaller() ;
+    virtual ~ConnectionIdMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ConnectionIdMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.cpp Wed Mar  1 09:34:23 2006
@@ -0,0 +1,108 @@
+/*
+ * 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 "marshal/ConnectionInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  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
+ */
+
+ConnectionInfoMarshaller::ConnectionInfoMarshaller()
+{
+    // no-op
+}
+
+ConnectionInfoMarshaller::~ConnectionInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ConnectionInfoMarshaller::createObject() 
+{
+    return new ConnectionInfo();
+}
+
+byte ConnectionInfoMarshaller::getDataStructureType() 
+{
+    return ConnectionInfo.ID_ConnectionInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ConnectionInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    ConnectionInfo& info = (ConnectionInfo&) o;
+        info.setConnectionId((ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setClientId(tightUnmarshalString(dataIn, bs));
+        info.setPassword(tightUnmarshalString(dataIn, bs));
+        info.setUserName(tightUnmarshalString(dataIn, bs));
+
+        if (bs.readBoolean()) {
+            short size = dataIn.readShort();
+            BrokerId value[] = new BrokerId[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (BrokerId) tightUnmarsalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.setBrokerPath(value);
+        }
+        else {
+            info.setBrokerPath(null);
+        }
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ConnectionInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ConnectionInfo& info = (ConnectionInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getConnectionId(), bs);
+    rc += writeString(info.getClientId(), bs);
+    rc += writeString(info.getPassword(), bs);
+    rc += writeString(info.getUserName(), bs);
+    rc += marshalObjectArray(wireFormat, info.getBrokerPath(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ConnectionInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    ConnectionInfo& info = (ConnectionInfo&) o;
+    marshal2CachedObject(wireFormat, info.getConnectionId(), dataOut, bs);
+    writeString(info.getClientId(), dataOut, bs);
+    writeString(info.getPassword(), dataOut, bs);
+    writeString(info.getUserName(), dataOut, bs);
+    marshalObjectArray(wireFormat, info.getBrokerPath(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ConnectionInfoMarshaller_hpp_
+#define ConnectionInfoMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ConnectionInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+    ConnectionInfoMarshaller() ;
+    virtual ~ConnectionInfoMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ConnectionInfoMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.cpp Wed Mar  1 09:34:23 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.
+ */
+#include "marshal/ConsumerIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  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
+ */
+
+ConsumerIdMarshaller::ConsumerIdMarshaller()
+{
+    // no-op
+}
+
+ConsumerIdMarshaller::~ConsumerIdMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ConsumerIdMarshaller::createObject() 
+{
+    return new ConsumerId();
+}
+
+byte ConsumerIdMarshaller::getDataStructureType() 
+{
+    return ConsumerId.ID_ConsumerId;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ConsumerIdMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    ConsumerId& info = (ConsumerId&) o;
+        info.setConnectionId(tightUnmarshalString(dataIn, bs));
+        info.setSessionId(tightUnmarshalLong(wireFormat, dataIn, bs));
+        info.setValue(tightUnmarshalLong(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ConsumerIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ConsumerId& info = (ConsumerId&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += writeString(info.getConnectionId(), bs);
+    rc += marshal1Long(wireFormat, info.getSessionId(), bs);
+    rc += marshal1Long(wireFormat, info.getValue(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ConsumerIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    ConsumerId& info = (ConsumerId&) o;
+    writeString(info.getConnectionId(), dataOut, bs);
+    marshal2Long(wireFormat, info.getSessionId(), dataOut, bs);
+    marshal2Long(wireFormat, info.getValue(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ConsumerIdMarshaller_hpp_
+#define ConsumerIdMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ConsumerIdMarshaller : public BaseDataStreamMarshaller
+{
+public:
+    ConsumerIdMarshaller() ;
+    virtual ~ConsumerIdMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ConsumerIdMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp Wed Mar  1 09:34:23 2006
@@ -0,0 +1,130 @@
+/*
+ * 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 "marshal/ConsumerInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ConsumerInfo
+ *
+ * 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
+ */
+
+ConsumerInfoMarshaller::ConsumerInfoMarshaller()
+{
+    // no-op
+}
+
+ConsumerInfoMarshaller::~ConsumerInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ConsumerInfoMarshaller::createObject() 
+{
+    return new ConsumerInfo();
+}
+
+byte ConsumerInfoMarshaller::getDataStructureType() 
+{
+    return ConsumerInfo.ID_ConsumerInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ConsumerInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    ConsumerInfo& info = (ConsumerInfo&) o;
+        info.setConsumerId((ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setBrowser(bs.readBoolean());
+        info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setPrefetchSize(dataIn.readInt());
+        info.setDispatchAsync(bs.readBoolean());
+        info.setSelector(tightUnmarshalString(dataIn, bs));
+        info.setSubcriptionName(tightUnmarshalString(dataIn, bs));
+        info.setNoLocal(bs.readBoolean());
+        info.setExclusive(bs.readBoolean());
+        info.setRetroactive(bs.readBoolean());
+        info.setPriority(dataIn.readByte());
+
+        if (bs.readBoolean()) {
+            short size = dataIn.readShort();
+            BrokerId value[] = new BrokerId[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (BrokerId) tightUnmarsalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.setBrokerPath(value);
+        }
+        else {
+            info.setBrokerPath(null);
+        }
+        info.setNetworkSubscription(bs.readBoolean());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ConsumerInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ConsumerInfo& info = (ConsumerInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs);
+    bs.writeBoolean(info.isBrowser());
+    rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+        bs.writeBoolean(info.isDispatchAsync());
+    rc += writeString(info.getSelector(), bs);
+    rc += writeString(info.getSubcriptionName(), bs);
+    bs.writeBoolean(info.isNoLocal());
+    bs.writeBoolean(info.isExclusive());
+    bs.writeBoolean(info.isRetroactive());
+        rc += marshalObjectArray(wireFormat, info.getBrokerPath(), bs);
+    bs.writeBoolean(info.isNetworkSubscription());
+
+    return rc + 2;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ConsumerInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    ConsumerInfo& info = (ConsumerInfo&) o;
+    marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs);
+    bs.readBoolean();
+    marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+    DataStreamMarshaller.writeInt(info.getPrefetchSize(), dataOut);
+    bs.readBoolean();
+    writeString(info.getSelector(), dataOut, bs);
+    writeString(info.getSubcriptionName(), dataOut, bs);
+    bs.readBoolean();
+    bs.readBoolean();
+    bs.readBoolean();
+    DataStreamMarshaller.writeByte(info.getPriority(), dataOut);
+    marshalObjectArray(wireFormat, info.getBrokerPath(), dataOut, bs);
+    bs.readBoolean();
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp Wed Mar  1 09:34:23 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.
+*/
+#ifndef ConsumerInfoMarshaller_hpp_
+#define ConsumerInfoMarshaller_hpp_
+
+#include <string>
+
+#include "command/DataStructure.hpp"
+
+/* we could cut this down  - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class ConsumerInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+    ConsumerInfoMarshaller() ;
+    virtual ~ConsumerInfoMarshaller() ;
+
+    virtual DataStructure* createCommand() ;
+    virtual byte getDataStructureType() ;
+    
+    virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+    virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ;
+    virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+     }
+    }
+  }
+}
+#endif /*ConsumerInfoMarshaller_hpp_*/



Mime
View raw message