Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 89665 invoked from network); 8 Mar 2006 15:17:47 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 8 Mar 2006 15:17:47 -0000 Received: (qmail 20757 invoked by uid 500); 8 Mar 2006 15:17:46 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 20653 invoked by uid 500); 8 Mar 2006 15:17:45 -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 20620 invoked by uid 99); 8 Mar 2006 15:17:45 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Mar 2006 07:17:45 -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; Wed, 08 Mar 2006 07:17:40 -0800 Received: (qmail 89426 invoked by uid 65534); 8 Mar 2006 15:17:19 -0000 Message-ID: <20060308151719.89424.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r384233 [4/5] - in /incubator/activemq/trunk/openwire-cpp/src: command/ marshal/ Date: Wed, 08 Mar 2006 15:16:45 -0000 To: activemq-commits@geronimo.apache.org From: jstrachan@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/JournalTransactionMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp?rev=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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 JournalTransactionMarshaller_hpp_ -#define JournalTransactionMarshaller_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 JournalTransactionMarshaller : public BaseDataStreamMarshaller -{ -public: - JournalTransactionMarshaller() ; - virtual ~JournalTransactionMarshaller() ; - - 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 /*JournalTransactionMarshaller_hpp_*/ +/* * 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 JournalTransactionMarshaller_hpp_ #define JournalTransactionMarshaller_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" #includ e "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 JournalTransactionMarshaller : public BaseDataStreamMarshaller { public: JournalTransactionMarshaller() ; virtual ~JournalTransactionMarshaller() ; 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) ; } ; /* na mespace */ } } } } #endif /*JournalTransactionMarshaller_hpp_*/ \ No newline at end of file Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp?rev=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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 KeepAliveInfoMarshaller_hpp_ -#define KeepAliveInfoMarshaller_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 KeepAliveInfoMarshaller : public BaseDataStreamMarshaller -{ -public: - KeepAliveInfoMarshaller() ; - virtual ~KeepAliveInfoMarshaller() ; - - 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 /*KeepAliveInfoMarshaller_hpp_*/ +/* * 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 KeepAliveInfoMarshaller_hpp_ #define KeepAliveInfoMarshaller_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 KeepAliveInfoMarshaller : public BaseDataStreamMarshaller { public: KeepAliveInfoMarshaller() ; virtual ~KeepAliveInfoMarshaller() ; 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 /*KeepAliveInfoMarshaller_hpp_*/ \ No newline at end of file Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp?rev=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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 LocalTransactionIdMarshaller_hpp_ -#define LocalTransactionIdMarshaller_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 LocalTransactionIdMarshaller : public TransactionIdMarshaller -{ -public: - LocalTransactionIdMarshaller() ; - virtual ~LocalTransactionIdMarshaller() ; - - 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 /*LocalTransactionIdMarshaller_hpp_*/ +/* * 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 LocalTransactionIdMarshaller_hpp_ #define LocalTransactionIdMarshaller_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" #includ e "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 LocalTransactionIdMarshaller : public TransactionIdMarshaller { public: LocalTransactionIdMarshaller() ; virtual ~LocalTransactionIdMarshaller() ; 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) ; } ; /* name space */ } } } } #endif /*LocalTransactionIdMarshaller_hpp_*/ \ No newline at end of file Modified: 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp Wed Mar 8 07:16:40 2006 @@ -59,6 +59,7 @@ #include "marshal/WireFormatInfoMarshaller.hpp" #include "marshal/ActiveMQTempTopicMarshaller.hpp" #include "marshal/DiscoveryEventMarshaller.hpp" +#include "marshal/ReplayCommandMarshaller.hpp" #include "marshal/ActiveMQTopicMarshaller.hpp" #include "marshal/BrokerInfoMarshaller.hpp" #include "marshal/DestinationInfoMarshaller.hpp" @@ -115,6 +116,7 @@ format.addMarshaller(new WireFormatInfoMarshaller()); format.addMarshaller(new ActiveMQTempTopicMarshaller()); format.addMarshaller(new DiscoveryEventMarshaller()); + format.addMarshaller(new ReplayCommandMarshaller()); format.addMarshaller(new ActiveMQTopicMarshaller()); format.addMarshaller(new BrokerInfoMarshaller()); format.addMarshaller(new DestinationInfoMarshaller()); Modified: 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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 - -#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 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_*/ +/* * 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 #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 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 /*Message AckMarshaller_hpp_*/ \ No newline at end of file Modified: 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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 - -#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 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_*/ +/* * 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 #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 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_*/ \ No newline at end of file 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp Wed Mar 8 07:16:40 2006 @@ -1,87 +1 @@ -/* - * 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); - -} +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.cpp?rev=384233&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.cpp Wed Mar 8 07:16:40 2006 @@ -0,0 +1,78 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include "marshal/ReplayCommandMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for ReplayCommand + * + * 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 + */ + +ReplayCommandMarshaller::ReplayCommandMarshaller() +{ + // no-op +} + +ReplayCommandMarshaller::~ReplayCommandMarshaller() +{ + // no-op +} + + + +DataStructure* ReplayCommandMarshaller::createObject() +{ + return new ReplayCommand(); +} + +byte ReplayCommandMarshaller::getDataStructureType() +{ + return ReplayCommand.ID_ReplayCommand; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void ReplayCommandMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int ReplayCommandMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + ReplayCommand& info = (ReplayCommand&) o; + + int rc = base.marshal1(wireFormat, info, bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void ReplayCommandMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.hpp?rev=384233&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -0,0 +1 @@ +/* * 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 ReplayCommandMarshaller_hpp_ #define ReplayCommandMarshaller_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 ReplayCommandMarshaller : public BaseCommandMarshaller { public: ReplayCommandMarshaller() ; virtual ~ReplayCommandMarshaller() ; 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 /*ReplayCommandMarshaller_hpp_*/ \ No newline at end of file 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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 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=384233&r1=384232&r2=384233&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp Wed Mar 8 07:16:40 2006 @@ -1,71 +1 @@ -/* -* 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_*/ +/* * 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