Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 60542 invoked from network); 7 Mar 2006 04:16:07 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 7 Mar 2006 04:16:07 -0000 Received: (qmail 64113 invoked by uid 500); 7 Mar 2006 04:16:03 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 63904 invoked by uid 500); 7 Mar 2006 04:16:02 -0000 Mailing-List: contact activemq-commits-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 63633 invoked by uid 99); 7 Mar 2006 04:15:58 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 06 Mar 2006 20:15:58 -0800 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [209.237.227.194] (HELO minotaur.apache.org) (209.237.227.194) by apache.org (qpsmtpd/0.29) with SMTP; Mon, 06 Mar 2006 20:15:44 -0800 Received: (qmail 60044 invoked by uid 65534); 7 Mar 2006 04:15:23 -0000 Message-ID: <20060307041523.60043.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r383767 [10/10] - in /incubator/activemq/trunk: activemq-core/src/gram/java/org/apache/activemq/openwire/tool/ activemq-core/src/gram/script/ activemq-core/src/main/java/org/apache/activemq/command/ activemq-core/src/main/java/org/apache/ac... Date: Tue, 07 Mar 2006 04:14:38 -0000 To: activemq-commits@geronimo.apache.org From: chirino@apache.org X-Mailer: svnmailer-1.0.7 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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/Produ cerId.hpp" #include "command/SessionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseCommandMarshaller.hpp" #include "util/ifr/p.hpp" 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& d ataOut, BooleanStream& bs) ; } ; /* namespace */ } } } } #endif /*MessageDispatchNotificationMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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/Session Id.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseDataStreamMarshaller.hpp" #include "util/ifr/p.hpp" 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 /*Messag eIdMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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.h pp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseCommandMarshaller.hpp" #include "util/ifr/p.hpp" 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_ */ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp Mon Mar 6 20:14:27 2006 @@ -1 +1,87 @@ -/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include "marshal/NetworkBridgeFilterMarshaller.hpp" using namespace apache::activemq::client::marshal; /* * Marshalling code for Open Wire Format for NetworkBridgeFilter * * 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 */ NetworkBridgeFilterMarshaller::NetworkBridgeFilterMarshaller() { // no-op } NetworkBridgeFilterMarshaller::~NetworkBridgeFilterMarshaller() { // no-op } DataStructure* NetworkBridgeFilterMarshaller::createObject() { return new NetworkBridgeFilter(); } byte NetworkBridgeFilterMarshaller::getDataStructureType() { return NetworkBridgeFilter.ID_NetworkBridgeFilter; } /* * Un-marshal an object instance from the data input stream */ void NetworkBridgeFilterMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) { base.unmarshal(wireFormat, o, dataIn, bs); NetworkBridgeFilter& info = (NetworkBridgeFilter&) o; info.setNetworkTTL(dataIn.readInt()); info.setNetworkBrokerId((org.apache.activemq.command.BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); } /* * Write the booleans that this object uses to a BooleanStream */ int NetworkBridgeFilterMarshaller: :marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { NetworkBridgeFilter& info = (NetworkBridgeFilter&) o; int rc = base.marshal1(wireFormat, info, bs); rc += marshal1CachedObject(wireFormat, info.getNetworkBrokerId(), bs); return rc + 1; } /* * Write a object instance to data output stream */ void NetworkBridgeFilterMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { base.marshal2(wireFormat, o, dataOut, bs); NetworkBridgeFilter& info = (NetworkBridgeFilter&) o; DataStreamMarshaller.writeInt(info.getNetworkTTL(), dataOut); marshal2CachedObject(wireFormat, info.getNetworkBrokerId(), dataOut, bs); } \ No newline at end of file +/* + * 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/NetworkBridgeFilterMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for NetworkBridgeFilter + * + * 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 + */ + +NetworkBridgeFilterMarshaller::NetworkBridgeFilterMarshaller() +{ + // no-op +} + +NetworkBridgeFilterMarshaller::~NetworkBridgeFilterMarshaller() +{ + // no-op +} + + + +DataStructure* NetworkBridgeFilterMarshaller::createObject() +{ + return new NetworkBridgeFilter(); +} + +byte NetworkBridgeFilterMarshaller::getDataStructureType() +{ + return NetworkBridgeFilter.ID_NetworkBridgeFilter; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void NetworkBridgeFilterMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + NetworkBridgeFilter& info = (NetworkBridgeFilter&) o; + info.setNetworkTTL(dataIn.readInt()); + info.setNetworkBrokerId((org.apache.activemq.command.BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int NetworkBridgeFilterMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + NetworkBridgeFilter& info = (NetworkBridgeFilter&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1CachedObject(wireFormat, info.getNetworkBrokerId(), bs); + + return rc + 1; +} + +/* + * Write a object instance to data output stream + */ +void NetworkBridgeFilterMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + NetworkBridgeFilter& info = (NetworkBridgeFilter&) o; + DataStreamMarshaller.writeInt(info.getNetworkTTL(), dataOut); + marshal2CachedObject(wireFormat, info.getNetworkBrokerId(), dataOut, bs); + +} Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 NetworkBridgeFilterMarshaller_hpp_ #define NetworkBridgeFilterMarshaller_hpp_ #include #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" #incl ude "command/SessionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseDataStreamMarshaller.hpp" #include "util/ifr/p.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; /* * */ class NetworkBridgeFilterMarshaller : public BaseDataStreamMarshaller { public: NetworkBridgeFilterMarshaller() ; virtual ~NetworkBridgeFilterMarshaller() ; 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 /*NetworkBridgeFilterMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 NetworkBridgeFilterMarshaller_hpp_ +#define NetworkBridgeFilterMarshaller_hpp_ + +#include + +#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.hpp" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class NetworkBridgeFilterMarshaller : public BaseDataStreamMarshaller +{ +public: + NetworkBridgeFilterMarshaller() ; + virtual ~NetworkBridgeFilterMarshaller() ; + + 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 /*NetworkBridgeFilterMarshaller_hpp_*/ Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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/Sessi onId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseDataStreamMarshaller.hpp" #include "util/ifr/p.hpp" 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 /*P roducerIdMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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/S essionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseCommandMarshaller.hpp" #include "util/ifr/p.hpp" 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_*/ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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/Sessi onId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseCommandMarshaller.hpp" #include "util/ifr/p.hpp" 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 /*RemoveI nfoMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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.hpp" 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_*/ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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.hpp" 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 /*ResponseMarshalle r_hpp_*/ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: 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=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 #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/Session Id.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseDataStreamMarshaller.hpp" #include "util/ifr/p.hpp" 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 /*Sessio nIdMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 + +#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.hpp" + +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_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 SessionInfoMarshaller_hpp_ #define SessionInfoMarshaller_hpp_ #include #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/Ses sionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseCommandMarshaller.hpp" #include "util/ifr/p.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; /* * */ class SessionInfoMarshaller : public BaseCommandMarshaller { public: SessionInfoMarshaller() ; virtual ~SessionInfoMarshaller() ; 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 /*Se ssionInfoMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 SessionInfoMarshaller_hpp_ +#define SessionInfoMarshaller_hpp_ + +#include + +#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.hpp" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class SessionInfoMarshaller : public BaseCommandMarshaller +{ +public: + SessionInfoMarshaller() ; + virtual ~SessionInfoMarshaller() ; + + 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 /*SessionInfoMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 ShutdownInfoMarshaller_hpp_ #define ShutdownInfoMarshaller_hpp_ #include #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/S essionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseCommandMarshaller.hpp" #include "util/ifr/p.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; /* * */ class ShutdownInfoMarshaller : public BaseCommandMarshaller { public: ShutdownInfoMarshaller() ; virtual ~ShutdownInfoMarshaller() ; 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 /*ShutdownInfoMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 ShutdownInfoMarshaller_hpp_ +#define ShutdownInfoMarshaller_hpp_ + +#include + +#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.hpp" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class ShutdownInfoMarshaller : public BaseCommandMarshaller +{ +public: + ShutdownInfoMarshaller() ; + virtual ~ShutdownInfoMarshaller() ; + + 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 /*ShutdownInfoMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 SubscriptionInfoMarshaller_hpp_ #define SubscriptionInfoMarshaller_hpp_ #include #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 "c ommand/SessionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseDataStreamMarshaller.hpp" #include "util/ifr/p.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; /* * */ class SubscriptionInfoMarshaller : public BaseDataStreamMarshaller { public: SubscriptionInfoMarshaller() ; virtual ~SubscriptionInfoMarshaller() ; 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 /*SubscriptionInfoMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 SubscriptionInfoMarshaller_hpp_ +#define SubscriptionInfoMarshaller_hpp_ + +#include + +#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.hpp" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class SubscriptionInfoMarshaller : public BaseDataStreamMarshaller +{ +public: + SubscriptionInfoMarshaller() ; + virtual ~SubscriptionInfoMarshaller() ; + + 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 /*SubscriptionInfoMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 TransactionIdMarshaller_hpp_ #define TransactionIdMarshaller_hpp_ #include #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.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; /* * */ class TransactionIdMarshaller : public BaseDataStreamMarshaller { public: TransactionIdMarshaller() ; virtual ~TransactionIdMarshaller() ; 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 /*TransactionIdMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 TransactionIdMarshaller_hpp_ +#define TransactionIdMarshaller_hpp_ + +#include + +#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.hpp" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class TransactionIdMarshaller : public BaseDataStreamMarshaller +{ +public: + TransactionIdMarshaller() ; + virtual ~TransactionIdMarshaller() ; + + 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 /*TransactionIdMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.hpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 TransactionInfoMarshaller_hpp_ #define TransactionInfoMarshaller_hpp_ #include #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 "com mand/SessionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseCommandMarshaller.hpp" #include "util/ifr/p.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; /* * */ class TransactionInfoMarshaller : public BaseCommandMarshaller { public: TransactionInfoMarshaller() ; virtual ~TransactionInfoMarshaller() ; 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 /*TransactionInfoMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 TransactionInfoMarshaller_hpp_ +#define TransactionInfoMarshaller_hpp_ + +#include + +#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.hpp" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class TransactionInfoMarshaller : public BaseCommandMarshaller +{ +public: + TransactionInfoMarshaller() ; + virtual ~TransactionInfoMarshaller() ; + + 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 /*TransactionInfoMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp Mon Mar 6 20:14:27 2006 @@ -56,10 +56,15 @@ base.unmarshal(wireFormat, o, dataIn, bs); WireFormatInfo& info = (WireFormatInfo&) o; + + info.beforeUnmarshall(wireFormat); + info.setMagic(tightUnmarshalConstByteArray(dataIn, bs, 8)); info.setVersion(dataIn.readInt()); info.setMarshalledProperties(tightUnmarshalByteSequence(dataIn, bs)); + info.afterUnmarshall(wireFormat); + } @@ -69,6 +74,8 @@ int WireFormatInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { WireFormatInfo& info = (WireFormatInfo&) o; + info.beforeMarshall(wireFormat); + int rc = base.marshal1(wireFormat, info, bs); bs.writeBoolean(info.getMarshalledProperties()!=null); rc += info.getMarshalledProperties()==null ? 0 : info.getMarshalledProperties().Length+4; @@ -89,5 +96,7 @@ DataStreamMarshaller.writeInt(info.getMarshalledProperties().Length, dataOut); dataOut.write(info.getMarshalledProperties()); } + + info.afterMarshall(wireFormat); } Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.hpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 WireFormatInfoMarshaller_hpp_ #define WireFormatInfoMarshaller_hpp_ #include #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 "comma nd/SessionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/BaseDataStreamMarshaller.hpp" #include "util/ifr/p.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; /* * */ class WireFormatInfoMarshaller : public BaseDataStreamMarshaller { public: WireFormatInfoMarshaller() ; virtual ~WireFormatInfoMarshaller() ; 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 /*WireFormatInfoMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 WireFormatInfoMarshaller_hpp_ +#define WireFormatInfoMarshaller_hpp_ + +#include + +#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.hpp" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class WireFormatInfoMarshaller : public BaseDataStreamMarshaller +{ +public: + WireFormatInfoMarshaller() ; + virtual ~WireFormatInfoMarshaller() ; + + 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 /*WireFormatInfoMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.hpp?rev=383767&r1=383766&r2=383767&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.hpp Mon Mar 6 20:14:27 2006 @@ -1 +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 XATransactionIdMarshaller_hpp_ #define XATransactionIdMarshaller_hpp_ #include #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 "com mand/SessionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/TransactionIdMarshaller.hpp" #include "util/ifr/p.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; /* * */ class XATransactionIdMarshaller : public TransactionIdMarshaller { public: XATransactionIdMarshaller() ; virtual ~XATransactionIdMarshaller() ; 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 /*XATransactionIdMarshaller_hpp_*/ \ No newline at end of file +/* +* 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 XATransactionIdMarshaller_hpp_ +#define XATransactionIdMarshaller_hpp_ + +#include + +#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/TransactionIdMarshaller.hpp" +#include "util/ifr/p.hpp" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class XATransactionIdMarshaller : public TransactionIdMarshaller +{ +public: + XATransactionIdMarshaller() ; + virtual ~XATransactionIdMarshaller() ; + + 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 /*XATransactionIdMarshaller_hpp_*/