activemq-commits mailing list archives

Site index · List index

Message view	« Date » · « Thread »
Top	« Date » · « Thread »
From	jstrac...@apache.org
Subject	svn commit: r430504 [11/13] - in /incubator/activemq/trunk: activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ openwire-c/src/libopenwire/ openwire-cpp/src/main/cpp/activemq/command/ openwire-cpp/sr...
Date	Thu, 10 Aug 2006 19:52:05 GMT
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You 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 JournalTopicAckMarshaller_hpp_ #define JournalTopicAckMarshaller_hpp_ #include <string> #include "command/IDataStructure.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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class JournalTopicAckMarshaller : public BaseDataStreamMarshaller { public: JournalTopicAckMarshaller() ; virtual ~JournalTopicAckMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryRe ader& dataIn, BooleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /JournalTopicAckMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,85 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/JournalTraceMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for JournalTrace + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +JournalTraceMarshaller::JournalTraceMarshaller() +{ + // no-op +} + +JournalTraceMarshaller::~JournalTraceMarshaller() +{ + // no-op +} + + + +IDataStructure JournalTraceMarshaller::createObject() +{ + return new JournalTrace(); +} + +char JournalTraceMarshaller::getDataStructureType() +{ + return JournalTrace.ID_JournalTrace; +} + + /* + * Un-marshal an object instance from the data input stream + / +void JournalTraceMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + JournalTrace& info = (JournalTrace&) o; + info.setMessage(tightUnmarshalString(dataIn, bs)); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int JournalTraceMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + JournalTrace& info = (JournalTrace&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += writeString(info.getMessage(), bs); + + return rc + 0; +} + +/ + * Write a object instance to data output stream + / +void JournalTraceMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + JournalTrace& info = (JournalTrace&) o; + writeString(info.getMessage(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You 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 JournalTraceMarshaller_hpp_ #define JournalTraceMarshaller_hpp_ #include <string> #include "command/IDataStructure.hpp" / we could cut this down - for now include all possible headers / #i nclude "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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class JournalTraceMarshaller : public BaseDataStreamMarshaller { public: JournalTraceMarshaller() ; virtual ~JournalTraceMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, B ooleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /JournalTraceMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,90 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/JournalTransactionMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for JournalTransaction + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +JournalTransactionMarshaller::JournalTransactionMarshaller() +{ + // no-op +} + +JournalTransactionMarshaller::~JournalTransactionMarshaller() +{ + // no-op +} + + + +IDataStructure JournalTransactionMarshaller::createObject() +{ + return new JournalTransaction(); +} + +char JournalTransactionMarshaller::getDataStructureType() +{ + return JournalTransaction.ID_JournalTransaction; +} + + /* + * Un-marshal an object instance from the data input stream + / +void JournalTransactionMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + JournalTransaction& info = (JournalTransaction&) o; + info.setTransactionId((org.apache.activemq.command.TransactionId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setType(dataIn.readByte()); + info.setWasPrepared(bs.readBoolean()); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int JournalTransactionMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + JournalTransaction& info = (JournalTransaction&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1NestedObject(wireFormat, info.getTransactionId(), bs); + bs.writeBoolean(info.getWasPrepared()); + + return rc + 1; +} + +/ + * Write a object instance to data output stream + / +void JournalTransactionMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + JournalTransaction& info = (JournalTransaction&) o; + marshal2NestedObject(wireFormat, info.getTransactionId(), dataOut, bs); + DataStreamMarshaller.writeByte(info.getType(), dataOut); + bs.readBoolean(); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / #ifndef JournalTransactionMarshaller_hpp_ #define JournalTransactionMarshaller_hpp_ #include <string> #include "command/IDataStructure.hpp" / we could cut this down - for now include all possible h eaders / #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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class JournalTransactionMarshaller : public BaseDataStreamMarshaller { public: JournalTransactionMarshaller() ; virtual ~JournalTransactionMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Obj ect o, BinaryReader& dataIn, BooleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /JournalTransactionMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,78 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/KeepAliveInfoMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for KeepAliveInfo + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +KeepAliveInfoMarshaller::KeepAliveInfoMarshaller() +{ + // no-op +} + +KeepAliveInfoMarshaller::~KeepAliveInfoMarshaller() +{ + // no-op +} + + + +IDataStructure KeepAliveInfoMarshaller::createObject() +{ + return new KeepAliveInfo(); +} + +char KeepAliveInfoMarshaller::getDataStructureType() +{ + return KeepAliveInfo.ID_KeepAliveInfo; +} + + /* + * Un-marshal an object instance from the data input stream + / +void KeepAliveInfoMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int KeepAliveInfoMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + KeepAliveInfo& info = (KeepAliveInfo&) o; + + int rc = base.marshal1(wireFormat, info, bs); + + return rc + 0; +} + +/ + * Write a object instance to data output stream + / +void KeepAliveInfoMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / #ifndef KeepAliveInfoMarshaller_hpp_ #define KeepAliveInfoMarshaller_hpp_ #include <string> #include "command/IDataStructure.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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class KeepAliveInfoMarshaller : public BaseCommandMarshaller { public: KeepAliveInfoMarshaller() ; virtual ~KeepAliveInfoMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, Bo oleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /KeepAliveInfoMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,78 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/LastPartialCommandMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for LastPartialCommand + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +LastPartialCommandMarshaller::LastPartialCommandMarshaller() +{ + // no-op +} + +LastPartialCommandMarshaller::~LastPartialCommandMarshaller() +{ + // no-op +} + + + +IDataStructure LastPartialCommandMarshaller::createObject() +{ + return new LastPartialCommand(); +} + +char LastPartialCommandMarshaller::getDataStructureType() +{ + return LastPartialCommand.ID_LastPartialCommand; +} + + /* + * Un-marshal an object instance from the data input stream + / +void LastPartialCommandMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int LastPartialCommandMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + LastPartialCommand& info = (LastPartialCommand&) o; + + int rc = base.marshal1(wireFormat, info, bs); + + return rc + 0; +} + +/ + * Write a object instance to data output stream + / +void LastPartialCommandMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You 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 LastPartialCommandMarshaller_hpp_ #define LastPartialCommandMarshaller_hpp_ #include <string> #include "command/IDataStructure.hpp" / we could cut this down - for now include all possible h eaders / #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/PartialCommandMarshaller.hpp" #include "util/ifr/p.hpp" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class LastPartialCommandMarshaller : public PartialCommandMarshaller { public: LastPartialCommandMarshaller() ; virtual ~LastPartialCommandMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Obj ect o, BinaryReader& dataIn, BooleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /LastPartialCommandMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,88 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/LocalTransactionIdMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for LocalTransactionId + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +LocalTransactionIdMarshaller::LocalTransactionIdMarshaller() +{ + // no-op +} + +LocalTransactionIdMarshaller::~LocalTransactionIdMarshaller() +{ + // no-op +} + + + +IDataStructure LocalTransactionIdMarshaller::createObject() +{ + return new LocalTransactionId(); +} + +char LocalTransactionIdMarshaller::getDataStructureType() +{ + return LocalTransactionId.ID_LocalTransactionId; +} + + /* + * Un-marshal an object instance from the data input stream + / +void LocalTransactionIdMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + LocalTransactionId& info = (LocalTransactionId&) o; + info.setValue(tightUnmarshalLong(wireFormat, dataIn, bs)); + info.setConnectionId((org.apache.activemq.command.ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int LocalTransactionIdMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + LocalTransactionId& info = (LocalTransactionId&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1Long(wireFormat, info.getValue(), bs); + rc += marshal1CachedObject(wireFormat, info.getConnectionId(), bs); + + return rc + 0; +} + +/ + * Write a object instance to data output stream + / +void LocalTransactionIdMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + LocalTransactionId& info = (LocalTransactionId&) o; + marshal2Long(wireFormat, info.getValue(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getConnectionId(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / #ifndef LocalTransactionIdMarshaller_hpp_ #define LocalTransactionIdMarshaller_hpp_ #include <string> #include "command/IDataStructure.hpp" / we could cut this down - for now include all possible h eaders / #include "command/BrokerId.hpp" #include "command/ConnectionId.hpp" #include "command/ConsumerId.hpp" #include "command/ProducerId.hpp" #include "command/SessionId.hpp" #include "io/BinaryReader.hpp" #include "io/BinaryWriter.hpp" #include "command/TransactionIdMarshaller.hpp" #include "util/ifr/p.hpp" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class LocalTransactionIdMarshaller : public TransactionIdMarshaller { public: LocalTransactionIdMarshaller() ; virtual ~LocalTransactionIdMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Objec t o, BinaryReader& dataIn, BooleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /LocalTransactionIdMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,144 @@ +/ +* Licensed to the Apache Software Foundation (ASF) under one or more +* contributor license agreements. See the NOTICE file distributed with +* this work for additional information regarding copyright ownership. +* The ASF licenses this file to You under the Apache License, Version 2.0 +* (the "License"); you may not use this file except in compliance with +* the License. You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +/ + +// Marshalling code for Open Wire Format +// +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Groovy scripts in the +// activemq-openwire module +// + +#include "marshal/ExceptionResponseMarshaller.hpp" + +#include "marshal/LocalTransactionIdMarshaller.hpp" +#include "marshal/PartialCommandMarshaller.hpp" +#include "marshal/IntegerResponseMarshaller.hpp" +#include "marshal/ActiveMQQueueMarshaller.hpp" +#include "marshal/ActiveMQObjectMessageMarshaller.hpp" +#include "marshal/ConnectionIdMarshaller.hpp" +#include "marshal/ConnectionInfoMarshaller.hpp" +#include "marshal/ProducerInfoMarshaller.hpp" +#include "marshal/MessageDispatchNotificationMarshaller.hpp" +#include "marshal/SessionInfoMarshaller.hpp" +#include "marshal/TransactionInfoMarshaller.hpp" +#include "marshal/ActiveMQStreamMessageMarshaller.hpp" +#include "marshal/MessageAckMarshaller.hpp" +#include "marshal/ProducerIdMarshaller.hpp" +#include "marshal/MessageIdMarshaller.hpp" +#include "marshal/ActiveMQTempQueueMarshaller.hpp" +#include "marshal/RemoveSubscriptionInfoMarshaller.hpp" +#include "marshal/SessionIdMarshaller.hpp" +#include "marshal/DataArrayResponseMarshaller.hpp" +#include "marshal/JournalQueueAckMarshaller.hpp" +#include "marshal/ResponseMarshaller.hpp" +#include "marshal/ConnectionErrorMarshaller.hpp" +#include "marshal/ConsumerInfoMarshaller.hpp" +#include "marshal/XATransactionIdMarshaller.hpp" +#include "marshal/JournalTraceMarshaller.hpp" +#include "marshal/ConsumerIdMarshaller.hpp" +#include "marshal/ActiveMQTextMessageMarshaller.hpp" +#include "marshal/SubscriptionInfoMarshaller.hpp" +#include "marshal/JournalTransactionMarshaller.hpp" +#include "marshal/ControlCommandMarshaller.hpp" +#include "marshal/LastPartialCommandMarshaller.hpp" +#include "marshal/NetworkBridgeFilterMarshaller.hpp" +#include "marshal/MessagePullMarshaller.hpp" +#include "marshal/ActiveMQBytesMessageMarshaller.hpp" +#include "marshal/WireFormatInfoMarshaller.hpp" +#include "marshal/ActiveMQTempTopicMarshaller.hpp" +#include "marshal/DiscoveryEventMarshaller.hpp" +#include "marshal/ReplayCommandMarshaller.hpp" +#include "marshal/ActiveMQTopicMarshaller.hpp" +#include "marshal/BrokerInfoMarshaller.hpp" +#include "marshal/DestinationInfoMarshaller.hpp" +#include "marshal/ShutdownInfoMarshaller.hpp" +#include "marshal/DataResponseMarshaller.hpp" +#include "marshal/ConnectionControlMarshaller.hpp" +#include "marshal/KeepAliveInfoMarshaller.hpp" +#include "marshal/FlushCommandMarshaller.hpp" +#include "marshal/ConsumerControlMarshaller.hpp" +#include "marshal/JournalTopicAckMarshaller.hpp" +#include "marshal/BrokerIdMarshaller.hpp" +#include "marshal/MessageDispatchMarshaller.hpp" +#include "marshal/ActiveMQMapMessageMarshaller.hpp" +#include "marshal/ActiveMQMessageMarshaller.hpp" +#include "marshal/RemoveInfoMarshaller.hpp" +#include "marshal/ExceptionResponseMarshaller.hpp" + + +using namespace apache::activemq::client::marshal; + + +void MarshallerFactory::configure(ProtocolFormat& format) +{ + + format.addMarshaller(new LocalTransactionIdMarshaller()); + format.addMarshaller(new PartialCommandMarshaller()); + format.addMarshaller(new IntegerResponseMarshaller()); + format.addMarshaller(new ActiveMQQueueMarshaller()); + format.addMarshaller(new ActiveMQObjectMessageMarshaller()); + format.addMarshaller(new ConnectionIdMarshaller()); + format.addMarshaller(new ConnectionInfoMarshaller()); + format.addMarshaller(new ProducerInfoMarshaller()); + format.addMarshaller(new MessageDispatchNotificationMarshaller()); + format.addMarshaller(new SessionInfoMarshaller()); + format.addMarshaller(new TransactionInfoMarshaller()); + format.addMarshaller(new ActiveMQStreamMessageMarshaller()); + format.addMarshaller(new MessageAckMarshaller()); + format.addMarshaller(new ProducerIdMarshaller()); + format.addMarshaller(new MessageIdMarshaller()); + format.addMarshaller(new ActiveMQTempQueueMarshaller()); + format.addMarshaller(new RemoveSubscriptionInfoMarshaller()); + format.addMarshaller(new SessionIdMarshaller()); + format.addMarshaller(new DataArrayResponseMarshaller()); + format.addMarshaller(new JournalQueueAckMarshaller()); + format.addMarshaller(new ResponseMarshaller()); + format.addMarshaller(new ConnectionErrorMarshaller()); + format.addMarshaller(new ConsumerInfoMarshaller()); + format.addMarshaller(new XATransactionIdMarshaller()); + format.addMarshaller(new JournalTraceMarshaller()); + format.addMarshaller(new ConsumerIdMarshaller()); + format.addMarshaller(new ActiveMQTextMessageMarshaller()); + format.addMarshaller(new SubscriptionInfoMarshaller()); + format.addMarshaller(new JournalTransactionMarshaller()); + format.addMarshaller(new ControlCommandMarshaller()); + format.addMarshaller(new LastPartialCommandMarshaller()); + format.addMarshaller(new NetworkBridgeFilterMarshaller()); + format.addMarshaller(new MessagePullMarshaller()); + format.addMarshaller(new ActiveMQBytesMessageMarshaller()); + format.addMarshaller(new WireFormatInfoMarshaller()); + format.addMarshaller(new ActiveMQTempTopicMarshaller()); + format.addMarshaller(new DiscoveryEventMarshaller()); + format.addMarshaller(new ReplayCommandMarshaller()); + format.addMarshaller(new ActiveMQTopicMarshaller()); + format.addMarshaller(new BrokerInfoMarshaller()); + format.addMarshaller(new DestinationInfoMarshaller()); + format.addMarshaller(new ShutdownInfoMarshaller()); + format.addMarshaller(new DataResponseMarshaller()); + format.addMarshaller(new ConnectionControlMarshaller()); + format.addMarshaller(new KeepAliveInfoMarshaller()); + format.addMarshaller(new FlushCommandMarshaller()); + format.addMarshaller(new ConsumerControlMarshaller()); + format.addMarshaller(new JournalTopicAckMarshaller()); + format.addMarshaller(new BrokerIdMarshaller()); + format.addMarshaller(new MessageDispatchMarshaller()); + format.addMarshaller(new ActiveMQMapMessageMarshaller()); + format.addMarshaller(new ActiveMQMessageMarshaller()); + format.addMarshaller(new RemoveInfoMarshaller()); + format.addMarshaller(new ExceptionResponseMarshaller()); +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,62 @@ +// +* Licensed to the Apache Software Foundation (ASF) under one or more +* contributor license agreements. See the NOTICE file distributed with +* this work for additional information regarding copyright ownership. +* The ASF licenses this file to You under the Apache License, Version 2.0 +* (the "License"); you may not use this file except in compliance with +* the License. You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +/ + +// Marshalling code for Open Wire Format +// +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Groovy scripts in the +// activemq-openwire module +// + +#ifndef MarshallerFactory_hpp_ +#define MarshallerFactory_hpp_ + + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace std ; + using namespace apache::activemq::client; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/ + * + / +class MarshallerFactory +{ +public: + MarshallerFactory() ; + virtual ~MarshallerFactory() ; + + virtual void configure(ProtocolFormat& format) ; +} ; + +/ namespace / + } + } + } +} + +#endif /MarshallerFactory_hpp_/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,101 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/MessageAckMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for MessageAck + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +MessageAckMarshaller::MessageAckMarshaller() +{ + // no-op +} + +MessageAckMarshaller::~MessageAckMarshaller() +{ + // no-op +} + + + +IDataStructure MessageAckMarshaller::createObject() +{ + return new MessageAck(); +} + +char MessageAckMarshaller::getDataStructureType() +{ + return MessageAck.ID_MessageAck; +} + + /* + * Un-marshal an object instance from the data input stream + / +void MessageAckMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + MessageAck& info = (MessageAck&) o; + info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setTransactionId((org.apache.activemq.command.TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setAckType(dataIn.readByte()); + info.setFirstMessageId((org.apache.activemq.command.MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setLastMessageId((org.apache.activemq.command.MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setMessageCount(dataIn.readInt()); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int MessageAckMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + MessageAck& info = (MessageAck&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1CachedObject(wireFormat, info.getDestination(), bs); + rc += marshal1CachedObject(wireFormat, info.getTransactionId(), bs); + rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs); + rc += marshal1NestedObject(wireFormat, info.getFirstMessageId(), bs); + rc += marshal1NestedObject(wireFormat, info.getLastMessageId(), bs); + + return rc + 2; +} + +/ + * Write a object instance to data output stream + / +void MessageAckMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + MessageAck& info = (MessageAck&) o; + marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getTransactionId(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs); + DataStreamMarshaller.writeByte(info.getAckType(), dataOut); + marshal2NestedObject(wireFormat, info.getFirstMessageId(), dataOut, bs); + marshal2NestedObject(wireFormat, info.getLastMessageId(), dataOut, bs); + DataStreamMarshaller.writeInt(info.getMessageCount(), dataOut); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / #ifndef MessageAckMarshaller_hpp_ #define MessageAckMarshaller_hpp_ #include <string> #include "command/IDataStructure.hpp" / we could cut this down - for now include all possible headers / #inclu de "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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class MessageAckMarshaller : public BaseCommandMarshaller { public: MessageAckMarshaller() ; virtual ~MessageAckMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs ) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /MessageAckMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,93 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/MessageDispatchMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for MessageDispatch + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +MessageDispatchMarshaller::MessageDispatchMarshaller() +{ + // no-op +} + +MessageDispatchMarshaller::~MessageDispatchMarshaller() +{ + // no-op +} + + + +IDataStructure MessageDispatchMarshaller::createObject() +{ + return new MessageDispatch(); +} + +char MessageDispatchMarshaller::getDataStructureType() +{ + return MessageDispatch.ID_MessageDispatch; +} + + /* + * Un-marshal an object instance from the data input stream + / +void MessageDispatchMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + MessageDispatch& info = (MessageDispatch&) o; + info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setMessage((org.apache.activemq.command.Message) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setRedeliveryCounter(dataIn.readInt()); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int MessageDispatchMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + MessageDispatch& info = (MessageDispatch&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs); + rc += marshal1CachedObject(wireFormat, info.getDestination(), bs); + rc += marshal1NestedObject(wireFormat, info.getMessage(), bs); + + return rc + 1; +} + +/ + * Write a object instance to data output stream + / +void MessageDispatchMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + MessageDispatch& info = (MessageDispatch&) o; + marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs); + marshal2NestedObject(wireFormat, info.getMessage(), dataOut, bs); + DataStreamMarshaller.writeInt(info.getRedeliveryCounter(), dataOut); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / #ifndef MessageDispatchMarshaller_hpp_ #define MessageDispatchMarshaller_hpp_ #include <string> #include "command/IDataStructure.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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class MessageDispatchMarshaller : public BaseCommandMarshaller { public: MessageDispatchMarshaller() ; virtual ~MessageDispatchMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /MessageDispatchMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,94 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/MessageDispatchNotificationMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for MessageDispatchNotification + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +MessageDispatchNotificationMarshaller::MessageDispatchNotificationMarshaller() +{ + // no-op +} + +MessageDispatchNotificationMarshaller::~MessageDispatchNotificationMarshaller() +{ + // no-op +} + + + +IDataStructure MessageDispatchNotificationMarshaller::createObject() +{ + return new MessageDispatchNotification(); +} + +char MessageDispatchNotificationMarshaller::getDataStructureType() +{ + return MessageDispatchNotification.ID_MessageDispatchNotification; +} + + /* + * Un-marshal an object instance from the data input stream + / +void MessageDispatchNotificationMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + MessageDispatchNotification& info = (MessageDispatchNotification&) o; + info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setDeliverySequenceId(tightUnmarshalLong(wireFormat, dataIn, bs)); + info.setMessageId((org.apache.activemq.command.MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int MessageDispatchNotificationMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + MessageDispatchNotification& info = (MessageDispatchNotification&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs); + rc += marshal1CachedObject(wireFormat, info.getDestination(), bs); + rc += marshal1Long(wireFormat, info.getDeliverySequenceId(), bs); + rc += marshal1NestedObject(wireFormat, info.getMessageId(), bs); + + return rc + 0; +} + +/ + * Write a object instance to data output stream + / +void MessageDispatchNotificationMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + MessageDispatchNotification& info = (MessageDispatchNotification&) o; + marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs); + marshal2Long(wireFormat, info.getDeliverySequenceId(), dataOut, bs); + marshal2NestedObject(wireFormat, info.getMessageId(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / #ifndef MessageDispatchNotificationMarshaller_hpp_ #define MessageDispatchNotificationMarshaller_hpp_ #include <string> #include "command/IDataStructure.hpp" / we could cut this down - for now incl ude 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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class MessageDispatchNotificationMarshaller : public BaseCommandMarshaller { public: MessageDispatchNotificationMarshaller() ; virtual ~MessageDispatchNotificationMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void un marshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /MessageDispatchNotificationMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,91 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/MessageIdMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for MessageId + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +MessageIdMarshaller::MessageIdMarshaller() +{ + // no-op +} + +MessageIdMarshaller::~MessageIdMarshaller() +{ + // no-op +} + + + +IDataStructure MessageIdMarshaller::createObject() +{ + return new MessageId(); +} + +char MessageIdMarshaller::getDataStructureType() +{ + return MessageId.ID_MessageId; +} + + /* + * Un-marshal an object instance from the data input stream + / +void MessageIdMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + MessageId& info = (MessageId&) o; + info.setProducerId((org.apache.activemq.command.ProducerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setProducerSequenceId(tightUnmarshalLong(wireFormat, dataIn, bs)); + info.setBrokerSequenceId(tightUnmarshalLong(wireFormat, dataIn, bs)); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int MessageIdMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + MessageId& info = (MessageId&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1CachedObject(wireFormat, info.getProducerId(), bs); + rc += marshal1Long(wireFormat, info.getProducerSequenceId(), bs); + rc += marshal1Long(wireFormat, info.getBrokerSequenceId(), bs); + + return rc + 0; +} + +/ + * Write a object instance to data output stream + / +void MessageIdMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + MessageId& info = (MessageId&) o; + marshal2CachedObject(wireFormat, info.getProducerId(), dataOut, bs); + marshal2Long(wireFormat, info.getProducerSequenceId(), dataOut, bs); + marshal2Long(wireFormat, info.getBrokerSequenceId(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / #ifndef MessageIdMarshaller_hpp_ #define MessageIdMarshaller_hpp_ #include <string> #include "command/IDataStructure.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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class MessageIdMarshaller : public BaseDataStreamMarshaller { public: MessageIdMarshaller() ; virtual ~MessageIdMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& b s) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /MessageIdMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,162 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/MessageMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for Message + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +MessageMarshaller::MessageMarshaller() +{ + // no-op +} + +MessageMarshaller::~MessageMarshaller() +{ + // no-op +} + + + / + * Un-marshal an object instance from the data input stream + / +void MessageMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + Message& info = (Message&) o; + info.setProducerId((org.apache.activemq.command.ProducerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setTransactionId((org.apache.activemq.command.TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setOriginalDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setMessageId((org.apache.activemq.command.MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setOriginalTransactionId((org.apache.activemq.command.TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setGroupID(tightUnmarshalString(dataIn, bs)); + info.setGroupSequence(dataIn.readInt()); + info.setCorrelationId(tightUnmarshalString(dataIn, bs)); + info.setPersistent(bs.readBoolean()); + info.setExpiration(tightUnmarshalLong(wireFormat, dataIn, bs)); + info.setPriority(dataIn.readByte()); + info.setReplyTo((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setTimestamp(tightUnmarshalLong(wireFormat, dataIn, bs)); + info.setType(tightUnmarshalString(dataIn, bs)); + info.setContent(tightUnmarshalByteSequence(dataIn, bs)); + info.setMarshalledProperties(tightUnmarshalByteSequence(dataIn, bs)); + info.setDataStructure((org.apache.activemq.command.DataStructure) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setTargetConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setCompressed(bs.readBoolean()); + info.setRedeliveryCounter(dataIn.readInt()); + + if (bs.readBoolean()) { + short size = dataIn.readShort(); + org.apache.activemq.command.BrokerId value[] = new org.apache.activemq.command.BrokerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (org.apache.activemq.command.BrokerId) tightUnmarsalNestedObject(wireFormat,dataIn, bs); + } + info.setBrokerPath(value); + } + else { + info.setBrokerPath(null); + } + info.setArrival(tightUnmarshalLong(wireFormat, dataIn, bs)); + info.setUserID(tightUnmarshalString(dataIn, bs)); + info.setRecievedByDFBridge(bs.readBoolean()); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int MessageMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + Message& info = (Message&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1CachedObject(wireFormat, info.getProducerId(), bs); + rc += marshal1CachedObject(wireFormat, info.getDestination(), bs); + rc += marshal1CachedObject(wireFormat, info.getTransactionId(), bs); + rc += marshal1CachedObject(wireFormat, info.getOriginalDestination(), bs); + rc += marshal1NestedObject(wireFormat, info.getMessageId(), bs); + rc += marshal1CachedObject(wireFormat, info.getOriginalTransactionId(), bs); + rc += writeString(info.getGroupID(), bs); + rc += writeString(info.getCorrelationId(), bs); + bs.writeBoolean(info.isPersistent()); + rc += marshal1Long(wireFormat, info.getExpiration(), bs); + rc += marshal1NestedObject(wireFormat, info.getReplyTo(), bs); + rc += marshal1Long(wireFormat, info.getTimestamp(), bs); + rc += writeString(info.getType(), bs); + bs.writeBoolean(info.getContent()!=null); + rc += info.getContent()==null ? 0 : info.getContent().Length+4; + bs.writeBoolean(info.getMarshalledProperties()!=null); + rc += info.getMarshalledProperties()==null ? 0 : info.getMarshalledProperties().Length+4; + rc += marshal1NestedObject(wireFormat, info.getDataStructure(), bs); + rc += marshal1CachedObject(wireFormat, info.getTargetConsumerId(), bs); + bs.writeBoolean(info.isCompressed()); + rc += marshalObjectArray(wireFormat, info.getBrokerPath(), bs); + rc += marshal1Long(wireFormat, info.getArrival(), bs); + rc += writeString(info.getUserID(), bs); + bs.writeBoolean(info.isRecievedByDFBridge()); + + return rc + 3; +} + +/ + * Write a object instance to data output stream + / +void MessageMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + Message& info = (Message&) o; + marshal2CachedObject(wireFormat, info.getProducerId(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getTransactionId(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getOriginalDestination(), dataOut, bs); + marshal2NestedObject(wireFormat, info.getMessageId(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getOriginalTransactionId(), dataOut, bs); + writeString(info.getGroupID(), dataOut, bs); + DataStreamMarshaller.writeInt(info.getGroupSequence(), dataOut); + writeString(info.getCorrelationId(), dataOut, bs); + bs.readBoolean(); + marshal2Long(wireFormat, info.getExpiration(), dataOut, bs); + DataStreamMarshaller.writeByte(info.getPriority(), dataOut); + marshal2NestedObject(wireFormat, info.getReplyTo(), dataOut, bs); + marshal2Long(wireFormat, info.getTimestamp(), dataOut, bs); + writeString(info.getType(), dataOut, bs); + if(bs.readBoolean()) { + DataStreamMarshaller.writeInt(info.getContent().Length, dataOut); + dataOut.write(info.getContent()); + } + if(bs.readBoolean()) { + DataStreamMarshaller.writeInt(info.getMarshalledProperties().Length, dataOut); + dataOut.write(info.getMarshalledProperties()); + } + marshal2NestedObject(wireFormat, info.getDataStructure(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getTargetConsumerId(), dataOut, bs); + bs.readBoolean(); + DataStreamMarshaller.writeInt(info.getRedeliveryCounter(), dataOut); + marshalObjectArray(wireFormat, info.getBrokerPath(), dataOut, bs); + marshal2Long(wireFormat, info.getArrival(), dataOut, bs); + writeString(info.getUserID(), dataOut, bs); + bs.readBoolean(); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/ * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / #ifndef MessageMarshaller_hpp_ #define MessageMarshaller_hpp_ #include <string> #include "command/IDataStructure.hpp" / we could cut this down - for now include all possible headers / #include "co mmand/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" #include "protocol/ProtocolFormat.hpp" namespace apache { namespace activemq { namespace client { namespace marshal { using namespace ifr ; using namespace apache::activemq::client::command; using namespace apache::activemq::client::io; using namespace apache::activemq::client::protocol; / * / class MessageMarshaller : public BaseCommandMarshaller { public: MessageMarshaller() ; virtual ~MessageMarshaller() ; virtual IDataStructure createCommand() ; virtual char getDataStructureType() ; virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ; virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; } ; /* namespace / } } } } #endif /MessageMarshaller_hpp_/ \ No newline at end of file Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp Thu Aug 10 12:51:56 2006 @@ -0,0 +1,91 @@ +/ + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + / +#include "marshal/MessagePullMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/ + * Marshalling code for Open Wire Format for MessagePull + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + / + +MessagePullMarshaller::MessagePullMarshaller() +{ + // no-op +} + +MessagePullMarshaller::~MessagePullMarshaller() +{ + // no-op +} + + + +IDataStructure MessagePullMarshaller::createObject() +{ + return new MessagePull(); +} + +char MessagePullMarshaller::getDataStructureType() +{ + return MessagePull.ID_MessagePull; +} + + /* + * Un-marshal an object instance from the data input stream + / +void MessagePullMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + MessagePull& info = (MessagePull&) o; + info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setTimeout(tightUnmarshalLong(wireFormat, dataIn, bs)); + +} + + +/ + * Write the booleans that this object uses to a BooleanStream + / +int MessagePullMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) { + MessagePull& info = (MessagePull&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs); + rc += marshal1CachedObject(wireFormat, info.getDestination(), bs); + rc += marshal1Long(wireFormat, info.getTimeout(), bs); + + return rc + 0; +} + +/ + * Write a object instance to data output stream + */ +void MessagePullMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + MessagePull& info = (MessagePull&) o; + marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs); + marshal2Long(wireFormat, info.getTimeout(), dataOut, bs); + +}
Mime	Unnamed text/plain (inline, 7-Bit, 89759 bytes)
	View raw message