Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 90159 invoked from network); 5 Mar 2006 08:50:06 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 5 Mar 2006 08:50:06 -0000 Received: (qmail 4586 invoked by uid 500); 5 Mar 2006 08:50:52 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 4468 invoked by uid 500); 5 Mar 2006 08:50:51 -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 4341 invoked by uid 99); 5 Mar 2006 08:50:50 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 05 Mar 2006 00:50:50 -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; Sun, 05 Mar 2006 00:50:44 -0800 Received: (qmail 89963 invoked by uid 65534); 5 Mar 2006 08:49:37 -0000 Message-ID: <20060305084937.89961.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r383296 [3/5] - in /incubator/activemq/trunk: activemq-core/ activemq-core/src/gram/java/org/apache/activemq/openwire/tool/ activemq-core/src/gram/script/ activemq-core/src/main/java/org/apache/activemq/openwire/v1/ activemq-core/src/test/j... Date: Sun, 05 Mar 2006 08:49:19 -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/ActiveMQTempDestinationMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ActiveMQTempDestinationMarshaller_hpp_ -#define ActiveMQTempDestinationMarshaller_hpp_ - -#include - -#include "command/DataStructure.hpp" - -/* we could cut this down - for now include all possible headers */ -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQDestinationMarshaller.hpp" -#include "util/ifr/p.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 ActiveMQTempDestinationMarshaller : public ActiveMQDestinationMarshaller -{ -public: - ActiveMQTempDestinationMarshaller() ; - virtual ~ActiveMQTempDestinationMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ActiveMQTempDestinationMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ActiveMQTempDestinationMarshaller_hpp_ +#define ActiveMQTempDestinationMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQDestinationMarshaller.hpp" +#include "util/ifr/p.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 ActiveMQTempDestinationMarshaller : public ActiveMQDestinationMarshaller +{ +public: + ActiveMQTempDestinationMarshaller() ; + virtual ~ActiveMQTempDestinationMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ActiveMQTempDestinationMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ActiveMQTempQueueMarshaller_hpp_ -#define ActiveMQTempQueueMarshaller_hpp_ - -#include - -#include "command/DataStructure.hpp" - -/* we could cut this down - for now include all possible headers */ -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQTempDestinationMarshaller.hpp" -#include "util/ifr/p.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 ActiveMQTempQueueMarshaller : public ActiveMQTempDestinationMarshaller -{ -public: - ActiveMQTempQueueMarshaller() ; - virtual ~ActiveMQTempQueueMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ActiveMQTempQueueMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ActiveMQTempQueueMarshaller_hpp_ +#define ActiveMQTempQueueMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQTempDestinationMarshaller.hpp" +#include "util/ifr/p.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 ActiveMQTempQueueMarshaller : public ActiveMQTempDestinationMarshaller +{ +public: + ActiveMQTempQueueMarshaller() ; + virtual ~ActiveMQTempQueueMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ActiveMQTempQueueMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ActiveMQTempTopicMarshaller_hpp_ -#define ActiveMQTempTopicMarshaller_hpp_ - -#include - -#include "command/DataStructure.hpp" - -/* we could cut this down - for now include all possible headers */ -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQTempDestinationMarshaller.hpp" -#include "util/ifr/p.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 ActiveMQTempTopicMarshaller : public ActiveMQTempDestinationMarshaller -{ -public: - ActiveMQTempTopicMarshaller() ; - virtual ~ActiveMQTempTopicMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ActiveMQTempTopicMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ActiveMQTempTopicMarshaller_hpp_ +#define ActiveMQTempTopicMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQTempDestinationMarshaller.hpp" +#include "util/ifr/p.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 ActiveMQTempTopicMarshaller : public ActiveMQTempDestinationMarshaller +{ +public: + ActiveMQTempTopicMarshaller() ; + virtual ~ActiveMQTempTopicMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ActiveMQTempTopicMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ActiveMQTextMessageMarshaller_hpp_ -#define ActiveMQTextMessageMarshaller_hpp_ - -#include - -#include "command/DataStructure.hpp" - -/* we could cut this down - for now include all possible headers */ -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQMessageMarshaller.hpp" -#include "util/ifr/p.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 ActiveMQTextMessageMarshaller : public ActiveMQMessageMarshaller -{ -public: - ActiveMQTextMessageMarshaller() ; - virtual ~ActiveMQTextMessageMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ActiveMQTextMessageMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ActiveMQTextMessageMarshaller_hpp_ +#define ActiveMQTextMessageMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQMessageMarshaller.hpp" +#include "util/ifr/p.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 ActiveMQTextMessageMarshaller : public ActiveMQMessageMarshaller +{ +public: + ActiveMQTextMessageMarshaller() ; + virtual ~ActiveMQTextMessageMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ActiveMQTextMessageMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ActiveMQTopicMarshaller_hpp_ -#define ActiveMQTopicMarshaller_hpp_ - -#include - -#include "command/DataStructure.hpp" - -/* we could cut this down - for now include all possible headers */ -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQDestinationMarshaller.hpp" -#include "util/ifr/p.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 ActiveMQTopicMarshaller : public ActiveMQDestinationMarshaller -{ -public: - ActiveMQTopicMarshaller() ; - virtual ~ActiveMQTopicMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ActiveMQTopicMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ActiveMQTopicMarshaller_hpp_ +#define ActiveMQTopicMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQDestinationMarshaller.hpp" +#include "util/ifr/p.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 ActiveMQTopicMarshaller : public ActiveMQDestinationMarshaller +{ +public: + ActiveMQTopicMarshaller() ; + virtual ~ActiveMQTopicMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ActiveMQTopicMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef BaseCommandMarshaller_hpp_ -#define BaseCommandMarshaller_hpp_ - -#include - -#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 BaseCommandMarshaller : public BaseDataStreamMarshaller -{ -public: - BaseCommandMarshaller() ; - virtual ~BaseCommandMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*BaseCommandMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef BaseCommandMarshaller_hpp_ +#define BaseCommandMarshaller_hpp_ + +#include + +#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 BaseCommandMarshaller : public BaseDataStreamMarshaller +{ +public: + BaseCommandMarshaller() ; + virtual ~BaseCommandMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*BaseCommandMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ConnectionErrorMarshaller_hpp_ -#define ConnectionErrorMarshaller_hpp_ - -#include - -#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 ConnectionErrorMarshaller : public BaseCommandMarshaller -{ -public: - ConnectionErrorMarshaller() ; - virtual ~ConnectionErrorMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ConnectionErrorMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ConnectionErrorMarshaller_hpp_ +#define ConnectionErrorMarshaller_hpp_ + +#include + +#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 ConnectionErrorMarshaller : public BaseCommandMarshaller +{ +public: + ConnectionErrorMarshaller() ; + virtual ~ConnectionErrorMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ConnectionErrorMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ConnectionIdMarshaller_hpp_ -#define ConnectionIdMarshaller_hpp_ - -#include - -#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 ConnectionIdMarshaller : public BaseDataStreamMarshaller -{ -public: - ConnectionIdMarshaller() ; - virtual ~ConnectionIdMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ConnectionIdMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ConnectionIdMarshaller_hpp_ +#define ConnectionIdMarshaller_hpp_ + +#include + +#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 ConnectionIdMarshaller : public BaseDataStreamMarshaller +{ +public: + ConnectionIdMarshaller() ; + virtual ~ConnectionIdMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ConnectionIdMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ConnectionInfoMarshaller_hpp_ -#define ConnectionInfoMarshaller_hpp_ - -#include - -#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 ConnectionInfoMarshaller : public BaseCommandMarshaller -{ -public: - ConnectionInfoMarshaller() ; - virtual ~ConnectionInfoMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ConnectionInfoMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ConnectionInfoMarshaller_hpp_ +#define ConnectionInfoMarshaller_hpp_ + +#include + +#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 ConnectionInfoMarshaller : public BaseCommandMarshaller +{ +public: + ConnectionInfoMarshaller() ; + virtual ~ConnectionInfoMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ConnectionInfoMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ConsumerIdMarshaller_hpp_ -#define ConsumerIdMarshaller_hpp_ - -#include - -#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 ConsumerIdMarshaller : public BaseDataStreamMarshaller -{ -public: - ConsumerIdMarshaller() ; - virtual ~ConsumerIdMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ConsumerIdMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ConsumerIdMarshaller_hpp_ +#define ConsumerIdMarshaller_hpp_ + +#include + +#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 ConsumerIdMarshaller : public BaseDataStreamMarshaller +{ +public: + ConsumerIdMarshaller() ; + virtual ~ConsumerIdMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ConsumerIdMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp Sun Mar 5 00:49:13 2006 @@ -60,6 +60,7 @@ info.setBrowser(bs.readBoolean()); info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); info.setPrefetchSize(dataIn.readInt()); + info.setMaximumPendingMessageLimit(dataIn.readInt()); info.setDispatchAsync(bs.readBoolean()); info.setSelector(tightUnmarshalString(dataIn, bs)); info.setSubcriptionName(tightUnmarshalString(dataIn, bs)); @@ -94,7 +95,7 @@ rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs); bs.writeBoolean(info.isBrowser()); rc += marshal1CachedObject(wireFormat, info.getDestination(), bs); - bs.writeBoolean(info.isDispatchAsync()); + bs.writeBoolean(info.isDispatchAsync()); rc += writeString(info.getSelector(), bs); rc += writeString(info.getSubcriptionName(), bs); bs.writeBoolean(info.isNoLocal()); @@ -103,7 +104,7 @@ rc += marshalObjectArray(wireFormat, info.getBrokerPath(), bs); bs.writeBoolean(info.isNetworkSubscription()); - return rc + 2; + return rc + 3; } /* @@ -117,6 +118,7 @@ bs.readBoolean(); marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs); DataStreamMarshaller.writeInt(info.getPrefetchSize(), dataOut); + DataStreamMarshaller.writeInt(info.getMaximumPendingMessageLimit(), dataOut); bs.readBoolean(); writeString(info.getSelector(), dataOut, bs); writeString(info.getSubcriptionName(), dataOut, bs); Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +1,71 @@ -/* -* Copyright 2006 The Apache Software Foundation or its licensors, as -* applicable. -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -#ifndef ConsumerInfoMarshaller_hpp_ -#define ConsumerInfoMarshaller_hpp_ - -#include - -#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 ConsumerInfoMarshaller : public BaseCommandMarshaller -{ -public: - ConsumerInfoMarshaller() ; - virtual ~ConsumerInfoMarshaller() ; - - virtual DataStructure* createCommand() ; - virtual byte getDataStructureType() ; - - virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; - virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; - virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; -} ; - -/* namespace */ - } - } - } -} -#endif /*ConsumerInfoMarshaller_hpp_*/ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +#ifndef ConsumerInfoMarshaller_hpp_ +#define ConsumerInfoMarshaller_hpp_ + +#include + +#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 ConsumerInfoMarshaller : public BaseCommandMarshaller +{ +public: + ConsumerInfoMarshaller() ; + virtual ~ConsumerInfoMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ConsumerInfoMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +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 ControlCommandMarshaller_hpp_ -#define ControlCommandMarshaller_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 ControlCommandMarshaller : public BaseCommandMarshaller -{ -public: - ControlCommandMarshaller() ; - virtual ~ControlCommandMarshaller() ; - - 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 /*ControlCommandMarshaller_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 ControlCommandMarshaller_hpp_ +#define ControlCommandMarshaller_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 ControlCommandMarshaller : public BaseCommandMarshaller +{ +public: + ControlCommandMarshaller() ; + virtual ~ControlCommandMarshaller() ; + + 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 /*ControlCommandMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +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 DataArrayResponseMarshaller_hpp_ -#define DataArrayResponseMarshaller_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/ResponseMarshaller.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 DataArrayResponseMarshaller : public ResponseMarshaller -{ -public: - DataArrayResponseMarshaller() ; - virtual ~DataArrayResponseMarshaller() ; - - 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 /*DataArrayResponseMarshaller_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 DataArrayResponseMarshaller_hpp_ +#define DataArrayResponseMarshaller_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/ResponseMarshaller.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 DataArrayResponseMarshaller : public ResponseMarshaller +{ +public: + DataArrayResponseMarshaller() ; + virtual ~DataArrayResponseMarshaller() ; + + 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 /*DataArrayResponseMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +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 DataResponseMarshaller_hpp_ -#define DataResponseMarshaller_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/ResponseMarshaller.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 DataResponseMarshaller : public ResponseMarshaller -{ -public: - DataResponseMarshaller() ; - virtual ~DataResponseMarshaller() ; - - 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 /*DataResponseMarshaller_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 DataResponseMarshaller_hpp_ +#define DataResponseMarshaller_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/ResponseMarshaller.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 DataResponseMarshaller : public ResponseMarshaller +{ +public: + DataResponseMarshaller() ; + virtual ~DataResponseMarshaller() ; + + 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 /*DataResponseMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +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 DestinationInfoMarshaller_hpp_ -#define DestinationInfoMarshaller_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 DestinationInfoMarshaller : public BaseCommandMarshaller -{ -public: - DestinationInfoMarshaller() ; - virtual ~DestinationInfoMarshaller() ; - - 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 /*DestinationInfoMarshaller_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 DestinationInfoMarshaller_hpp_ +#define DestinationInfoMarshaller_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 DestinationInfoMarshaller : public BaseCommandMarshaller +{ +public: + DestinationInfoMarshaller() ; + virtual ~DestinationInfoMarshaller() ; + + 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 /*DestinationInfoMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +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 DiscoveryEventMarshaller_hpp_ -#define DiscoveryEventMarshaller_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 DiscoveryEventMarshaller : public BaseDataStreamMarshaller -{ -public: - DiscoveryEventMarshaller() ; - virtual ~DiscoveryEventMarshaller() ; - - 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 /*DiscoveryEventMarshaller_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 DiscoveryEventMarshaller_hpp_ +#define DiscoveryEventMarshaller_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 DiscoveryEventMarshaller : public BaseDataStreamMarshaller +{ +public: + DiscoveryEventMarshaller() ; + virtual ~DiscoveryEventMarshaller() ; + + 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 /*DiscoveryEventMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +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 ExceptionResponseMarshaller_hpp_ -#define ExceptionResponseMarshaller_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/ResponseMarshaller.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 ExceptionResponseMarshaller : public ResponseMarshaller -{ -public: - ExceptionResponseMarshaller() ; - virtual ~ExceptionResponseMarshaller() ; - - 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 /*ExceptionResponseMarshaller_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 ExceptionResponseMarshaller_hpp_ +#define ExceptionResponseMarshaller_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/ResponseMarshaller.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 ExceptionResponseMarshaller : public ResponseMarshaller +{ +public: + ExceptionResponseMarshaller() ; + virtual ~ExceptionResponseMarshaller() ; + + 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 /*ExceptionResponseMarshaller_hpp_*/ Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp?rev=383296&r1=383295&r2=383296&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp (original) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp Sun Mar 5 00:49:13 2006 @@ -1,71 +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 FlushCommandMarshaller_hpp_ -#define FlushCommandMarshaller_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 FlushCommandMarshaller : public BaseCommandMarshaller -{ -public: - FlushCommandMarshaller() ; - virtual ~FlushCommandMarshaller() ; - - 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 /*FlushCommandMarshaller_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 FlushCommandMarshaller_hpp_ +#define FlushCommandMarshaller_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 FlushCommandMarshaller : public BaseCommandMarshaller +{ +public: + FlushCommandMarshaller() ; + virtual ~FlushCommandMarshaller() ; + + 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 /*FlushCommandMarshaller_hpp_*/