You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/03/01 18:34:38 UTC
svn commit: r382091 [5/6] - in /incubator/activemq/trunk/openwire-cpp: ./
src/command/ src/marshal/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.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.
+*/
+
+// Marshalling code for Open Wire Format
+//
+//
+// NOTE!: This file is autogenerated - do not modify!
+// if you need to make a change, please see the Groovy scripts in the
+// activemq-openwire module
+//
+
+#include "marshal/ExceptionResponseMarshaller.hpp"
+
+#include "marshal/MessageIdMarshaller.hpp"
+#include "marshal/BrokerInfoMarshaller.hpp"
+#include "marshal/ActiveMQTempQueueMarshaller.hpp"
+#include "marshal/LocalTransactionIdMarshaller.hpp"
+#include "marshal/RemoveSubscriptionInfoMarshaller.hpp"
+#include "marshal/IntegerResponseMarshaller.hpp"
+#include "marshal/ActiveMQQueueMarshaller.hpp"
+#include "marshal/DestinationInfoMarshaller.hpp"
+#include "marshal/ActiveMQBytesMessageMarshaller.hpp"
+#include "marshal/ShutdownInfoMarshaller.hpp"
+#include "marshal/DataResponseMarshaller.hpp"
+#include "marshal/SessionIdMarshaller.hpp"
+#include "marshal/DataArrayResponseMarshaller.hpp"
+#include "marshal/JournalQueueAckMarshaller.hpp"
+#include "marshal/WireFormatInfoMarshaller.hpp"
+#include "marshal/ResponseMarshaller.hpp"
+#include "marshal/ConnectionErrorMarshaller.hpp"
+#include "marshal/ActiveMQObjectMessageMarshaller.hpp"
+#include "marshal/ConsumerInfoMarshaller.hpp"
+#include "marshal/ActiveMQTempTopicMarshaller.hpp"
+#include "marshal/ConnectionIdMarshaller.hpp"
+#include "marshal/DiscoveryEventMarshaller.hpp"
+#include "marshal/ConnectionInfoMarshaller.hpp"
+#include "marshal/KeepAliveInfoMarshaller.hpp"
+#include "marshal/XATransactionIdMarshaller.hpp"
+#include "marshal/JournalTraceMarshaller.hpp"
+#include "marshal/FlushCommandMarshaller.hpp"
+#include "marshal/ConsumerIdMarshaller.hpp"
+#include "marshal/JournalTopicAckMarshaller.hpp"
+#include "marshal/ActiveMQTextMessageMarshaller.hpp"
+#include "marshal/BrokerIdMarshaller.hpp"
+#include "marshal/MessageDispatchMarshaller.hpp"
+#include "marshal/ProducerInfoMarshaller.hpp"
+#include "marshal/SubscriptionInfoMarshaller.hpp"
+#include "marshal/ActiveMQMapMessageMarshaller.hpp"
+#include "marshal/MessageDispatchNotificationMarshaller.hpp"
+#include "marshal/SessionInfoMarshaller.hpp"
+#include "marshal/ActiveMQMessageMarshaller.hpp"
+#include "marshal/TransactionInfoMarshaller.hpp"
+#include "marshal/ActiveMQStreamMessageMarshaller.hpp"
+#include "marshal/MessageAckMarshaller.hpp"
+#include "marshal/ProducerIdMarshaller.hpp"
+#include "marshal/ActiveMQTopicMarshaller.hpp"
+#include "marshal/JournalTransactionMarshaller.hpp"
+#include "marshal/RemoveInfoMarshaller.hpp"
+#include "marshal/ControlCommandMarshaller.hpp"
+#include "marshal/ExceptionResponseMarshaller.hpp"
+
+
+using namespace apache::activemq::client::marshal;
+
+
+void MarshallerFactory::configure(OpenWireFormat& format)
+{
+
+ format.addMarshaller(new MessageIdMarshaller());
+ format.addMarshaller(new BrokerInfoMarshaller());
+ format.addMarshaller(new ActiveMQTempQueueMarshaller());
+ format.addMarshaller(new LocalTransactionIdMarshaller());
+ format.addMarshaller(new RemoveSubscriptionInfoMarshaller());
+ format.addMarshaller(new IntegerResponseMarshaller());
+ format.addMarshaller(new ActiveMQQueueMarshaller());
+ format.addMarshaller(new DestinationInfoMarshaller());
+ format.addMarshaller(new ActiveMQBytesMessageMarshaller());
+ format.addMarshaller(new ShutdownInfoMarshaller());
+ format.addMarshaller(new DataResponseMarshaller());
+ format.addMarshaller(new SessionIdMarshaller());
+ format.addMarshaller(new DataArrayResponseMarshaller());
+ format.addMarshaller(new JournalQueueAckMarshaller());
+ format.addMarshaller(new WireFormatInfoMarshaller());
+ format.addMarshaller(new ResponseMarshaller());
+ format.addMarshaller(new ConnectionErrorMarshaller());
+ format.addMarshaller(new ActiveMQObjectMessageMarshaller());
+ format.addMarshaller(new ConsumerInfoMarshaller());
+ format.addMarshaller(new ActiveMQTempTopicMarshaller());
+ format.addMarshaller(new ConnectionIdMarshaller());
+ format.addMarshaller(new DiscoveryEventMarshaller());
+ format.addMarshaller(new ConnectionInfoMarshaller());
+ format.addMarshaller(new KeepAliveInfoMarshaller());
+ format.addMarshaller(new XATransactionIdMarshaller());
+ format.addMarshaller(new JournalTraceMarshaller());
+ format.addMarshaller(new FlushCommandMarshaller());
+ format.addMarshaller(new ConsumerIdMarshaller());
+ format.addMarshaller(new JournalTopicAckMarshaller());
+ format.addMarshaller(new ActiveMQTextMessageMarshaller());
+ format.addMarshaller(new BrokerIdMarshaller());
+ format.addMarshaller(new MessageDispatchMarshaller());
+ format.addMarshaller(new ProducerInfoMarshaller());
+ format.addMarshaller(new SubscriptionInfoMarshaller());
+ format.addMarshaller(new ActiveMQMapMessageMarshaller());
+ format.addMarshaller(new MessageDispatchNotificationMarshaller());
+ format.addMarshaller(new SessionInfoMarshaller());
+ format.addMarshaller(new ActiveMQMessageMarshaller());
+ format.addMarshaller(new TransactionInfoMarshaller());
+ format.addMarshaller(new ActiveMQStreamMessageMarshaller());
+ format.addMarshaller(new MessageAckMarshaller());
+ format.addMarshaller(new ProducerIdMarshaller());
+ format.addMarshaller(new ActiveMQTopicMarshaller());
+ format.addMarshaller(new JournalTransactionMarshaller());
+ format.addMarshaller(new RemoveInfoMarshaller());
+ format.addMarshaller(new ControlCommandMarshaller());
+ format.addMarshaller(new ExceptionResponseMarshaller());
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp Wed Mar 1 09:34:23 2006
@@ -0,0 +1,62 @@
+//*
+* 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.
+*/
+
+// Marshalling code for Open Wire Format
+//
+//
+// NOTE!: This file is autogenerated - do not modify!
+// if you need to make a change, please see the Groovy scripts in the
+// activemq-openwire module
+//
+
+#ifndef MarshallerFactory_hpp_
+#define MarshallerFactory_hpp_
+
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace std ;
+ using namespace apache::activemq::client;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+
+/*
+ *
+ */
+class MarshallerFactory
+{
+public:
+ MarshallerFactory() ;
+ virtual ~MarshallerFactory() ;
+
+ virtual void configure(OpenWireFormat& format) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*MarshallerFactory_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp Wed Mar 1 09:34:23 2006
@@ -0,0 +1,101 @@
+/*
+ * 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/MessageAckMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+MessageAckMarshaller::MessageAckMarshaller()
+{
+ // no-op
+}
+
+MessageAckMarshaller::~MessageAckMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* MessageAckMarshaller::createObject()
+{
+ return new MessageAck();
+}
+
+byte MessageAckMarshaller::getDataStructureType()
+{
+ return MessageAck.ID_MessageAck;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void MessageAckMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ MessageAck& info = (MessageAck&) o;
+ info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setTransactionId((TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setConsumerId((ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setAckType(dataIn.readByte());
+ info.setFirstMessageId((MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+ info.setLastMessageId((MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+ info.setMessageCount(dataIn.readInt());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageAckMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ MessageAck& info = (MessageAck&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getTransactionId(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs);
+ rc += marshal1NestedObject(wireFormat, info.getFirstMessageId(), bs);
+ rc += marshal1NestedObject(wireFormat, info.getLastMessageId(), bs);
+
+ return rc + 2;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void MessageAckMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ MessageAck& info = (MessageAck&) o;
+ marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getTransactionId(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs);
+ DataStreamMarshaller.writeByte(info.getAckType(), dataOut);
+ marshal2NestedObject(wireFormat, info.getFirstMessageId(), dataOut, bs);
+ marshal2NestedObject(wireFormat, info.getLastMessageId(), dataOut, bs);
+ DataStreamMarshaller.writeInt(info.getMessageCount(), dataOut);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.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 MessageAckMarshaller_hpp_
+#define MessageAckMarshaller_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 MessageAckMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessageAckMarshaller() ;
+ virtual ~MessageAckMarshaller() ;
+
+ 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 /*MessageAckMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp Wed Mar 1 09:34:23 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.
+ */
+#include "marshal/MessageDispatchMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+MessageDispatchMarshaller::MessageDispatchMarshaller()
+{
+ // no-op
+}
+
+MessageDispatchMarshaller::~MessageDispatchMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* MessageDispatchMarshaller::createObject()
+{
+ return new MessageDispatch();
+}
+
+byte MessageDispatchMarshaller::getDataStructureType()
+{
+ return MessageDispatch.ID_MessageDispatch;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void MessageDispatchMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ MessageDispatch& info = (MessageDispatch&) o;
+ info.setConsumerId((ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setMessage((Message) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+ info.setRedeliveryCounter(dataIn.readInt());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageDispatchMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ MessageDispatch& info = (MessageDispatch&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+ rc += marshal1NestedObject(wireFormat, info.getMessage(), bs);
+
+ return rc + 1;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void MessageDispatchMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ MessageDispatch& info = (MessageDispatch&) o;
+ marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+ marshal2NestedObject(wireFormat, info.getMessage(), dataOut, bs);
+ DataStreamMarshaller.writeInt(info.getRedeliveryCounter(), dataOut);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.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 MessageDispatchMarshaller_hpp_
+#define MessageDispatchMarshaller_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 MessageDispatchMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessageDispatchMarshaller() ;
+ virtual ~MessageDispatchMarshaller() ;
+
+ 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 /*MessageDispatchMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp Wed Mar 1 09:34:23 2006
@@ -0,0 +1,94 @@
+/*
+ * 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/MessageDispatchNotificationMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+MessageDispatchNotificationMarshaller::MessageDispatchNotificationMarshaller()
+{
+ // no-op
+}
+
+MessageDispatchNotificationMarshaller::~MessageDispatchNotificationMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* MessageDispatchNotificationMarshaller::createObject()
+{
+ return new MessageDispatchNotification();
+}
+
+byte MessageDispatchNotificationMarshaller::getDataStructureType()
+{
+ return MessageDispatchNotification.ID_MessageDispatchNotification;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void MessageDispatchNotificationMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ MessageDispatchNotification& info = (MessageDispatchNotification&) o;
+ info.setConsumerId((ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setDeliverySequenceId(tightUnmarshalLong(wireFormat, dataIn, bs));
+ info.setMessageId((MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageDispatchNotificationMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ MessageDispatchNotification& info = (MessageDispatchNotification&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+ rc += marshal1Long(wireFormat, info.getDeliverySequenceId(), bs);
+ rc += marshal1NestedObject(wireFormat, info.getMessageId(), bs);
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void MessageDispatchNotificationMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ MessageDispatchNotification& info = (MessageDispatchNotification&) o;
+ marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+ marshal2Long(wireFormat, info.getDeliverySequenceId(), dataOut, bs);
+ marshal2NestedObject(wireFormat, info.getMessageId(), dataOut, bs);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.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 MessageDispatchNotificationMarshaller_hpp_
+#define MessageDispatchNotificationMarshaller_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 MessageDispatchNotificationMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessageDispatchNotificationMarshaller() ;
+ virtual ~MessageDispatchNotificationMarshaller() ;
+
+ 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 /*MessageDispatchNotificationMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.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/MessageIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+MessageIdMarshaller::MessageIdMarshaller()
+{
+ // no-op
+}
+
+MessageIdMarshaller::~MessageIdMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* MessageIdMarshaller::createObject()
+{
+ return new MessageId();
+}
+
+byte MessageIdMarshaller::getDataStructureType()
+{
+ return MessageId.ID_MessageId;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void MessageIdMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ MessageId& info = (MessageId&) o;
+ info.setProducerId((ProducerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setProducerSequenceId(tightUnmarshalLong(wireFormat, dataIn, bs));
+ info.setBrokerSequenceId(tightUnmarshalLong(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ MessageId& info = (MessageId&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getProducerId(), bs);
+ rc += marshal1Long(wireFormat, info.getProducerSequenceId(), bs);
+ rc += marshal1Long(wireFormat, info.getBrokerSequenceId(), bs);
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void MessageIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ MessageId& info = (MessageId&) o;
+ marshal2CachedObject(wireFormat, info.getProducerId(), dataOut, bs);
+ marshal2Long(wireFormat, info.getProducerSequenceId(), dataOut, bs);
+ marshal2Long(wireFormat, info.getBrokerSequenceId(), dataOut, bs);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.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 MessageIdMarshaller_hpp_
+#define MessageIdMarshaller_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 MessageIdMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ MessageIdMarshaller() ;
+ virtual ~MessageIdMarshaller() ;
+
+ 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 /*MessageIdMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp Wed Mar 1 09:34:23 2006
@@ -0,0 +1,162 @@
+/*
+ * 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/MessageMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+MessageMarshaller::MessageMarshaller()
+{
+ // no-op
+}
+
+MessageMarshaller::~MessageMarshaller()
+{
+ // no-op
+}
+
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void MessageMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ Message& info = (Message&) o;
+ info.setProducerId((ProducerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setTransactionId((TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setOriginalDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setMessageId((MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+ info.setOriginalTransactionId((TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setGroupID(tightUnmarshalString(dataIn, bs));
+ info.setGroupSequence(dataIn.readInt());
+ info.setCorrelationId(tightUnmarshalString(dataIn, bs));
+ info.setPersistent(bs.readBoolean());
+ info.setExpiration(tightUnmarshalLong(wireFormat, dataIn, bs));
+ info.setPriority(dataIn.readByte());
+ info.setReplyTo((ActiveMQDestination) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+ info.setTimestamp(tightUnmarshalLong(wireFormat, dataIn, bs));
+ info.setType(tightUnmarshalString(dataIn, bs));
+ info.setContent(tightUnmarshalByteSequence(dataIn, bs));
+ info.setMarshalledProperties(tightUnmarshalByteSequence(dataIn, bs));
+ info.setDataStructure((DataStructure) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+ info.setTargetConsumerId((ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setCompressed(bs.readBoolean());
+ info.setRedeliveryCounter(dataIn.readInt());
+
+ 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.setArrival(tightUnmarshalLong(wireFormat, dataIn, bs));
+ info.setUserID(tightUnmarshalString(dataIn, bs));
+ info.setRecievedByDFBridge(bs.readBoolean());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ Message& info = (Message&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getProducerId(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getTransactionId(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getOriginalDestination(), bs);
+ rc += marshal1NestedObject(wireFormat, info.getMessageId(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getOriginalTransactionId(), bs);
+ rc += writeString(info.getGroupID(), bs);
+ rc += writeString(info.getCorrelationId(), bs);
+ bs.writeBoolean(info.isPersistent());
+ rc += marshal1Long(wireFormat, info.getExpiration(), bs);
+ rc += marshal1NestedObject(wireFormat, info.getReplyTo(), bs);
+ rc += marshal1Long(wireFormat, info.getTimestamp(), bs);
+ rc += writeString(info.getType(), bs);
+ bs.writeBoolean(info.getContent()!=null);
+ rc += info.getContent()==null ? 0 : info.getContent().Length+4;
+ bs.writeBoolean(info.getMarshalledProperties()!=null);
+ rc += info.getMarshalledProperties()==null ? 0 : info.getMarshalledProperties().Length+4;
+ rc += marshal1NestedObject(wireFormat, info.getDataStructure(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getTargetConsumerId(), bs);
+ bs.writeBoolean(info.isCompressed());
+ rc += marshalObjectArray(wireFormat, info.getBrokerPath(), bs);
+ rc += marshal1Long(wireFormat, info.getArrival(), bs);
+ rc += writeString(info.getUserID(), bs);
+ bs.writeBoolean(info.isRecievedByDFBridge());
+
+ return rc + 3;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void MessageMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ Message& info = (Message&) o;
+ marshal2CachedObject(wireFormat, info.getProducerId(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getTransactionId(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getOriginalDestination(), dataOut, bs);
+ marshal2NestedObject(wireFormat, info.getMessageId(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getOriginalTransactionId(), dataOut, bs);
+ writeString(info.getGroupID(), dataOut, bs);
+ DataStreamMarshaller.writeInt(info.getGroupSequence(), dataOut);
+ writeString(info.getCorrelationId(), dataOut, bs);
+ bs.readBoolean();
+ marshal2Long(wireFormat, info.getExpiration(), dataOut, bs);
+ DataStreamMarshaller.writeByte(info.getPriority(), dataOut);
+ marshal2NestedObject(wireFormat, info.getReplyTo(), dataOut, bs);
+ marshal2Long(wireFormat, info.getTimestamp(), dataOut, bs);
+ writeString(info.getType(), dataOut, bs);
+ if(bs.readBoolean()) {
+ DataStreamMarshaller.writeInt(info.getContent().Length, dataOut);
+ dataOut.write(info.getContent());
+ }
+ if(bs.readBoolean()) {
+ DataStreamMarshaller.writeInt(info.getMarshalledProperties().Length, dataOut);
+ dataOut.write(info.getMarshalledProperties());
+ }
+ marshal2NestedObject(wireFormat, info.getDataStructure(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getTargetConsumerId(), dataOut, bs);
+ bs.readBoolean();
+ DataStreamMarshaller.writeInt(info.getRedeliveryCounter(), dataOut);
+ marshalObjectArray(wireFormat, info.getBrokerPath(), dataOut, bs);
+ marshal2Long(wireFormat, info.getArrival(), dataOut, bs);
+ writeString(info.getUserID(), dataOut, bs);
+ bs.readBoolean();
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.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 MessageMarshaller_hpp_
+#define MessageMarshaller_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 MessageMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessageMarshaller() ;
+ virtual ~MessageMarshaller() ;
+
+ 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 /*MessageMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.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/ProducerIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+ProducerIdMarshaller::ProducerIdMarshaller()
+{
+ // no-op
+}
+
+ProducerIdMarshaller::~ProducerIdMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* ProducerIdMarshaller::createObject()
+{
+ return new ProducerId();
+}
+
+byte ProducerIdMarshaller::getDataStructureType()
+{
+ return ProducerId.ID_ProducerId;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void ProducerIdMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ ProducerId& info = (ProducerId&) o;
+ info.setConnectionId(tightUnmarshalString(dataIn, bs));
+ info.setValue(tightUnmarshalLong(wireFormat, dataIn, bs));
+ info.setSessionId(tightUnmarshalLong(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ProducerIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ ProducerId& info = (ProducerId&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += writeString(info.getConnectionId(), bs);
+ rc += marshal1Long(wireFormat, info.getValue(), bs);
+ rc += marshal1Long(wireFormat, info.getSessionId(), bs);
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void ProducerIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ ProducerId& info = (ProducerId&) o;
+ writeString(info.getConnectionId(), dataOut, bs);
+ marshal2Long(wireFormat, info.getValue(), dataOut, bs);
+ marshal2Long(wireFormat, info.getSessionId(), dataOut, bs);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.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 ProducerIdMarshaller_hpp_
+#define ProducerIdMarshaller_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 ProducerIdMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ ProducerIdMarshaller() ;
+ virtual ~ProducerIdMarshaller() ;
+
+ 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 /*ProducerIdMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.cpp Wed Mar 1 09:34:23 2006
@@ -0,0 +1,102 @@
+/*
+ * 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/ProducerInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+ProducerInfoMarshaller::ProducerInfoMarshaller()
+{
+ // no-op
+}
+
+ProducerInfoMarshaller::~ProducerInfoMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* ProducerInfoMarshaller::createObject()
+{
+ return new ProducerInfo();
+}
+
+byte ProducerInfoMarshaller::getDataStructureType()
+{
+ return ProducerInfo.ID_ProducerInfo;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void ProducerInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ ProducerInfo& info = (ProducerInfo&) o;
+ info.setProducerId((ProducerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, 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 ProducerInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ ProducerInfo& info = (ProducerInfo&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getProducerId(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+ rc += marshalObjectArray(wireFormat, info.getBrokerPath(), bs);
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void ProducerInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ ProducerInfo& info = (ProducerInfo&) o;
+ marshal2CachedObject(wireFormat, info.getProducerId(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+ marshalObjectArray(wireFormat, info.getBrokerPath(), dataOut, bs);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.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 ProducerInfoMarshaller_hpp_
+#define ProducerInfoMarshaller_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 ProducerInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+ ProducerInfoMarshaller() ;
+ virtual ~ProducerInfoMarshaller() ;
+
+ 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 /*ProducerInfoMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.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/RemoveInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+RemoveInfoMarshaller::RemoveInfoMarshaller()
+{
+ // no-op
+}
+
+RemoveInfoMarshaller::~RemoveInfoMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* RemoveInfoMarshaller::createObject()
+{
+ return new RemoveInfo();
+}
+
+byte RemoveInfoMarshaller::getDataStructureType()
+{
+ return RemoveInfo.ID_RemoveInfo;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void RemoveInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ RemoveInfo& info = (RemoveInfo&) o;
+ info.setObjectId((DataStructure) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int RemoveInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ RemoveInfo& info = (RemoveInfo&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getObjectId(), bs);
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void RemoveInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ RemoveInfo& info = (RemoveInfo&) o;
+ marshal2CachedObject(wireFormat, info.getObjectId(), dataOut, bs);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.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 RemoveInfoMarshaller_hpp_
+#define RemoveInfoMarshaller_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 RemoveInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+ RemoveInfoMarshaller() ;
+ virtual ~RemoveInfoMarshaller() ;
+
+ 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 /*RemoveInfoMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.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/RemoveSubscriptionInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+RemoveSubscriptionInfoMarshaller::RemoveSubscriptionInfoMarshaller()
+{
+ // no-op
+}
+
+RemoveSubscriptionInfoMarshaller::~RemoveSubscriptionInfoMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* RemoveSubscriptionInfoMarshaller::createObject()
+{
+ return new RemoveSubscriptionInfo();
+}
+
+byte RemoveSubscriptionInfoMarshaller::getDataStructureType()
+{
+ return RemoveSubscriptionInfo.ID_RemoveSubscriptionInfo;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void RemoveSubscriptionInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ RemoveSubscriptionInfo& info = (RemoveSubscriptionInfo&) o;
+ info.setConnectionId((ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+ info.setSubcriptionName(tightUnmarshalString(dataIn, bs));
+ info.setClientId(tightUnmarshalString(dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int RemoveSubscriptionInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ RemoveSubscriptionInfo& info = (RemoveSubscriptionInfo&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getConnectionId(), bs);
+ rc += writeString(info.getSubcriptionName(), bs);
+ rc += writeString(info.getClientId(), bs);
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void RemoveSubscriptionInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ RemoveSubscriptionInfo& info = (RemoveSubscriptionInfo&) o;
+ marshal2CachedObject(wireFormat, info.getConnectionId(), dataOut, bs);
+ writeString(info.getSubcriptionName(), dataOut, bs);
+ writeString(info.getClientId(), dataOut, bs);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.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 RemoveSubscriptionInfoMarshaller_hpp_
+#define RemoveSubscriptionInfoMarshaller_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 RemoveSubscriptionInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+ RemoveSubscriptionInfoMarshaller() ;
+ virtual ~RemoveSubscriptionInfoMarshaller() ;
+
+ 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 /*RemoveSubscriptionInfoMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.cpp Wed Mar 1 09:34:23 2006
@@ -0,0 +1,84 @@
+/*
+ * 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/ResponseMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+ResponseMarshaller::ResponseMarshaller()
+{
+ // no-op
+}
+
+ResponseMarshaller::~ResponseMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* ResponseMarshaller::createObject()
+{
+ return new Response();
+}
+
+byte ResponseMarshaller::getDataStructureType()
+{
+ return Response.ID_Response;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void ResponseMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ Response& info = (Response&) o;
+ info.setCorrelationId(dataIn.readShort());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int ResponseMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ Response& info = (Response&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+
+ return rc + 1;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void ResponseMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ Response& info = (Response&) o;
+ DataStreamMarshaller.writeShort(info.getCorrelationId(), dataOut);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.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 ResponseMarshaller_hpp_
+#define ResponseMarshaller_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 ResponseMarshaller : public BaseCommandMarshaller
+{
+public:
+ ResponseMarshaller() ;
+ virtual ~ResponseMarshaller() ;
+
+ 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 /*ResponseMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.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/SessionIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * 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
+ */
+
+SessionIdMarshaller::SessionIdMarshaller()
+{
+ // no-op
+}
+
+SessionIdMarshaller::~SessionIdMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* SessionIdMarshaller::createObject()
+{
+ return new SessionId();
+}
+
+byte SessionIdMarshaller::getDataStructureType()
+{
+ return SessionId.ID_SessionId;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void SessionIdMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ SessionId& info = (SessionId&) o;
+ info.setConnectionId(tightUnmarshalString(dataIn, bs));
+ info.setValue(tightUnmarshalLong(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int SessionIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ SessionId& info = (SessionId&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += writeString(info.getConnectionId(), bs);
+ rc += marshal1Long(wireFormat, info.getValue(), bs);
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void SessionIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ SessionId& info = (SessionId&) o;
+ writeString(info.getConnectionId(), dataOut, bs);
+ marshal2Long(wireFormat, info.getValue(), dataOut, bs);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.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 SessionIdMarshaller_hpp_
+#define SessionIdMarshaller_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 SessionIdMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ SessionIdMarshaller() ;
+ virtual ~SessionIdMarshaller() ;
+
+ 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 /*SessionIdMarshaller_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.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/SessionInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ * Marshalling code for Open Wire Format for SessionInfo
+ *
+ * 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
+ */
+
+SessionInfoMarshaller::SessionInfoMarshaller()
+{
+ // no-op
+}
+
+SessionInfoMarshaller::~SessionInfoMarshaller()
+{
+ // no-op
+}
+
+
+
+DataStructure* SessionInfoMarshaller::createObject()
+{
+ return new SessionInfo();
+}
+
+byte SessionInfoMarshaller::getDataStructureType()
+{
+ return SessionInfo.ID_SessionInfo;
+}
+
+ /*
+ * Un-marshal an object instance from the data input stream
+ */
+void SessionInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ base.unmarshal(wireFormat, o, dataIn, bs);
+
+ SessionInfo& info = (SessionInfo&) o;
+ info.setSessionId((SessionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int SessionInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) {
+ SessionInfo& info = (SessionInfo&) o;
+
+ int rc = base.marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getSessionId(), bs);
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void SessionInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ base.marshal2(wireFormat, o, dataOut, bs);
+
+ SessionInfo& info = (SessionInfo&) o;
+ marshal2CachedObject(wireFormat, info.getSessionId(), dataOut, bs);
+
+}
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL