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/04/27 23:59:44 UTC
svn commit: r397654 [5/12] - in /incubator/activemq/trunk/openwire-cpp: ./
src/ src/command/ src/gram/ src/gram/java/ src/gram/java/org/
src/gram/java/org/apache/ src/gram/java/org/apache/activemq/
src/gram/java/org/apache/activemq/openwire/ src/gram/j...
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,243 @@
+/*
+* 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/ConsumerInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ConsumerInfo
+ *
+ *
+ * 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
+ *
+ */
+ConsumerInfo::ConsumerInfo()
+{
+ this->consumerId = NULL ;
+ this->browser = false ;
+ this->destination = NULL ;
+ this->prefetchSize = 0 ;
+ this->dispatchAsync = false ;
+ this->selector = NULL ;
+ this->subcriptionName = NULL ;
+ this->noLocal = false ;
+ this->exclusive = false ;
+ this->retroactive = false ;
+ this->priority = 0 ;
+ this->brokerPath = NULL ;
+ this->networkSubscription = false ;
+}
+
+ConsumerInfo::~ConsumerInfo()
+{
+}
+
+unsigned char ConsumerInfo::getDataStructureType()
+{
+ return ConsumerInfo::TYPE ;
+}
+
+
+p<ConsumerId> ConsumerInfo::getConsumerId()
+{
+ return consumerId ;
+}
+
+void ConsumerInfo::setConsumerId(p<ConsumerId> consumerId)
+{
+ this->consumerId = consumerId ;
+}
+
+
+bool ConsumerInfo::getBrowser()
+{
+ return browser ;
+}
+
+void ConsumerInfo::setBrowser(bool browser)
+{
+ this->browser = browser ;
+}
+
+
+p<ActiveMQDestination> ConsumerInfo::getDestination()
+{
+ return destination ;
+}
+
+void ConsumerInfo::setDestination(p<ActiveMQDestination> destination)
+{
+ this->destination = destination ;
+}
+
+
+int ConsumerInfo::getPrefetchSize()
+{
+ return prefetchSize ;
+}
+
+void ConsumerInfo::setPrefetchSize(int prefetchSize)
+{
+ this->prefetchSize = prefetchSize ;
+}
+
+
+bool ConsumerInfo::getDispatchAsync()
+{
+ return dispatchAsync ;
+}
+
+void ConsumerInfo::setDispatchAsync(bool dispatchAsync)
+{
+ this->dispatchAsync = dispatchAsync ;
+}
+
+
+p<string> ConsumerInfo::getSelector()
+{
+ return selector ;
+}
+
+void ConsumerInfo::setSelector(p<string> selector)
+{
+ this->selector = selector ;
+}
+
+
+p<string> ConsumerInfo::getSubcriptionName()
+{
+ return subcriptionName ;
+}
+
+void ConsumerInfo::setSubcriptionName(p<string> subcriptionName)
+{
+ this->subcriptionName = subcriptionName ;
+}
+
+
+bool ConsumerInfo::getNoLocal()
+{
+ return noLocal ;
+}
+
+void ConsumerInfo::setNoLocal(bool noLocal)
+{
+ this->noLocal = noLocal ;
+}
+
+
+bool ConsumerInfo::getExclusive()
+{
+ return exclusive ;
+}
+
+void ConsumerInfo::setExclusive(bool exclusive)
+{
+ this->exclusive = exclusive ;
+}
+
+
+bool ConsumerInfo::getRetroactive()
+{
+ return retroactive ;
+}
+
+void ConsumerInfo::setRetroactive(bool retroactive)
+{
+ this->retroactive = retroactive ;
+}
+
+
+char ConsumerInfo::getPriority()
+{
+ return priority ;
+}
+
+void ConsumerInfo::setPriority(char priority)
+{
+ this->priority = priority ;
+}
+
+
+array<BrokerId> ConsumerInfo::getBrokerPath()
+{
+ return brokerPath ;
+}
+
+void ConsumerInfo::setBrokerPath(array<BrokerId> brokerPath)
+{
+ this->brokerPath = brokerPath ;
+}
+
+
+bool ConsumerInfo::getNetworkSubscription()
+{
+ return networkSubscription ;
+}
+
+void ConsumerInfo::setNetworkSubscription(bool networkSubscription)
+{
+ this->networkSubscription = networkSubscription ;
+}
+
+int ConsumerInfo::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(consumerId, mode, writer) ;
+ size += marshaller->marshalBoolean(browser, mode, writer) ;
+ size += marshaller->marshalObject(destination, mode, writer) ;
+ size += marshaller->marshalInt(prefetchSize, mode, writer) ;
+ size += marshaller->marshalInt(maximumPendingMessageLimit, mode, writer) ;
+ size += marshaller->marshalBoolean(dispatchAsync, mode, writer) ;
+ size += marshaller->marshalString(selector, mode, writer) ;
+ size += marshaller->marshalString(subcriptionName, mode, writer) ;
+ size += marshaller->marshalBoolean(noLocal, mode, writer) ;
+ size += marshaller->marshalBoolean(exclusive, mode, writer) ;
+ size += marshaller->marshalBoolean(retroactive, mode, writer) ;
+ size += marshaller->marshalByte(priority, mode, writer) ;
+ size += marshaller->marshalObjectArray(brokerPath, mode, writer) ;
+ size += marshaller->marshalObject(additionalPredicate, mode, writer) ;
+ size += marshaller->marshalBoolean(networkSubscription, mode, writer) ;
+ return size ;
+}
+
+void ConsumerInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, reader)) ;
+ browser = (marshaller->unmarshalBoolean(mode, reader)) ;
+ destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ;
+ prefetchSize = (marshaller->unmarshalInt(mode, reader)) ;
+ maximumPendingMessageLimit = (marshaller->unmarshalInt(mode, reader)) ;
+ dispatchAsync = (marshaller->unmarshalBoolean(mode, reader)) ;
+ selector = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
+ subcriptionName = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
+ noLocal = (marshaller->unmarshalBoolean(mode, reader)) ;
+ exclusive = (marshaller->unmarshalBoolean(mode, reader)) ;
+ retroactive = (marshaller->unmarshalBoolean(mode, reader)) ;
+ priority = (marshaller->unmarshalByte(mode, reader)) ;
+ brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, reader)) ;
+ additionalPredicate = p_cast<BooleanExpression>(marshaller->unmarshalObject(mode, reader)) ;
+ networkSubscription = (marshaller->unmarshalBoolean(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,136 @@
+/*
+* 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_ConsumerInfo_hpp_
+#define ActiveMQ_ConsumerInfo_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/ConsumerId.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+#include "activemq/command/BrokerId.hpp"
+#include "activemq/command/BooleanExpression.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 ConsumerInfo
+ *
+ *
+ * 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 ConsumerInfo : public BaseCommand
+{
+protected:
+ p<ConsumerId> consumerId ;
+ p<ActiveMQDestination> destination ;
+ int prefetchSize ;
+ int maximumPendingMessageLimit ;
+ bool browser ;
+ bool dispatchAsync ;
+ p<string> selector ;
+ p<string> subcriptionName ;
+ bool noLocal ;
+ bool exclusive ;
+ bool retroactive ;
+ char priority ;
+ array<BrokerId> brokerPath ;
+ p<BooleanExpression> additionalPredicate ;
+ bool networkSubscription ;
+
+public:
+ const static unsigned char TYPE = 5;
+
+public:
+ ConsumerInfo() ;
+ virtual ~ConsumerInfo() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<ConsumerId> getConsumerId() ;
+ virtual void setConsumerId(p<ConsumerId> consumerId) ;
+
+ virtual bool getBrowser() ;
+ virtual void setBrowser(bool browser) ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual int getPrefetchSize() ;
+ virtual void setPrefetchSize(int prefetchSize) ;
+
+ virtual bool getDispatchAsync() ;
+ virtual void setDispatchAsync(bool dispatchAsync) ;
+
+ virtual p<string> getSelector() ;
+ virtual void setSelector(p<string> selector) ;
+
+ virtual p<string> getSubcriptionName() ;
+ virtual void setSubcriptionName(p<string> subcriptionName) ;
+
+ virtual bool getNoLocal() ;
+ virtual void setNoLocal(bool noLocal) ;
+
+ virtual bool getExclusive() ;
+ virtual void setExclusive(bool exclusive) ;
+
+ virtual bool getRetroactive() ;
+ virtual void setRetroactive(bool retroactive) ;
+
+ virtual char getPriority() ;
+ virtual void setPriority(char priority) ;
+
+ virtual array<BrokerId> getBrokerPath() ;
+ virtual void setBrokerPath(array<BrokerId> brokerPath) ;
+
+ virtual bool getNetworkSubscription() ;
+ virtual void setNetworkSubscription(bool networkSubscription) ;
+
+ 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_ConsumerInfo_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/ControlCommand.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ControlCommand
+ *
+ *
+ * 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
+ *
+ */
+ControlCommand::ControlCommand()
+{
+ this->command = NULL ;
+}
+
+ControlCommand::~ControlCommand()
+{
+}
+
+unsigned char ControlCommand::getDataStructureType()
+{
+ return ControlCommand::TYPE ;
+}
+
+
+p<string> ControlCommand::getCommand()
+{
+ return command ;
+}
+
+void ControlCommand::setCommand(p<string> command)
+{
+ this->command = command ;
+}
+
+int ControlCommand::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->marshalString(command, mode, writer) ;
+ return size ;
+}
+
+void ControlCommand::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ command = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,82 @@
+/*
+* 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_ControlCommand_hpp_
+#define ActiveMQ_ControlCommand_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;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ControlCommand
+ *
+ *
+ * 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 ControlCommand : public BaseCommand
+{
+protected:
+ p<string> command ;
+
+public:
+ const static unsigned char TYPE = 14;
+
+public:
+ ControlCommand() ;
+ virtual ~ControlCommand() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<string> getCommand() ;
+ virtual void setCommand(p<string> command) ;
+
+ 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_ControlCommand_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/DataArrayResponse.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for DataArrayResponse
+ *
+ *
+ * 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
+ *
+ */
+DataArrayResponse::DataArrayResponse()
+{
+ this->data = NULL ;
+}
+
+DataArrayResponse::~DataArrayResponse()
+{
+}
+
+unsigned char DataArrayResponse::getDataStructureType()
+{
+ return DataArrayResponse::TYPE ;
+}
+
+
+array<IDataStructure> DataArrayResponse::getData()
+{
+ return data ;
+}
+
+void DataArrayResponse::setData(array<IDataStructure> data)
+{
+ this->data = data ;
+}
+
+int DataArrayResponse::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->marshalObjectArray(data, mode, writer) ;
+ return size ;
+}
+
+void DataArrayResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ data = array_cast<IDataStructure>(marshaller->unmarshalObjectArray(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +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.
+*/
+#ifndef ActiveMQ_DataArrayResponse_hpp_
+#define ActiveMQ_DataArrayResponse_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/Response.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 DataArrayResponse
+ *
+ *
+ * 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 DataArrayResponse : public Response
+{
+protected:
+ array<IDataStructure> data ;
+
+public:
+ const static unsigned char TYPE = 33;
+
+public:
+ DataArrayResponse() ;
+ virtual ~DataArrayResponse() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual array<IDataStructure> getData() ;
+ virtual void setData(array<IDataStructure> data) ;
+
+ 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_DataArrayResponse_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/DataResponse.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for DataResponse
+ *
+ *
+ * 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
+ *
+ */
+DataResponse::DataResponse()
+{
+ this->data = NULL ;
+}
+
+DataResponse::~DataResponse()
+{
+}
+
+unsigned char DataResponse::getDataStructureType()
+{
+ return DataResponse::TYPE ;
+}
+
+
+p<IDataStructure> DataResponse::getData()
+{
+ return data ;
+}
+
+void DataResponse::setData(p<IDataStructure> data)
+{
+ this->data = data ;
+}
+
+int DataResponse::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(data, mode, writer) ;
+ return size ;
+}
+
+void DataResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ data = p_cast<IDataStructure>(marshaller->unmarshalObject(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +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.
+*/
+#ifndef ActiveMQ_DataResponse_hpp_
+#define ActiveMQ_DataResponse_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/Response.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 DataResponse
+ *
+ *
+ * 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 DataResponse : public Response
+{
+protected:
+ p<IDataStructure> data ;
+
+public:
+ const static unsigned char TYPE = 32;
+
+public:
+ DataResponse() ;
+ virtual ~DataResponse() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<IDataStructure> getData() ;
+ virtual void setData(p<IDataStructure> data) ;
+
+ 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_DataResponse_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,127 @@
+/*
+* 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/DestinationInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for DestinationInfo
+ *
+ *
+ * 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
+ *
+ */
+DestinationInfo::DestinationInfo()
+{
+ this->connectionId = NULL ;
+ this->destination = NULL ;
+ this->operationType = 0 ;
+ this->timeout = 0 ;
+ this->brokerPath = NULL ;
+}
+
+DestinationInfo::~DestinationInfo()
+{
+}
+
+unsigned char DestinationInfo::getDataStructureType()
+{
+ return DestinationInfo::TYPE ;
+}
+
+
+p<ConnectionId> DestinationInfo::getConnectionId()
+{
+ return connectionId ;
+}
+
+void DestinationInfo::setConnectionId(p<ConnectionId> connectionId)
+{
+ this->connectionId = connectionId ;
+}
+
+
+p<ActiveMQDestination> DestinationInfo::getDestination()
+{
+ return destination ;
+}
+
+void DestinationInfo::setDestination(p<ActiveMQDestination> destination)
+{
+ this->destination = destination ;
+}
+
+
+char DestinationInfo::getOperationType()
+{
+ return operationType ;
+}
+
+void DestinationInfo::setOperationType(char operationType)
+{
+ this->operationType = operationType ;
+}
+
+
+long long DestinationInfo::getTimeout()
+{
+ return timeout ;
+}
+
+void DestinationInfo::setTimeout(long long timeout)
+{
+ this->timeout = timeout ;
+}
+
+
+array<BrokerId> DestinationInfo::getBrokerPath()
+{
+ return brokerPath ;
+}
+
+void DestinationInfo::setBrokerPath(array<BrokerId> brokerPath)
+{
+ this->brokerPath = brokerPath ;
+}
+
+int DestinationInfo::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(connectionId, mode, writer) ;
+ size += marshaller->marshalObject(destination, mode, writer) ;
+ size += marshaller->marshalByte(operationType, mode, writer) ;
+ size += marshaller->marshalLong(timeout, mode, writer) ;
+ size += marshaller->marshalObjectArray(brokerPath, mode, writer) ;
+ return size ;
+}
+
+void DestinationInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, reader)) ;
+ destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, reader)) ;
+ operationType = (marshaller->unmarshalByte(mode, reader)) ;
+ timeout = (marshaller->unmarshalLong(mode, reader)) ;
+ brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,101 @@
+/*
+* 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_DestinationInfo_hpp_
+#define ActiveMQ_DestinationInfo_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/ConnectionId.hpp"
+#include "activemq/command/ActiveMQDestination.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 DestinationInfo
+ *
+ *
+ * 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 DestinationInfo : public BaseCommand
+{
+protected:
+ p<ConnectionId> connectionId ;
+ p<ActiveMQDestination> destination ;
+ char operationType ;
+ long long timeout ;
+ array<BrokerId> brokerPath ;
+
+public:
+ const static unsigned char TYPE = 8;
+
+public:
+ DestinationInfo() ;
+ virtual ~DestinationInfo() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<ConnectionId> getConnectionId() ;
+ virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual char getOperationType() ;
+ virtual void setOperationType(char operationType) ;
+
+ virtual long long getTimeout() ;
+ virtual void setTimeout(long long timeout) ;
+
+ virtual array<BrokerId> getBrokerPath() ;
+ virtual void setBrokerPath(array<BrokerId> brokerPath) ;
+
+ 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_DestinationInfo_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,85 @@
+/*
+* 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/DiscoveryEvent.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for DiscoveryEvent
+ *
+ *
+ * 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
+ *
+ */
+DiscoveryEvent::DiscoveryEvent()
+{
+ this->serviceName = NULL ;
+ this->brokerName = NULL ;
+}
+
+DiscoveryEvent::~DiscoveryEvent()
+{
+}
+
+unsigned char DiscoveryEvent::getDataStructureType()
+{
+ return DiscoveryEvent::TYPE ;
+}
+
+
+p<string> DiscoveryEvent::getServiceName()
+{
+ return serviceName ;
+}
+
+void DiscoveryEvent::setServiceName(p<string> serviceName)
+{
+ this->serviceName = serviceName ;
+}
+
+
+p<string> DiscoveryEvent::getBrokerName()
+{
+ return brokerName ;
+}
+
+void DiscoveryEvent::setBrokerName(p<string> brokerName)
+{
+ this->brokerName = brokerName ;
+}
+
+int DiscoveryEvent::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->marshalString(serviceName, mode, writer) ;
+ size += marshaller->marshalString(brokerName, mode, writer) ;
+ return size ;
+}
+
+void DiscoveryEvent::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ serviceName = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
+ brokerName = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,86 @@
+/*
+* 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_DiscoveryEvent_hpp_
+#define ActiveMQ_DiscoveryEvent_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 DiscoveryEvent
+ *
+ *
+ * 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 DiscoveryEvent : public AbstractCommand
+{
+protected:
+ p<string> serviceName ;
+ p<string> brokerName ;
+
+public:
+ const static unsigned char TYPE = 40;
+
+public:
+ DiscoveryEvent() ;
+ virtual ~DiscoveryEvent() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<string> getServiceName() ;
+ virtual void setServiceName(p<string> serviceName) ;
+
+ virtual p<string> getBrokerName() ;
+ virtual void setBrokerName(p<string> brokerName) ;
+
+ 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_DiscoveryEvent_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/ExceptionResponse.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ExceptionResponse
+ *
+ *
+ * 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
+ *
+ */
+ExceptionResponse::ExceptionResponse()
+{
+ this->exception = NULL ;
+}
+
+ExceptionResponse::~ExceptionResponse()
+{
+}
+
+unsigned char ExceptionResponse::getDataStructureType()
+{
+ return ExceptionResponse::TYPE ;
+}
+
+
+p<BrokerError> ExceptionResponse::getException()
+{
+ return exception ;
+}
+
+void ExceptionResponse::setException(p<BrokerError> exception)
+{
+ this->exception = exception ;
+}
+
+int ExceptionResponse::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(exception, mode, writer) ;
+ return size ;
+}
+
+void ExceptionResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ exception = p_cast<BrokerError>(marshaller->unmarshalObject(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +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.
+*/
+#ifndef ActiveMQ_ExceptionResponse_hpp_
+#define ActiveMQ_ExceptionResponse_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/Response.hpp"
+#include "activemq/command/BrokerError.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 ExceptionResponse
+ *
+ *
+ * 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 ExceptionResponse : public Response
+{
+protected:
+ p<BrokerError> exception ;
+
+public:
+ const static unsigned char TYPE = 31;
+
+public:
+ ExceptionResponse() ;
+ virtual ~ExceptionResponse() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<BrokerError> getException() ;
+ virtual void setException(p<BrokerError> exception) ;
+
+ 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_ExceptionResponse_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,57 @@
+/*
+* 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/FlushCommand.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for FlushCommand
+ *
+ *
+ * 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
+ *
+ */
+FlushCommand::FlushCommand()
+{
+}
+
+FlushCommand::~FlushCommand()
+{
+}
+
+unsigned char FlushCommand::getDataStructureType()
+{
+ return FlushCommand::TYPE ;
+}
+
+int FlushCommand::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 FlushCommand::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,78 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_FlushCommand_hpp_
+#define ActiveMQ_FlushCommand_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;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for FlushCommand
+ *
+ *
+ * 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 FlushCommand : public BaseCommand
+{
+protected:
+
+public:
+ const static unsigned char TYPE = 15;
+
+public:
+ FlushCommand() ;
+ virtual ~FlushCommand() ;
+
+ 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_FlushCommand_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/IntegerResponse.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for IntegerResponse
+ *
+ *
+ * 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
+ *
+ */
+IntegerResponse::IntegerResponse()
+{
+ this->result = 0 ;
+}
+
+IntegerResponse::~IntegerResponse()
+{
+}
+
+unsigned char IntegerResponse::getDataStructureType()
+{
+ return IntegerResponse::TYPE ;
+}
+
+
+int IntegerResponse::getResult()
+{
+ return result ;
+}
+
+void IntegerResponse::setResult(int result)
+{
+ this->result = result ;
+}
+
+int IntegerResponse::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->marshalInt(result, mode, writer) ;
+ return size ;
+}
+
+void IntegerResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ result = (marshaller->unmarshalInt(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,82 @@
+/*
+* 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_IntegerResponse_hpp_
+#define ActiveMQ_IntegerResponse_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/Response.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 IntegerResponse
+ *
+ *
+ * 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 IntegerResponse : public Response
+{
+protected:
+ int result ;
+
+public:
+ const static unsigned char TYPE = 34;
+
+public:
+ IntegerResponse() ;
+ virtual ~IntegerResponse() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual int getResult() ;
+ virtual void setResult(int result) ;
+
+ 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_IntegerResponse_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,85 @@
+/*
+* 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/JournalQueueAck.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for JournalQueueAck
+ *
+ *
+ * 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
+ *
+ */
+JournalQueueAck::JournalQueueAck()
+{
+ this->destination = NULL ;
+ this->messageAck = NULL ;
+}
+
+JournalQueueAck::~JournalQueueAck()
+{
+}
+
+unsigned char JournalQueueAck::getDataStructureType()
+{
+ return JournalQueueAck::TYPE ;
+}
+
+
+p<ActiveMQDestination> JournalQueueAck::getDestination()
+{
+ return destination ;
+}
+
+void JournalQueueAck::setDestination(p<ActiveMQDestination> destination)
+{
+ this->destination = destination ;
+}
+
+
+p<MessageAck> JournalQueueAck::getMessageAck()
+{
+ return messageAck ;
+}
+
+void JournalQueueAck::setMessageAck(p<MessageAck> messageAck)
+{
+ this->messageAck = messageAck ;
+}
+
+int JournalQueueAck::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(messageAck, mode, writer) ;
+ return size ;
+}
+
+void JournalQueueAck::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)) ;
+ messageAck = p_cast<MessageAck>(marshaller->unmarshalObject(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +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_JournalQueueAck_hpp_
+#define ActiveMQ_JournalQueueAck_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/ActiveMQDestination.hpp"
+#include "activemq/command/MessageAck.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 JournalQueueAck
+ *
+ *
+ * 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 JournalQueueAck : public AbstractCommand
+{
+protected:
+ p<ActiveMQDestination> destination ;
+ p<MessageAck> messageAck ;
+
+public:
+ const static unsigned char TYPE = 52;
+
+public:
+ JournalQueueAck() ;
+ virtual ~JournalQueueAck() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual p<MessageAck> getMessageAck() ;
+ virtual void setMessageAck(p<MessageAck> messageAck) ;
+
+ 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_JournalQueueAck_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,141 @@
+/*
+* 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/JournalTopicAck.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for JournalTopicAck
+ *
+ *
+ * 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
+ *
+ */
+JournalTopicAck::JournalTopicAck()
+{
+ this->destination = NULL ;
+ this->messageId = NULL ;
+ this->messageSequenceId = 0 ;
+ this->subscritionName = NULL ;
+ this->clientId = NULL ;
+ this->transactionId = NULL ;
+}
+
+JournalTopicAck::~JournalTopicAck()
+{
+}
+
+unsigned char JournalTopicAck::getDataStructureType()
+{
+ return JournalTopicAck::TYPE ;
+}
+
+
+p<ActiveMQDestination> JournalTopicAck::getDestination()
+{
+ return destination ;
+}
+
+void JournalTopicAck::setDestination(p<ActiveMQDestination> destination)
+{
+ this->destination = destination ;
+}
+
+
+p<MessageId> JournalTopicAck::getMessageId()
+{
+ return messageId ;
+}
+
+void JournalTopicAck::setMessageId(p<MessageId> messageId)
+{
+ this->messageId = messageId ;
+}
+
+
+long long JournalTopicAck::getMessageSequenceId()
+{
+ return messageSequenceId ;
+}
+
+void JournalTopicAck::setMessageSequenceId(long long messageSequenceId)
+{
+ this->messageSequenceId = messageSequenceId ;
+}
+
+
+p<string> JournalTopicAck::getSubscritionName()
+{
+ return subscritionName ;
+}
+
+void JournalTopicAck::setSubscritionName(p<string> subscritionName)
+{
+ this->subscritionName = subscritionName ;
+}
+
+
+p<string> JournalTopicAck::getClientId()
+{
+ return clientId ;
+}
+
+void JournalTopicAck::setClientId(p<string> clientId)
+{
+ this->clientId = clientId ;
+}
+
+
+p<TransactionId> JournalTopicAck::getTransactionId()
+{
+ return transactionId ;
+}
+
+void JournalTopicAck::setTransactionId(p<TransactionId> transactionId)
+{
+ this->transactionId = transactionId ;
+}
+
+int JournalTopicAck::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(messageId, mode, writer) ;
+ size += marshaller->marshalLong(messageSequenceId, mode, writer) ;
+ size += marshaller->marshalString(subscritionName, mode, writer) ;
+ size += marshaller->marshalString(clientId, mode, writer) ;
+ size += marshaller->marshalObject(transactionId, mode, writer) ;
+ return size ;
+}
+
+void JournalTopicAck::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)) ;
+ messageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, reader)) ;
+ messageSequenceId = (marshaller->unmarshalLong(mode, reader)) ;
+ subscritionName = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
+ clientId = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
+ transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,105 @@
+/*
+* 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_JournalTopicAck_hpp_
+#define ActiveMQ_JournalTopicAck_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/ActiveMQDestination.hpp"
+#include "activemq/command/MessageId.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 JournalTopicAck
+ *
+ *
+ * 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 JournalTopicAck : public AbstractCommand
+{
+protected:
+ p<ActiveMQDestination> destination ;
+ p<MessageId> messageId ;
+ long long messageSequenceId ;
+ p<string> subscritionName ;
+ p<string> clientId ;
+ p<TransactionId> transactionId ;
+
+public:
+ const static unsigned char TYPE = 50;
+
+public:
+ JournalTopicAck() ;
+ virtual ~JournalTopicAck() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual p<MessageId> getMessageId() ;
+ virtual void setMessageId(p<MessageId> messageId) ;
+
+ virtual long long getMessageSequenceId() ;
+ virtual void setMessageSequenceId(long long messageSequenceId) ;
+
+ virtual p<string> getSubscritionName() ;
+ virtual void setSubscritionName(p<string> subscritionName) ;
+
+ virtual p<string> getClientId() ;
+ virtual void setClientId(p<string> clientId) ;
+
+ virtual p<TransactionId> getTransactionId() ;
+ virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+ 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_JournalTopicAck_hpp_*/
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "activemq/command/JournalTrace.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ * 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
+ *
+ */
+JournalTrace::JournalTrace()
+{
+ this->message = NULL ;
+}
+
+JournalTrace::~JournalTrace()
+{
+}
+
+unsigned char JournalTrace::getDataStructureType()
+{
+ return JournalTrace::TYPE ;
+}
+
+
+p<string> JournalTrace::getMessage()
+{
+ return message ;
+}
+
+void JournalTrace::setMessage(p<string> message)
+{
+ this->message = message ;
+}
+
+int JournalTrace::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->marshalString(message, mode, writer) ;
+ return size ;
+}
+
+void JournalTrace::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+ commandId = marshaller->unmarshalInt(mode, reader) ;
+ responseRequired = marshaller->unmarshalBoolean(mode, reader) ;
+ message = p_cast<string>(marshaller->unmarshalString(mode, reader)) ;
+}
Added: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.hpp?rev=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,82 @@
+/*
+* 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_JournalTrace_hpp_
+#define ActiveMQ_JournalTrace_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 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
+ *
+ */
+class JournalTrace : public AbstractCommand
+{
+protected:
+ p<string> message ;
+
+public:
+ const static unsigned char TYPE = 53;
+
+public:
+ JournalTrace() ;
+ virtual ~JournalTrace() ;
+
+ virtual unsigned char getDataStructureType() ;
+
+ virtual p<string> getMessage() ;
+ virtual void setMessage(p<string> message) ;
+
+ 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_JournalTrace_hpp_*/
Added: 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=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,99 @@
+/*
+* 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)) ;
+}
Added: 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=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.hpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,91 @@
+/*
+* 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_*/
Added: 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=397654&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp Thu Apr 27 14:59:28 2006
@@ -0,0 +1,57 @@
+/*
+* 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) ;
+}