You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by nm...@apache.org on 2006/05/15 15:39:33 UTC
svn commit: r406628 [5/10] - in /incubator/activemq/trunk/openwire-cpp: ./
src/gram/java/org/apache/activemq/openwire/tool/ src/gram/script/
src/main/cpp/activemq/ src/main/cpp/activemq/command/
src/main/cpp/activemq/protocol/ src/main/cpp/activemq/pro...
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp Mon May 15 06:38:57 2006
@@ -1,99 +1,97 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#include "activemq/command/JournalTransaction.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- * 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
- *
- */
-JournalTransaction::JournalTransaction()
-{
- this->transactionId = NULL ;
- this->type = 0 ;
- this->wasPrepared = false ;
-}
-
-JournalTransaction::~JournalTransaction()
-{
-}
-
-unsigned char JournalTransaction::getDataStructureType()
-{
- return JournalTransaction::TYPE ;
-}
-
-
-p<TransactionId> JournalTransaction::getTransactionId()
-{
- return transactionId ;
-}
-
-void JournalTransaction::setTransactionId(p<TransactionId> transactionId)
-{
- this->transactionId = transactionId ;
-}
-
-
-char JournalTransaction::getType()
-{
- return type ;
-}
-
-void JournalTransaction::setType(char type)
-{
- this->type = type ;
-}
-
-
-bool JournalTransaction::getWasPrepared()
-{
- return wasPrepared ;
-}
-
-void JournalTransaction::setWasPrepared(bool wasPrepared)
-{
- this->wasPrepared = wasPrepared ;
-}
-
-int JournalTransaction::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
-{
- int size = 0 ;
-
- size += marshaller->marshalInt(commandId, mode, writer) ;
- size += marshaller->marshalBoolean(responseRequired, mode, writer) ;
- size += marshaller->marshalObject(transactionId, mode, writer) ;
- size += marshaller->marshalByte(type, mode, writer) ;
- size += marshaller->marshalBoolean(wasPrepared, mode, writer) ;
- return size ;
-}
-
-void JournalTransaction::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
-{
- commandId = marshaller->unmarshalInt(mode, reader) ;
- responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
- transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, reader)) ;
- type = (marshaller->unmarshalByte(mode, reader)) ;
- wasPrepared = (marshaller->unmarshalBoolean(mode, reader)) ;
-}
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/JournalTransaction.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+JournalTransaction::JournalTransaction()
+{
+ this->transactionId = NULL ;
+ this->type = 0 ;
+ this->wasPrepared = false ;
+}
+
+JournalTransaction::~JournalTransaction()
+{
+}
+
+unsigned char JournalTransaction::getDataStructureType()
+{
+ return JournalTransaction::TYPE ;
+}
+
+
+p<TransactionId> JournalTransaction::getTransactionId()
+{
+ return transactionId ;
+}
+
+void JournalTransaction::setTransactionId(p<TransactionId> transactionId)
+{
+ this->transactionId = transactionId ;
+}
+
+
+char JournalTransaction::getType()
+{
+ return type ;
+}
+
+void JournalTransaction::setType(char type)
+{
+ this->type = type ;
+}
+
+
+bool JournalTransaction::getWasPrepared()
+{
+ return wasPrepared ;
+}
+
+void JournalTransaction::setWasPrepared(bool wasPrepared)
+{
+ this->wasPrepared = wasPrepared ;
+}
+
+int JournalTransaction::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+ int size = 0 ;
+
+ size += BaseDataStructure::marshal(marshaller, mode, ostream) ;
+ size += marshaller->marshalObject(transactionId, mode, ostream) ;
+ size += marshaller->marshalByte(type, mode, ostream) ;
+ size += marshaller->marshalBoolean(wasPrepared, mode, ostream) ;
+ return size ;
+}
+
+void JournalTransaction::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+ BaseDataStructure::unmarshal(marshaller, mode, istream) ;
+ transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, istream)) ;
+ type = (marshaller->unmarshalByte(mode, istream)) ;
+ wasPrepared = (marshaller->unmarshalBoolean(mode, istream)) ;
+}
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.hpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.hpp Mon May 15 06:38:57 2006
@@ -1,91 +1,92 @@
-/*
-* 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 ActiveMQ_JournalTransaction_hpp_
-#define ActiveMQ_JournalTransaction_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/AbstractCommand.hpp"
-#include "activemq/command/TransactionId.hpp"
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
- namespace activemq
- {
- namespace command
- {
- using namespace ifr;
- using namespace std;
- using namespace apache::activemq;
- using namespace apache::activemq::protocol;
- using namespace apache::ppr::io;
-
-/*
- *
- * 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
- *
- */
-class JournalTransaction : public AbstractCommand
-{
-protected:
- p<TransactionId> transactionId ;
- char type ;
- bool wasPrepared ;
-
-public:
- const static unsigned char TYPE = 54;
-
-public:
- JournalTransaction() ;
- virtual ~JournalTransaction() ;
-
- virtual unsigned char getDataStructureType() ;
-
- virtual p<TransactionId> getTransactionId() ;
- virtual void setTransactionId(p<TransactionId> transactionId) ;
-
- virtual char getType() ;
- virtual void setType(char type) ;
-
- virtual bool getWasPrepared() ;
- virtual void setWasPrepared(bool wasPrepared) ;
-
- virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException) ;
- virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException) ;
-} ;
-
-/* namespace */
- }
- }
-}
-
-#endif /*ActiveMQ_JournalTransaction_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 ActiveMQ_JournalTransaction_hpp_
+#define ActiveMQ_JournalTransaction_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseDataStructure.hpp"
+#include "activemq/command/TransactionId.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq;
+ using namespace apache::activemq::protocol;
+ using namespace apache::ppr::io;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+class JournalTransaction : public BaseDataStructure
+{
+protected:
+ p<TransactionId> transactionId ;
+ char type ;
+ bool wasPrepared ;
+
+public:
+ const static unsigned char TYPE = 54;
+
+public:
+ JournalTransaction() ;
+ virtual ~JournalTransaction() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<TransactionId> getTransactionId() ;
+ virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+ virtual char getType() ;
+ virtual void setType(char type) ;
+
+ virtual bool getWasPrepared() ;
+ virtual void setWasPrepared(bool wasPrepared) ;
+
+ virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+ virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+ }
+ }
+}
+
+#endif /*ActiveMQ_JournalTransaction_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp Mon May 15 06:38:57 2006
@@ -1,57 +1,55 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#include "activemq/command/KeepAliveInfo.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- * 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
- *
- */
-KeepAliveInfo::KeepAliveInfo()
-{
-}
-
-KeepAliveInfo::~KeepAliveInfo()
-{
-}
-
-unsigned char KeepAliveInfo::getDataStructureType()
-{
- return KeepAliveInfo::TYPE ;
-}
-
-int KeepAliveInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
-{
- int size = 0 ;
-
- size += marshaller->marshalInt(commandId, mode, writer) ;
- size += marshaller->marshalBoolean(responseRequired, mode, writer) ;
- return size ;
-}
-
-void KeepAliveInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
-{
- commandId = marshaller->unmarshalInt(mode, reader) ;
- responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
-}
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/KeepAliveInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+KeepAliveInfo::KeepAliveInfo()
+{
+}
+
+KeepAliveInfo::~KeepAliveInfo()
+{
+}
+
+unsigned char KeepAliveInfo::getDataStructureType()
+{
+ return KeepAliveInfo::TYPE ;
+}
+
+int KeepAliveInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+ int size = 0 ;
+
+ size += BaseCommand::marshal(marshaller, mode, ostream) ;
+ return size ;
+}
+
+void KeepAliveInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+ BaseCommand::unmarshal(marshaller, mode, istream) ;
+}
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.hpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.hpp Mon May 15 06:38:57 2006
@@ -1,78 +1,79 @@
-/*
-* 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 ActiveMQ_KeepAliveInfo_hpp_
-#define ActiveMQ_KeepAliveInfo_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/AbstractCommand.hpp"
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
- namespace activemq
- {
- namespace command
- {
- using namespace ifr;
- using namespace std;
- using namespace apache::activemq;
- using namespace apache::activemq::protocol;
- using namespace apache::ppr::io;
-
-/*
- *
- * 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
- *
- */
-class KeepAliveInfo : public AbstractCommand
-{
-protected:
-
-public:
- const static unsigned char TYPE = 10;
-
-public:
- KeepAliveInfo() ;
- virtual ~KeepAliveInfo() ;
-
- virtual unsigned char getDataStructureType() ;
-
- virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException) ;
- virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException) ;
-} ;
-
-/* namespace */
- }
- }
-}
-
-#endif /*ActiveMQ_KeepAliveInfo_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 ActiveMQ_KeepAliveInfo_hpp_
+#define ActiveMQ_KeepAliveInfo_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq;
+ using namespace apache::activemq::protocol;
+ using namespace apache::ppr::io;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+class KeepAliveInfo : public BaseCommand
+{
+protected:
+
+public:
+ const static unsigned char TYPE = 10;
+
+public:
+ KeepAliveInfo() ;
+ virtual ~KeepAliveInfo() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+ virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+ }
+ }
+}
+
+#endif /*ActiveMQ_KeepAliveInfo_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LastPartialCommand.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LastPartialCommand.cpp?rev=406628&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LastPartialCommand.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LastPartialCommand.cpp Mon May 15 06:38:57 2006
@@ -0,0 +1,55 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/LastPartialCommand.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+LastPartialCommand::LastPartialCommand()
+{
+}
+
+LastPartialCommand::~LastPartialCommand()
+{
+}
+
+unsigned char LastPartialCommand::getDataStructureType()
+{
+ return LastPartialCommand::TYPE ;
+}
+
+int LastPartialCommand::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+ int size = 0 ;
+
+ size += PartialCommand::marshal(marshaller, mode, ostream) ;
+ return size ;
+}
+
+void LastPartialCommand::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+ PartialCommand::unmarshal(marshaller, mode, istream) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LastPartialCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LastPartialCommand.hpp?rev=406628&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LastPartialCommand.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LastPartialCommand.hpp Mon May 15 06:38:57 2006
@@ -0,0 +1,79 @@
+/*
+* 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 ActiveMQ_LastPartialCommand_hpp_
+#define ActiveMQ_LastPartialCommand_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/PartialCommand.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq;
+ using namespace apache::activemq::protocol;
+ using namespace apache::ppr::io;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+class LastPartialCommand : public PartialCommand
+{
+protected:
+
+public:
+ const static unsigned char TYPE = 61;
+
+public:
+ LastPartialCommand() ;
+ virtual ~LastPartialCommand() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+ virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+ }
+ }
+}
+
+#endif /*ActiveMQ_LastPartialCommand_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.cpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.cpp Mon May 15 06:38:57 2006
@@ -1,81 +1,83 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#include "activemq/command/LocalTransactionId.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- * 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
- *
- */
-LocalTransactionId::LocalTransactionId()
-{
- this->value = 0 ;
- this->connectionId = NULL ;
-}
-
-LocalTransactionId::~LocalTransactionId()
-{
-}
-
-unsigned char LocalTransactionId::getDataStructureType()
-{
- return LocalTransactionId::TYPE ;
-}
-
-
-long long LocalTransactionId::getValue()
-{
- return value ;
-}
-
-void LocalTransactionId::setValue(long long value)
-{
- this->value = value ;
-}
-
-
-p<ConnectionId> LocalTransactionId::getConnectionId()
-{
- return connectionId ;
-}
-
-void LocalTransactionId::setConnectionId(p<ConnectionId> connectionId)
-{
- this->connectionId = connectionId ;
-}
-
-int LocalTransactionId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
-{
- int size = 0 ;
-
- size += marshaller->marshalLong(value, mode, writer) ;
- size += marshaller->marshalObject(connectionId, mode, writer) ;
- return size ;
-}
-
-void LocalTransactionId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
-{
- value = (marshaller->unmarshalLong(mode, reader)) ;
- connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, reader)) ;
-}
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/LocalTransactionId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+LocalTransactionId::LocalTransactionId()
+{
+ this->value = 0 ;
+ this->connectionId = NULL ;
+}
+
+LocalTransactionId::~LocalTransactionId()
+{
+}
+
+unsigned char LocalTransactionId::getDataStructureType()
+{
+ return LocalTransactionId::TYPE ;
+}
+
+
+long long LocalTransactionId::getValue()
+{
+ return value ;
+}
+
+void LocalTransactionId::setValue(long long value)
+{
+ this->value = value ;
+}
+
+
+p<ConnectionId> LocalTransactionId::getConnectionId()
+{
+ return connectionId ;
+}
+
+void LocalTransactionId::setConnectionId(p<ConnectionId> connectionId)
+{
+ this->connectionId = connectionId ;
+}
+
+int LocalTransactionId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+ int size = 0 ;
+
+ size += TransactionId::marshal(marshaller, mode, ostream) ;
+ size += marshaller->marshalLong(value, mode, ostream) ;
+ size += marshaller->marshalObject(connectionId, mode, ostream) ;
+ return size ;
+}
+
+void LocalTransactionId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+ TransactionId::unmarshal(marshaller, mode, istream) ;
+ value = (marshaller->unmarshalLong(mode, istream)) ;
+ connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, istream)) ;
+}
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.hpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/LocalTransactionId.hpp Mon May 15 06:38:57 2006
@@ -1,87 +1,88 @@
-/*
-* 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 ActiveMQ_LocalTransactionId_hpp_
-#define ActiveMQ_LocalTransactionId_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/TransactionId.hpp"
-#include "activemq/command/ConnectionId.hpp"
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
- namespace activemq
- {
- namespace command
- {
- using namespace ifr;
- using namespace std;
- using namespace apache::activemq;
- using namespace apache::activemq::protocol;
- using namespace apache::ppr::io;
-
-/*
- *
- * 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
- *
- */
-class LocalTransactionId : public TransactionId
-{
-protected:
- long long value ;
- p<ConnectionId> connectionId ;
-
-public:
- const static unsigned char TYPE = 111;
-
-public:
- LocalTransactionId() ;
- virtual ~LocalTransactionId() ;
-
- virtual unsigned char getDataStructureType() ;
-
- virtual long long getValue() ;
- virtual void setValue(long long value) ;
-
- virtual p<ConnectionId> getConnectionId() ;
- virtual void setConnectionId(p<ConnectionId> connectionId) ;
-
- virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException) ;
- virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException) ;
-} ;
-
-/* namespace */
- }
- }
-}
-
-#endif /*ActiveMQ_LocalTransactionId_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 ActiveMQ_LocalTransactionId_hpp_
+#define ActiveMQ_LocalTransactionId_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/TransactionId.hpp"
+#include "activemq/command/ConnectionId.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq;
+ using namespace apache::activemq::protocol;
+ using namespace apache::ppr::io;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+class LocalTransactionId : public TransactionId
+{
+protected:
+ long long value ;
+ p<ConnectionId> connectionId ;
+
+public:
+ const static unsigned char TYPE = 111;
+
+public:
+ LocalTransactionId() ;
+ virtual ~LocalTransactionId() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual long long getValue() ;
+ virtual void setValue(long long value) ;
+
+ virtual p<ConnectionId> getConnectionId() ;
+ virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+ virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+ virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+ }
+ }
+}
+
+#endif /*ActiveMQ_LocalTransactionId_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.cpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.cpp Mon May 15 06:38:57 2006
@@ -1,407 +1,405 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#include "activemq/command/Message.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- * 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
- *
- */
-Message::Message()
-{
- this->producerId = NULL ;
- this->destination = NULL ;
- this->transactionId = NULL ;
- this->originalDestination = NULL ;
- this->messageId = NULL ;
- this->originalTransactionId = NULL ;
- this->groupID = NULL ;
- this->groupSequence = 0 ;
- this->correlationId = NULL ;
- this->persistent = false ;
- this->expiration = 0 ;
- this->priority = 0 ;
- this->replyTo = NULL ;
- this->timestamp = 0 ;
- this->type = NULL ;
- this->content = NULL ;
- this->marshalledProperties = NULL ;
- this->dataStructure = NULL ;
- this->targetConsumerId = NULL ;
- this->compressed = false ;
- this->redeliveryCounter = 0 ;
- this->brokerPath = NULL ;
- this->arrival = 0 ;
- this->userID = NULL ;
- this->recievedByDFBridge = false ;
-}
-
-Message::~Message()
-{
-}
-
-unsigned char Message::getDataStructureType()
-{
- return Message::TYPE ;
-}
-
-
-p<ProducerId> Message::getProducerId()
-{
- return producerId ;
-}
-
-void Message::setProducerId(p<ProducerId> producerId)
-{
- this->producerId = producerId ;
-}
-
-
-p<ActiveMQDestination> Message::getDestination()
-{
- return destination ;
-}
-
-void Message::setDestination(p<ActiveMQDestination> destination)
-{
- this->destination = destination ;
-}
-
-
-p<TransactionId> Message::getTransactionId()
-{
- return transactionId ;
-}
-
-void Message::setTransactionId(p<TransactionId> transactionId)
-{
- this->transactionId = transactionId ;
-}
-
-
-p<ActiveMQDestination> Message::getOriginalDestination()
-{
- return originalDestination ;
-}
-
-void Message::setOriginalDestination(p<ActiveMQDestination> originalDestination)
-{
- this->originalDestination = originalDestination ;
-}
-
-
-p<MessageId> Message::getMessageId()
-{
- return messageId ;
-}
-
-void Message::setMessageId(p<MessageId> messageId)
-{
- this->messageId = messageId ;
-}
-
-
-p<TransactionId> Message::getOriginalTransactionId()
-{
- return originalTransactionId ;
-}
-
-void Message::setOriginalTransactionId(p<TransactionId> originalTransactionId)
-{
- this->originalTransactionId = originalTransactionId ;
-}
-
-
-p<string> Message::getGroupID()
-{
- return groupID ;
-}
-
-void Message::setGroupID(p<string> groupID)
-{
- this->groupID = groupID ;
-}
-
-
-int Message::getGroupSequence()
-{
- return groupSequence ;
-}
-
-void Message::setGroupSequence(int groupSequence)
-{
- this->groupSequence = groupSequence ;
-}
-
-
-p<string> Message::getCorrelationId()
-{
- return correlationId ;
-}
-
-void Message::setCorrelationId(p<string> correlationId)
-{
- this->correlationId = correlationId ;
-}
-
-
-bool Message::getPersistent()
-{
- return persistent ;
-}
-
-void Message::setPersistent(bool persistent)
-{
- this->persistent = persistent ;
-}
-
-
-long long Message::getExpiration()
-{
- return expiration ;
-}
-
-void Message::setExpiration(long long expiration)
-{
- this->expiration = expiration ;
-}
-
-
-char Message::getPriority()
-{
- return priority ;
-}
-
-void Message::setPriority(char priority)
-{
- this->priority = priority ;
-}
-
-
-p<ActiveMQDestination> Message::getReplyTo()
-{
- return replyTo ;
-}
-
-void Message::setReplyTo(p<ActiveMQDestination> replyTo)
-{
- this->replyTo = replyTo ;
-}
-
-
-long long Message::getTimestamp()
-{
- return timestamp ;
-}
-
-void Message::setTimestamp(long long timestamp)
-{
- this->timestamp = timestamp ;
-}
-
-
-p<string> Message::getType()
-{
- return type ;
-}
-
-void Message::setType(p<string> type)
-{
- this->type = type ;
-}
-
-
-array<char> Message::getContent()
-{
- return content ;
-}
-
-void Message::setContent(array<char> content)
-{
- this->content = content ;
-}
-
-
-array<char> Message::getMarshalledProperties()
-{
- return marshalledProperties ;
-}
-
-void Message::setMarshalledProperties(array<char> marshalledProperties)
-{
- this->marshalledProperties = marshalledProperties ;
-}
-
-
-p<IDataStructure> Message::getDataStructure()
-{
- return dataStructure ;
-}
-
-void Message::setDataStructure(p<IDataStructure> dataStructure)
-{
- this->dataStructure = dataStructure ;
-}
-
-
-p<ConsumerId> Message::getTargetConsumerId()
-{
- return targetConsumerId ;
-}
-
-void Message::setTargetConsumerId(p<ConsumerId> targetConsumerId)
-{
- this->targetConsumerId = targetConsumerId ;
-}
-
-
-bool Message::getCompressed()
-{
- return compressed ;
-}
-
-void Message::setCompressed(bool compressed)
-{
- this->compressed = compressed ;
-}
-
-
-int Message::getRedeliveryCounter()
-{
- return redeliveryCounter ;
-}
-
-void Message::setRedeliveryCounter(int redeliveryCounter)
-{
- this->redeliveryCounter = redeliveryCounter ;
-}
-
-
-array<BrokerId> Message::getBrokerPath()
-{
- return brokerPath ;
-}
-
-void Message::setBrokerPath(array<BrokerId> brokerPath)
-{
- this->brokerPath = brokerPath ;
-}
-
-
-long long Message::getArrival()
-{
- return arrival ;
-}
-
-void Message::setArrival(long long arrival)
-{
- this->arrival = arrival ;
-}
-
-
-p<string> Message::getUserID()
-{
- return userID ;
-}
-
-void Message::setUserID(p<string> userID)
-{
- this->userID = userID ;
-}
-
-
-bool Message::getRecievedByDFBridge()
-{
- return recievedByDFBridge ;
-}
-
-void Message::setRecievedByDFBridge(bool recievedByDFBridge)
-{
- this->recievedByDFBridge = recievedByDFBridge ;
-}
-
-int Message::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
-{
- int size = 0 ;
-
- size += marshaller->marshalInt(commandId, mode, writer) ;
- size += marshaller->marshalBoolean(responseRequired, mode, writer) ;
- size += marshaller->marshalObject(producerId, mode, writer) ;
- size += marshaller->marshalObject(destination, mode, writer) ;
- size += marshaller->marshalObject(transactionId, mode, writer) ;
- size += marshaller->marshalObject(originalDestination, mode, writer) ;
- size += marshaller->marshalObject(messageId, mode, writer) ;
- size += marshaller->marshalObject(originalTransactionId, mode, writer) ;
- size += marshaller->marshalString(groupID, mode, writer) ;
- size += marshaller->marshalInt(groupSequence, mode, writer) ;
- size += marshaller->marshalString(correlationId, mode, writer) ;
- size += marshaller->marshalBoolean(persistent, mode, writer) ;
- size += marshaller->marshalLong(expiration, mode, writer) ;
- size += marshaller->marshalByte(priority, mode, writer) ;
- size += marshaller->marshalObject(replyTo, mode, writer) ;
- size += marshaller->marshalLong(timestamp, mode, writer) ;
- size += marshaller->marshalString(type, mode, writer) ;
- size += marshaller->marshalByteArray(content, mode, writer) ;
- size += marshaller->marshalByteArray(marshalledProperties, mode, writer) ;
- size += marshaller->marshalObject(dataStructure, mode, writer) ;
- size += marshaller->marshalObject(targetConsumerId, mode, writer) ;
- size += marshaller->marshalBoolean(compressed, mode, writer) ;
- size += marshaller->marshalInt(redeliveryCounter, mode, writer) ;
- size += marshaller->marshalObjectArray(brokerPath, mode, writer) ;
- size += marshaller->marshalLong(arrival, mode, writer) ;
- size += marshaller->marshalString(userID, mode, writer) ;
- size += marshaller->marshalBoolean(recievedByDFBridge, mode, writer) ;
- return size ;
-}
-
-void Message::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
-{
- commandId = marshaller->unmarshalInt(mode, reader) ;
- responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
- producerId = p_cast<ProducerId>(marshaller->unmarshalObject(mode, reader)) ;
- destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ;
- transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, reader)) ;
- originalDestination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ;
- messageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, reader)) ;
- originalTransactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, reader)) ;
- groupID = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
- groupSequence = (marshaller->unmarshalInt(mode, reader)) ;
- correlationId = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
- persistent = (marshaller->unmarshalBoolean(mode, reader)) ;
- expiration = (marshaller->unmarshalLong(mode, reader)) ;
- priority = (marshaller->unmarshalByte(mode, reader)) ;
- replyTo = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ;
- timestamp = (marshaller->unmarshalLong(mode, reader)) ;
- type = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
- content = (marshaller->unmarshalByteArray(mode, reader)) ;
- marshalledProperties = (marshaller->unmarshalByteArray(mode, reader)) ;
- dataStructure = p_cast<IDataStructure>(marshaller->unmarshalObject(mode, reader)) ;
- targetConsumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, reader)) ;
- compressed = (marshaller->unmarshalBoolean(mode, reader)) ;
- redeliveryCounter = (marshaller->unmarshalInt(mode, reader)) ;
- brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, reader)) ;
- arrival = (marshaller->unmarshalLong(mode, reader)) ;
- userID = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
- recievedByDFBridge = (marshaller->unmarshalBoolean(mode, reader)) ;
-}
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/Message.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+Message::Message()
+{
+ this->producerId = NULL ;
+ this->destination = NULL ;
+ this->transactionId = NULL ;
+ this->originalDestination = NULL ;
+ this->messageId = NULL ;
+ this->originalTransactionId = NULL ;
+ this->groupID = NULL ;
+ this->groupSequence = 0 ;
+ this->correlationId = NULL ;
+ this->persistent = false ;
+ this->expiration = 0 ;
+ this->priority = 0 ;
+ this->replyTo = NULL ;
+ this->timestamp = 0 ;
+ this->type = NULL ;
+ this->content = NULL ;
+ this->marshalledProperties = NULL ;
+ this->dataStructure = NULL ;
+ this->targetConsumerId = NULL ;
+ this->compressed = false ;
+ this->redeliveryCounter = 0 ;
+ this->brokerPath = NULL ;
+ this->arrival = 0 ;
+ this->userID = NULL ;
+ this->recievedByDFBridge = false ;
+}
+
+Message::~Message()
+{
+}
+
+unsigned char Message::getDataStructureType()
+{
+ return Message::TYPE ;
+}
+
+
+p<ProducerId> Message::getProducerId()
+{
+ return producerId ;
+}
+
+void Message::setProducerId(p<ProducerId> producerId)
+{
+ this->producerId = producerId ;
+}
+
+
+p<ActiveMQDestination> Message::getDestination()
+{
+ return destination ;
+}
+
+void Message::setDestination(p<ActiveMQDestination> destination)
+{
+ this->destination = destination ;
+}
+
+
+p<TransactionId> Message::getTransactionId()
+{
+ return transactionId ;
+}
+
+void Message::setTransactionId(p<TransactionId> transactionId)
+{
+ this->transactionId = transactionId ;
+}
+
+
+p<ActiveMQDestination> Message::getOriginalDestination()
+{
+ return originalDestination ;
+}
+
+void Message::setOriginalDestination(p<ActiveMQDestination> originalDestination)
+{
+ this->originalDestination = originalDestination ;
+}
+
+
+p<MessageId> Message::getMessageId()
+{
+ return messageId ;
+}
+
+void Message::setMessageId(p<MessageId> messageId)
+{
+ this->messageId = messageId ;
+}
+
+
+p<TransactionId> Message::getOriginalTransactionId()
+{
+ return originalTransactionId ;
+}
+
+void Message::setOriginalTransactionId(p<TransactionId> originalTransactionId)
+{
+ this->originalTransactionId = originalTransactionId ;
+}
+
+
+p<string> Message::getGroupID()
+{
+ return groupID ;
+}
+
+void Message::setGroupID(p<string> groupID)
+{
+ this->groupID = groupID ;
+}
+
+
+int Message::getGroupSequence()
+{
+ return groupSequence ;
+}
+
+void Message::setGroupSequence(int groupSequence)
+{
+ this->groupSequence = groupSequence ;
+}
+
+
+p<string> Message::getCorrelationId()
+{
+ return correlationId ;
+}
+
+void Message::setCorrelationId(p<string> correlationId)
+{
+ this->correlationId = correlationId ;
+}
+
+
+bool Message::getPersistent()
+{
+ return persistent ;
+}
+
+void Message::setPersistent(bool persistent)
+{
+ this->persistent = persistent ;
+}
+
+
+long long Message::getExpiration()
+{
+ return expiration ;
+}
+
+void Message::setExpiration(long long expiration)
+{
+ this->expiration = expiration ;
+}
+
+
+char Message::getPriority()
+{
+ return priority ;
+}
+
+void Message::setPriority(char priority)
+{
+ this->priority = priority ;
+}
+
+
+p<ActiveMQDestination> Message::getReplyTo()
+{
+ return replyTo ;
+}
+
+void Message::setReplyTo(p<ActiveMQDestination> replyTo)
+{
+ this->replyTo = replyTo ;
+}
+
+
+long long Message::getTimestamp()
+{
+ return timestamp ;
+}
+
+void Message::setTimestamp(long long timestamp)
+{
+ this->timestamp = timestamp ;
+}
+
+
+p<string> Message::getType()
+{
+ return type ;
+}
+
+void Message::setType(p<string> type)
+{
+ this->type = type ;
+}
+
+
+array<char> Message::getContent()
+{
+ return content ;
+}
+
+void Message::setContent(array<char> content)
+{
+ this->content = content ;
+}
+
+
+array<char> Message::getMarshalledProperties()
+{
+ return marshalledProperties ;
+}
+
+void Message::setMarshalledProperties(array<char> marshalledProperties)
+{
+ this->marshalledProperties = marshalledProperties ;
+}
+
+
+p<IDataStructure> Message::getDataStructure()
+{
+ return dataStructure ;
+}
+
+void Message::setDataStructure(p<IDataStructure> dataStructure)
+{
+ this->dataStructure = dataStructure ;
+}
+
+
+p<ConsumerId> Message::getTargetConsumerId()
+{
+ return targetConsumerId ;
+}
+
+void Message::setTargetConsumerId(p<ConsumerId> targetConsumerId)
+{
+ this->targetConsumerId = targetConsumerId ;
+}
+
+
+bool Message::getCompressed()
+{
+ return compressed ;
+}
+
+void Message::setCompressed(bool compressed)
+{
+ this->compressed = compressed ;
+}
+
+
+int Message::getRedeliveryCounter()
+{
+ return redeliveryCounter ;
+}
+
+void Message::setRedeliveryCounter(int redeliveryCounter)
+{
+ this->redeliveryCounter = redeliveryCounter ;
+}
+
+
+array<BrokerId> Message::getBrokerPath()
+{
+ return brokerPath ;
+}
+
+void Message::setBrokerPath(array<BrokerId> brokerPath)
+{
+ this->brokerPath = brokerPath ;
+}
+
+
+long long Message::getArrival()
+{
+ return arrival ;
+}
+
+void Message::setArrival(long long arrival)
+{
+ this->arrival = arrival ;
+}
+
+
+p<string> Message::getUserID()
+{
+ return userID ;
+}
+
+void Message::setUserID(p<string> userID)
+{
+ this->userID = userID ;
+}
+
+
+bool Message::getRecievedByDFBridge()
+{
+ return recievedByDFBridge ;
+}
+
+void Message::setRecievedByDFBridge(bool recievedByDFBridge)
+{
+ this->recievedByDFBridge = recievedByDFBridge ;
+}
+
+int Message::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+ int size = 0 ;
+
+ size += BaseCommand::marshal(marshaller, mode, ostream) ;
+ size += marshaller->marshalObject(producerId, mode, ostream) ;
+ size += marshaller->marshalObject(destination, mode, ostream) ;
+ size += marshaller->marshalObject(transactionId, mode, ostream) ;
+ size += marshaller->marshalObject(originalDestination, mode, ostream) ;
+ size += marshaller->marshalObject(messageId, mode, ostream) ;
+ size += marshaller->marshalObject(originalTransactionId, mode, ostream) ;
+ size += marshaller->marshalString(groupID, mode, ostream) ;
+ size += marshaller->marshalInt(groupSequence, mode, ostream) ;
+ size += marshaller->marshalString(correlationId, mode, ostream) ;
+ size += marshaller->marshalBoolean(persistent, mode, ostream) ;
+ size += marshaller->marshalLong(expiration, mode, ostream) ;
+ size += marshaller->marshalByte(priority, mode, ostream) ;
+ size += marshaller->marshalObject(replyTo, mode, ostream) ;
+ size += marshaller->marshalLong(timestamp, mode, ostream) ;
+ size += marshaller->marshalString(type, mode, ostream) ;
+ size += marshaller->marshalByteArray(content, mode, ostream) ;
+ size += marshaller->marshalByteArray(marshalledProperties, mode, ostream) ;
+ size += marshaller->marshalObject(dataStructure, mode, ostream) ;
+ size += marshaller->marshalObject(targetConsumerId, mode, ostream) ;
+ size += marshaller->marshalBoolean(compressed, mode, ostream) ;
+ size += marshaller->marshalInt(redeliveryCounter, mode, ostream) ;
+ size += marshaller->marshalObjectArray(brokerPath, mode, ostream) ;
+ size += marshaller->marshalLong(arrival, mode, ostream) ;
+ size += marshaller->marshalString(userID, mode, ostream) ;
+ size += marshaller->marshalBoolean(recievedByDFBridge, mode, ostream) ;
+ return size ;
+}
+
+void Message::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+ BaseCommand::unmarshal(marshaller, mode, istream) ;
+ producerId = p_cast<ProducerId>(marshaller->unmarshalObject(mode, istream)) ;
+ destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ;
+ transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, istream)) ;
+ originalDestination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ;
+ messageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, istream)) ;
+ originalTransactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, istream)) ;
+ groupID = p_cast<string>(marshaller->unmarshalString(mode, istream)) ;
+ groupSequence = (marshaller->unmarshalInt(mode, istream)) ;
+ correlationId = p_cast<string>(marshaller->unmarshalString(mode, istream)) ;
+ persistent = (marshaller->unmarshalBoolean(mode, istream)) ;
+ expiration = (marshaller->unmarshalLong(mode, istream)) ;
+ priority = (marshaller->unmarshalByte(mode, istream)) ;
+ replyTo = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ;
+ timestamp = (marshaller->unmarshalLong(mode, istream)) ;
+ type = p_cast<string>(marshaller->unmarshalString(mode, istream)) ;
+ content = (marshaller->unmarshalByteArray(mode, istream)) ;
+ marshalledProperties = (marshaller->unmarshalByteArray(mode, istream)) ;
+ dataStructure = p_cast<IDataStructure>(marshaller->unmarshalObject(mode, istream)) ;
+ targetConsumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, istream)) ;
+ compressed = (marshaller->unmarshalBoolean(mode, istream)) ;
+ redeliveryCounter = (marshaller->unmarshalInt(mode, istream)) ;
+ brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, istream)) ;
+ arrival = (marshaller->unmarshalLong(mode, istream)) ;
+ userID = p_cast<string>(marshaller->unmarshalString(mode, istream)) ;
+ recievedByDFBridge = (marshaller->unmarshalBoolean(mode, istream)) ;
+}
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.hpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Message.hpp Mon May 15 06:38:57 2006
@@ -1,188 +1,189 @@
-/*
-* 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 ActiveMQ_Message_hpp_
-#define ActiveMQ_Message_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/IDataStructure.hpp"
-#include "activemq/command/BaseCommand.hpp"
-#include "activemq/command/ProducerId.hpp"
-#include "activemq/command/ActiveMQDestination.hpp"
-#include "activemq/command/TransactionId.hpp"
-#include "activemq/command/ActiveMQDestination.hpp"
-#include "activemq/command/MessageId.hpp"
-#include "activemq/command/TransactionId.hpp"
-#include "activemq/command/ActiveMQDestination.hpp"
-#include "activemq/command/ConsumerId.hpp"
-#include "activemq/command/BrokerId.hpp"
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
- namespace activemq
- {
- namespace command
- {
- using namespace ifr;
- using namespace std;
- using namespace apache::activemq;
- using namespace apache::activemq::protocol;
- using namespace apache::ppr::io;
-
-/*
- *
- * 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
- *
- */
-class Message : public BaseCommand
-{
-protected:
- p<ProducerId> producerId ;
- p<ActiveMQDestination> destination ;
- p<TransactionId> transactionId ;
- p<ActiveMQDestination> originalDestination ;
- p<MessageId> messageId ;
- p<TransactionId> originalTransactionId ;
- p<string> groupID ;
- int groupSequence ;
- p<string> correlationId ;
- bool persistent ;
- long long expiration ;
- char priority ;
- p<ActiveMQDestination> replyTo ;
- long long timestamp ;
- p<string> type ;
- array<char> content ;
- array<char> marshalledProperties ;
- p<IDataStructure> dataStructure ;
- p<ConsumerId> targetConsumerId ;
- bool compressed ;
- int redeliveryCounter ;
- array<BrokerId> brokerPath ;
- long long arrival ;
- p<string> userID ;
- bool recievedByDFBridge ;
-
-public:
- const static unsigned char TYPE = 0;
-
-public:
- Message() ;
- virtual ~Message() ;
-
- virtual unsigned char getDataStructureType() ;
-
- virtual p<ProducerId> getProducerId() ;
- virtual void setProducerId(p<ProducerId> producerId) ;
-
- virtual p<ActiveMQDestination> getDestination() ;
- virtual void setDestination(p<ActiveMQDestination> destination) ;
-
- virtual p<TransactionId> getTransactionId() ;
- virtual void setTransactionId(p<TransactionId> transactionId) ;
-
- virtual p<ActiveMQDestination> getOriginalDestination() ;
- virtual void setOriginalDestination(p<ActiveMQDestination> originalDestination) ;
-
- virtual p<MessageId> getMessageId() ;
- virtual void setMessageId(p<MessageId> messageId) ;
-
- virtual p<TransactionId> getOriginalTransactionId() ;
- virtual void setOriginalTransactionId(p<TransactionId> originalTransactionId) ;
-
- virtual p<string> getGroupID() ;
- virtual void setGroupID(p<string> groupID) ;
-
- virtual int getGroupSequence() ;
- virtual void setGroupSequence(int groupSequence) ;
-
- virtual p<string> getCorrelationId() ;
- virtual void setCorrelationId(p<string> correlationId) ;
-
- virtual bool getPersistent() ;
- virtual void setPersistent(bool persistent) ;
-
- virtual long long getExpiration() ;
- virtual void setExpiration(long long expiration) ;
-
- virtual char getPriority() ;
- virtual void setPriority(char priority) ;
-
- virtual p<ActiveMQDestination> getReplyTo() ;
- virtual void setReplyTo(p<ActiveMQDestination> replyTo) ;
-
- virtual long long getTimestamp() ;
- virtual void setTimestamp(long long timestamp) ;
-
- virtual p<string> getType() ;
- virtual void setType(p<string> type) ;
-
- virtual array<char> getContent() ;
- virtual void setContent(array<char> content) ;
-
- virtual array<char> getMarshalledProperties() ;
- virtual void setMarshalledProperties(array<char> marshalledProperties) ;
-
- virtual p<IDataStructure> getDataStructure() ;
- virtual void setDataStructure(p<IDataStructure> dataStructure) ;
-
- virtual p<ConsumerId> getTargetConsumerId() ;
- virtual void setTargetConsumerId(p<ConsumerId> targetConsumerId) ;
-
- virtual bool getCompressed() ;
- virtual void setCompressed(bool compressed) ;
-
- virtual int getRedeliveryCounter() ;
- virtual void setRedeliveryCounter(int redeliveryCounter) ;
-
- virtual array<BrokerId> getBrokerPath() ;
- virtual void setBrokerPath(array<BrokerId> brokerPath) ;
-
- virtual long long getArrival() ;
- virtual void setArrival(long long arrival) ;
-
- virtual p<string> getUserID() ;
- virtual void setUserID(p<string> userID) ;
-
- virtual bool getRecievedByDFBridge() ;
- virtual void setRecievedByDFBridge(bool recievedByDFBridge) ;
-
- virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException) ;
- virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException) ;
-} ;
-
-/* namespace */
- }
- }
-}
-
-#endif /*ActiveMQ_Message_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 ActiveMQ_Message_hpp_
+#define ActiveMQ_Message_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/ProducerId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/TransactionId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/MessageId.hpp"
+#include "activemq/command/TransactionId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/IDataStructure.hpp"
+#include "activemq/command/ConsumerId.hpp"
+#include "activemq/command/BrokerId.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq;
+ using namespace apache::activemq::protocol;
+ using namespace apache::ppr::io;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+class Message : public BaseCommand
+{
+protected:
+ p<ProducerId> producerId ;
+ p<ActiveMQDestination> destination ;
+ p<TransactionId> transactionId ;
+ p<ActiveMQDestination> originalDestination ;
+ p<MessageId> messageId ;
+ p<TransactionId> originalTransactionId ;
+ p<string> groupID ;
+ int groupSequence ;
+ p<string> correlationId ;
+ bool persistent ;
+ long long expiration ;
+ char priority ;
+ p<ActiveMQDestination> replyTo ;
+ long long timestamp ;
+ p<string> type ;
+ array<char> content ;
+ array<char> marshalledProperties ;
+ p<IDataStructure> dataStructure ;
+ p<ConsumerId> targetConsumerId ;
+ bool compressed ;
+ int redeliveryCounter ;
+ array<BrokerId> brokerPath ;
+ long long arrival ;
+ p<string> userID ;
+ bool recievedByDFBridge ;
+
+public:
+ const static unsigned char TYPE = 0;
+
+public:
+ Message() ;
+ virtual ~Message() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<ProducerId> getProducerId() ;
+ virtual void setProducerId(p<ProducerId> producerId) ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual p<TransactionId> getTransactionId() ;
+ virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+ virtual p<ActiveMQDestination> getOriginalDestination() ;
+ virtual void setOriginalDestination(p<ActiveMQDestination> originalDestination) ;
+
+ virtual p<MessageId> getMessageId() ;
+ virtual void setMessageId(p<MessageId> messageId) ;
+
+ virtual p<TransactionId> getOriginalTransactionId() ;
+ virtual void setOriginalTransactionId(p<TransactionId> originalTransactionId) ;
+
+ virtual p<string> getGroupID() ;
+ virtual void setGroupID(p<string> groupID) ;
+
+ virtual int getGroupSequence() ;
+ virtual void setGroupSequence(int groupSequence) ;
+
+ virtual p<string> getCorrelationId() ;
+ virtual void setCorrelationId(p<string> correlationId) ;
+
+ virtual bool getPersistent() ;
+ virtual void setPersistent(bool persistent) ;
+
+ virtual long long getExpiration() ;
+ virtual void setExpiration(long long expiration) ;
+
+ virtual char getPriority() ;
+ virtual void setPriority(char priority) ;
+
+ virtual p<ActiveMQDestination> getReplyTo() ;
+ virtual void setReplyTo(p<ActiveMQDestination> replyTo) ;
+
+ virtual long long getTimestamp() ;
+ virtual void setTimestamp(long long timestamp) ;
+
+ virtual p<string> getType() ;
+ virtual void setType(p<string> type) ;
+
+ virtual array<char> getContent() ;
+ virtual void setContent(array<char> content) ;
+
+ virtual array<char> getMarshalledProperties() ;
+ virtual void setMarshalledProperties(array<char> marshalledProperties) ;
+
+ virtual p<IDataStructure> getDataStructure() ;
+ virtual void setDataStructure(p<IDataStructure> dataStructure) ;
+
+ virtual p<ConsumerId> getTargetConsumerId() ;
+ virtual void setTargetConsumerId(p<ConsumerId> targetConsumerId) ;
+
+ virtual bool getCompressed() ;
+ virtual void setCompressed(bool compressed) ;
+
+ virtual int getRedeliveryCounter() ;
+ virtual void setRedeliveryCounter(int redeliveryCounter) ;
+
+ virtual array<BrokerId> getBrokerPath() ;
+ virtual void setBrokerPath(array<BrokerId> brokerPath) ;
+
+ virtual long long getArrival() ;
+ virtual void setArrival(long long arrival) ;
+
+ virtual p<string> getUserID() ;
+ virtual void setUserID(p<string> userID) ;
+
+ virtual bool getRecievedByDFBridge() ;
+ virtual void setRecievedByDFBridge(bool recievedByDFBridge) ;
+
+ virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+ virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+ }
+ }
+}
+
+#endif /*ActiveMQ_Message_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.cpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.cpp Mon May 15 06:38:57 2006
@@ -1,155 +1,153 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#include "activemq/command/MessageAck.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- * 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
- *
- */
-MessageAck::MessageAck()
-{
- this->destination = NULL ;
- this->transactionId = NULL ;
- this->consumerId = NULL ;
- this->ackType = 0 ;
- this->firstMessageId = NULL ;
- this->lastMessageId = NULL ;
- this->messageCount = 0 ;
-}
-
-MessageAck::~MessageAck()
-{
-}
-
-unsigned char MessageAck::getDataStructureType()
-{
- return MessageAck::TYPE ;
-}
-
-
-p<ActiveMQDestination> MessageAck::getDestination()
-{
- return destination ;
-}
-
-void MessageAck::setDestination(p<ActiveMQDestination> destination)
-{
- this->destination = destination ;
-}
-
-
-p<TransactionId> MessageAck::getTransactionId()
-{
- return transactionId ;
-}
-
-void MessageAck::setTransactionId(p<TransactionId> transactionId)
-{
- this->transactionId = transactionId ;
-}
-
-
-p<ConsumerId> MessageAck::getConsumerId()
-{
- return consumerId ;
-}
-
-void MessageAck::setConsumerId(p<ConsumerId> consumerId)
-{
- this->consumerId = consumerId ;
-}
-
-
-char MessageAck::getAckType()
-{
- return ackType ;
-}
-
-void MessageAck::setAckType(char ackType)
-{
- this->ackType = ackType ;
-}
-
-
-p<MessageId> MessageAck::getFirstMessageId()
-{
- return firstMessageId ;
-}
-
-void MessageAck::setFirstMessageId(p<MessageId> firstMessageId)
-{
- this->firstMessageId = firstMessageId ;
-}
-
-
-p<MessageId> MessageAck::getLastMessageId()
-{
- return lastMessageId ;
-}
-
-void MessageAck::setLastMessageId(p<MessageId> lastMessageId)
-{
- this->lastMessageId = lastMessageId ;
-}
-
-
-int MessageAck::getMessageCount()
-{
- return messageCount ;
-}
-
-void MessageAck::setMessageCount(int messageCount)
-{
- this->messageCount = messageCount ;
-}
-
-int MessageAck::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
-{
- int size = 0 ;
-
- size += marshaller->marshalInt(commandId, mode, writer) ;
- size += marshaller->marshalBoolean(responseRequired, mode, writer) ;
- size += marshaller->marshalObject(destination, mode, writer) ;
- size += marshaller->marshalObject(transactionId, mode, writer) ;
- size += marshaller->marshalObject(consumerId, mode, writer) ;
- size += marshaller->marshalByte(ackType, mode, writer) ;
- size += marshaller->marshalObject(firstMessageId, mode, writer) ;
- size += marshaller->marshalObject(lastMessageId, mode, writer) ;
- size += marshaller->marshalInt(messageCount, mode, writer) ;
- return size ;
-}
-
-void MessageAck::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
-{
- commandId = marshaller->unmarshalInt(mode, reader) ;
- responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
- destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ;
- transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, reader)) ;
- consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, reader)) ;
- ackType = (marshaller->unmarshalByte(mode, reader)) ;
- firstMessageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, reader)) ;
- lastMessageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, reader)) ;
- messageCount = (marshaller->unmarshalInt(mode, reader)) ;
-}
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/MessageAck.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+MessageAck::MessageAck()
+{
+ this->destination = NULL ;
+ this->transactionId = NULL ;
+ this->consumerId = NULL ;
+ this->ackType = 0 ;
+ this->firstMessageId = NULL ;
+ this->lastMessageId = NULL ;
+ this->messageCount = 0 ;
+}
+
+MessageAck::~MessageAck()
+{
+}
+
+unsigned char MessageAck::getDataStructureType()
+{
+ return MessageAck::TYPE ;
+}
+
+
+p<ActiveMQDestination> MessageAck::getDestination()
+{
+ return destination ;
+}
+
+void MessageAck::setDestination(p<ActiveMQDestination> destination)
+{
+ this->destination = destination ;
+}
+
+
+p<TransactionId> MessageAck::getTransactionId()
+{
+ return transactionId ;
+}
+
+void MessageAck::setTransactionId(p<TransactionId> transactionId)
+{
+ this->transactionId = transactionId ;
+}
+
+
+p<ConsumerId> MessageAck::getConsumerId()
+{
+ return consumerId ;
+}
+
+void MessageAck::setConsumerId(p<ConsumerId> consumerId)
+{
+ this->consumerId = consumerId ;
+}
+
+
+char MessageAck::getAckType()
+{
+ return ackType ;
+}
+
+void MessageAck::setAckType(char ackType)
+{
+ this->ackType = ackType ;
+}
+
+
+p<MessageId> MessageAck::getFirstMessageId()
+{
+ return firstMessageId ;
+}
+
+void MessageAck::setFirstMessageId(p<MessageId> firstMessageId)
+{
+ this->firstMessageId = firstMessageId ;
+}
+
+
+p<MessageId> MessageAck::getLastMessageId()
+{
+ return lastMessageId ;
+}
+
+void MessageAck::setLastMessageId(p<MessageId> lastMessageId)
+{
+ this->lastMessageId = lastMessageId ;
+}
+
+
+int MessageAck::getMessageCount()
+{
+ return messageCount ;
+}
+
+void MessageAck::setMessageCount(int messageCount)
+{
+ this->messageCount = messageCount ;
+}
+
+int MessageAck::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+ int size = 0 ;
+
+ size += BaseCommand::marshal(marshaller, mode, ostream) ;
+ size += marshaller->marshalObject(destination, mode, ostream) ;
+ size += marshaller->marshalObject(transactionId, mode, ostream) ;
+ size += marshaller->marshalObject(consumerId, mode, ostream) ;
+ size += marshaller->marshalByte(ackType, mode, ostream) ;
+ size += marshaller->marshalObject(firstMessageId, mode, ostream) ;
+ size += marshaller->marshalObject(lastMessageId, mode, ostream) ;
+ size += marshaller->marshalInt(messageCount, mode, ostream) ;
+ return size ;
+}
+
+void MessageAck::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+ BaseCommand::unmarshal(marshaller, mode, istream) ;
+ destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ;
+ transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, istream)) ;
+ consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, istream)) ;
+ ackType = (marshaller->unmarshalByte(mode, istream)) ;
+ firstMessageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, istream)) ;
+ lastMessageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, istream)) ;
+ messageCount = (marshaller->unmarshalInt(mode, istream)) ;
+}
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.hpp?rev=406628&r1=406627&r2=406628&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/MessageAck.hpp Mon May 15 06:38:57 2006
@@ -1,111 +1,112 @@
-/*
-* 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 ActiveMQ_MessageAck_hpp_
-#define ActiveMQ_MessageAck_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseCommand.hpp"
-#include "activemq/command/ActiveMQDestination.hpp"
-#include "activemq/command/TransactionId.hpp"
-#include "activemq/command/ConsumerId.hpp"
-#include "activemq/command/MessageId.hpp"
-#include "activemq/command/MessageId.hpp"
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
- namespace activemq
- {
- namespace command
- {
- using namespace ifr;
- using namespace std;
- using namespace apache::activemq;
- using namespace apache::activemq::protocol;
- using namespace apache::ppr::io;
-
-/*
- *
- * 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
- *
- */
-class MessageAck : public BaseCommand
-{
-protected:
- p<ActiveMQDestination> destination ;
- p<TransactionId> transactionId ;
- p<ConsumerId> consumerId ;
- char ackType ;
- p<MessageId> firstMessageId ;
- p<MessageId> lastMessageId ;
- int messageCount ;
-
-public:
- const static unsigned char TYPE = 22;
-
-public:
- MessageAck() ;
- virtual ~MessageAck() ;
-
- virtual unsigned char getDataStructureType() ;
-
- virtual p<ActiveMQDestination> getDestination() ;
- virtual void setDestination(p<ActiveMQDestination> destination) ;
-
- virtual p<TransactionId> getTransactionId() ;
- virtual void setTransactionId(p<TransactionId> transactionId) ;
-
- virtual p<ConsumerId> getConsumerId() ;
- virtual void setConsumerId(p<ConsumerId> consumerId) ;
-
- virtual char getAckType() ;
- virtual void setAckType(char ackType) ;
-
- virtual p<MessageId> getFirstMessageId() ;
- virtual void setFirstMessageId(p<MessageId> firstMessageId) ;
-
- virtual p<MessageId> getLastMessageId() ;
- virtual void setLastMessageId(p<MessageId> lastMessageId) ;
-
- virtual int getMessageCount() ;
- virtual void setMessageCount(int messageCount) ;
-
- virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException) ;
- virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException) ;
-} ;
-
-/* namespace */
- }
- }
-}
-
-#endif /*ActiveMQ_MessageAck_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 ActiveMQ_MessageAck_hpp_
+#define ActiveMQ_MessageAck_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/TransactionId.hpp"
+#include "activemq/command/ConsumerId.hpp"
+#include "activemq/command/MessageId.hpp"
+#include "activemq/command/MessageId.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq;
+ using namespace apache::activemq::protocol;
+ using namespace apache::ppr::io;
+
+/*
+ *
+ * Command and marshalling code for OpenWire 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
+ *
+ */
+class MessageAck : public BaseCommand
+{
+protected:
+ p<ActiveMQDestination> destination ;
+ p<TransactionId> transactionId ;
+ p<ConsumerId> consumerId ;
+ char ackType ;
+ p<MessageId> firstMessageId ;
+ p<MessageId> lastMessageId ;
+ int messageCount ;
+
+public:
+ const static unsigned char TYPE = 22;
+
+public:
+ MessageAck() ;
+ virtual ~MessageAck() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual p<TransactionId> getTransactionId() ;
+ virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+ virtual p<ConsumerId> getConsumerId() ;
+ virtual void setConsumerId(p<ConsumerId> consumerId) ;
+
+ virtual char getAckType() ;
+ virtual void setAckType(char ackType) ;
+
+ virtual p<MessageId> getFirstMessageId() ;
+ virtual void setFirstMessageId(p<MessageId> firstMessageId) ;
+
+ virtual p<MessageId> getLastMessageId() ;
+ virtual void setLastMessageId(p<MessageId> lastMessageId) ;
+
+ virtual int getMessageCount() ;
+ virtual void setMessageCount(int messageCount) ;
+
+ virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+ virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+ }
+ }
+}
+
+#endif /*ActiveMQ_MessageAck_hpp_*/