activemq-commits mailing list archives

Site index · List index

Message view	« Date » · « Thread »
Top	« Date » · « Thread »
From	chir...@apache.org
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 GMT
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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQDestinationMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQDestinationMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQTempDestinationMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQTempDestinationMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQTempDestinationMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQTempDestinationMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQMessageMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQMessageMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/ActiveMQDestinationMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ActiveMQDestinationMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseDataStreamMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseCommandMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseDataStreamMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseCommandMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseDataStreamMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseCommandMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseCommandMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseCommandMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseDataStreamMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p.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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/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 <string> - -#include "command/DataStructure.hpp" - -/ we could cut this down - for now include all possible headers / -#include "command/BrokerId.hpp" -#include "command/ConnectionId.hpp" -#include "command/ConsumerId.hpp" -#include "command/ProducerId.hpp" -#include "command/SessionId.hpp" - -#include "io/BinaryReader.hpp" -#include "io/BinaryWriter.hpp" - -#include "command/BaseCommandMarshaller.hpp" -#include "util/ifr/p.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 <string> + +#include "command/DataStructure.hpp" + +/ we could cut this down - for now include all possible headers / +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p.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_*/
Mime	Unnamed text/plain (inline, 7-Bit, 87579 bytes)
	View raw message