activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r419422 [5/11] - in /incubator/activemq/trunk/openwire-cpp/src/main/cpp: activemq/ activemq/command/ activemq/protocol/openwire/ activemq/transport/ activemq/transport/tcp/ cms/ ppr/ ppr/io/ ppr/io/encoding/ ppr/net/ ppr/thread/ ppr/util/
Date Thu, 06 Jul 2006 03:18:03 GMT
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp Wed Jul  5 20:17:58 2006
@@ -1,293 +1,293 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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->maximumPendingMessageLimit = 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->additionalPredicate = NULL ;
-    this->networkSubscription = false ;
-    this->optimizedAcknowledge = false ;
-    this->noRangeAcks = 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 ;
-}
-
-        
-int ConsumerInfo::getMaximumPendingMessageLimit()
-{
-    return maximumPendingMessageLimit ;
-}
-
-void ConsumerInfo::setMaximumPendingMessageLimit(int maximumPendingMessageLimit)
-{
-    this->maximumPendingMessageLimit = maximumPendingMessageLimit ;
-}
-
-        
-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 ;
-}
-
-        
-p<BooleanExpression> ConsumerInfo::getAdditionalPredicate()
-{
-    return additionalPredicate ;
-}
-
-void ConsumerInfo::setAdditionalPredicate(p<BooleanExpression> additionalPredicate)
-{
-    this->additionalPredicate = additionalPredicate ;
-}
-
-        
-bool ConsumerInfo::getNetworkSubscription()
-{
-    return networkSubscription ;
-}
-
-void ConsumerInfo::setNetworkSubscription(bool networkSubscription)
-{
-    this->networkSubscription = networkSubscription ;
-}
-
-        
-bool ConsumerInfo::getOptimizedAcknowledge()
-{
-    return optimizedAcknowledge ;
-}
-
-void ConsumerInfo::setOptimizedAcknowledge(bool optimizedAcknowledge)
-{
-    this->optimizedAcknowledge = optimizedAcknowledge ;
-}
-
-        
-bool ConsumerInfo::getNoRangeAcks()
-{
-    return noRangeAcks ;
-}
-
-void ConsumerInfo::setNoRangeAcks(bool noRangeAcks)
-{
-    this->noRangeAcks = noRangeAcks ;
-}
-
-int ConsumerInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObject(consumerId, mode, ostream) ; 
-    size += marshaller->marshalBoolean(browser, mode, ostream) ; 
-    size += marshaller->marshalObject(destination, mode, ostream) ; 
-    size += marshaller->marshalInt(prefetchSize, mode, ostream) ; 
-    size += marshaller->marshalInt(maximumPendingMessageLimit, mode, ostream) ; 
-    size += marshaller->marshalBoolean(dispatchAsync, mode, ostream) ; 
-    size += marshaller->marshalString(selector, mode, ostream) ; 
-    size += marshaller->marshalString(subcriptionName, mode, ostream) ; 
-    size += marshaller->marshalBoolean(noLocal, mode, ostream) ; 
-    size += marshaller->marshalBoolean(exclusive, mode, ostream) ; 
-    size += marshaller->marshalBoolean(retroactive, mode, ostream) ; 
-    size += marshaller->marshalByte(priority, mode, ostream) ; 
-    size += marshaller->marshalObjectArray(brokerPath, mode, ostream) ; 
-    size += marshaller->marshalObject(additionalPredicate, mode, ostream) ; 
-    size += marshaller->marshalBoolean(networkSubscription, mode, ostream) ; 
-    size += marshaller->marshalBoolean(optimizedAcknowledge, mode, ostream) ; 
-    size += marshaller->marshalBoolean(noRangeAcks, mode, ostream) ; 
-    return size ;
-}
-
-void ConsumerInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-    consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, istream)) ; 
-    browser = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ; 
-    prefetchSize = (marshaller->unmarshalInt(mode, istream)) ; 
-    maximumPendingMessageLimit = (marshaller->unmarshalInt(mode, istream)) ; 
-    dispatchAsync = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    selector = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    subcriptionName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    noLocal = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    exclusive = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    retroactive = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    priority = (marshaller->unmarshalByte(mode, istream)) ; 
-    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, istream)) ; 
-    additionalPredicate = p_cast<BooleanExpression>(marshaller->unmarshalObject(mode, istream)) ; 
-    networkSubscription = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    optimizedAcknowledge = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    noRangeAcks = (marshaller->unmarshalBoolean(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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->maximumPendingMessageLimit = 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->additionalPredicate = NULL ;
+    this->networkSubscription = false ;
+    this->optimizedAcknowledge = false ;
+    this->noRangeAcks = 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 ;
+}
+
+        
+int ConsumerInfo::getMaximumPendingMessageLimit()
+{
+    return maximumPendingMessageLimit ;
+}
+
+void ConsumerInfo::setMaximumPendingMessageLimit(int maximumPendingMessageLimit)
+{
+    this->maximumPendingMessageLimit = maximumPendingMessageLimit ;
+}
+
+        
+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 ;
+}
+
+        
+p<BooleanExpression> ConsumerInfo::getAdditionalPredicate()
+{
+    return additionalPredicate ;
+}
+
+void ConsumerInfo::setAdditionalPredicate(p<BooleanExpression> additionalPredicate)
+{
+    this->additionalPredicate = additionalPredicate ;
+}
+
+        
+bool ConsumerInfo::getNetworkSubscription()
+{
+    return networkSubscription ;
+}
+
+void ConsumerInfo::setNetworkSubscription(bool networkSubscription)
+{
+    this->networkSubscription = networkSubscription ;
+}
+
+        
+bool ConsumerInfo::getOptimizedAcknowledge()
+{
+    return optimizedAcknowledge ;
+}
+
+void ConsumerInfo::setOptimizedAcknowledge(bool optimizedAcknowledge)
+{
+    this->optimizedAcknowledge = optimizedAcknowledge ;
+}
+
+        
+bool ConsumerInfo::getNoRangeAcks()
+{
+    return noRangeAcks ;
+}
+
+void ConsumerInfo::setNoRangeAcks(bool noRangeAcks)
+{
+    this->noRangeAcks = noRangeAcks ;
+}
+
+int ConsumerInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObject(consumerId, mode, ostream) ; 
+    size += marshaller->marshalBoolean(browser, mode, ostream) ; 
+    size += marshaller->marshalObject(destination, mode, ostream) ; 
+    size += marshaller->marshalInt(prefetchSize, mode, ostream) ; 
+    size += marshaller->marshalInt(maximumPendingMessageLimit, mode, ostream) ; 
+    size += marshaller->marshalBoolean(dispatchAsync, mode, ostream) ; 
+    size += marshaller->marshalString(selector, mode, ostream) ; 
+    size += marshaller->marshalString(subcriptionName, mode, ostream) ; 
+    size += marshaller->marshalBoolean(noLocal, mode, ostream) ; 
+    size += marshaller->marshalBoolean(exclusive, mode, ostream) ; 
+    size += marshaller->marshalBoolean(retroactive, mode, ostream) ; 
+    size += marshaller->marshalByte(priority, mode, ostream) ; 
+    size += marshaller->marshalObjectArray(brokerPath, mode, ostream) ; 
+    size += marshaller->marshalObject(additionalPredicate, mode, ostream) ; 
+    size += marshaller->marshalBoolean(networkSubscription, mode, ostream) ; 
+    size += marshaller->marshalBoolean(optimizedAcknowledge, mode, ostream) ; 
+    size += marshaller->marshalBoolean(noRangeAcks, mode, ostream) ; 
+    return size ;
+}
+
+void ConsumerInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+    consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, istream)) ; 
+    browser = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ; 
+    prefetchSize = (marshaller->unmarshalInt(mode, istream)) ; 
+    maximumPendingMessageLimit = (marshaller->unmarshalInt(mode, istream)) ; 
+    dispatchAsync = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    selector = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    subcriptionName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    noLocal = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    exclusive = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    retroactive = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    priority = (marshaller->unmarshalByte(mode, istream)) ; 
+    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, istream)) ; 
+    additionalPredicate = p_cast<BooleanExpression>(marshaller->unmarshalObject(mode, istream)) ; 
+    networkSubscription = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    optimizedAcknowledge = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    noRangeAcks = (marshaller->unmarshalBoolean(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp Wed Jul  5 20:17:58 2006
@@ -1,69 +1,69 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalString(command, mode, ostream) ; 
-    return size ;
-}
-
-void ControlCommand::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-    command = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalString(command, mode, ostream) ; 
+    return size ;
+}
+
+void ControlCommand::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+    command = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ControlCommand.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp Wed Jul  5 20:17:58 2006
@@ -1,69 +1,69 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += Response::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObjectArray(data, mode, ostream) ; 
-    return size ;
-}
-
-void DataArrayResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    Response::unmarshal(marshaller, mode, istream) ; 
-    data = array_cast<IDataStructure>(marshaller->unmarshalObjectArray(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += Response::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObjectArray(data, mode, ostream) ; 
+    return size ;
+}
+
+void DataArrayResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    Response::unmarshal(marshaller, mode, istream) ; 
+    data = array_cast<IDataStructure>(marshaller->unmarshalObjectArray(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataArrayResponse.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp Wed Jul  5 20:17:58 2006
@@ -1,69 +1,69 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += Response::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObject(data, mode, ostream) ; 
-    return size ;
-}
-
-void DataResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    Response::unmarshal(marshaller, mode, istream) ; 
-    data = p_cast<IDataStructure>(marshaller->unmarshalObject(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += Response::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObject(data, mode, ostream) ; 
+    return size ;
+}
+
+void DataResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    Response::unmarshal(marshaller, mode, istream) ; 
+    data = p_cast<IDataStructure>(marshaller->unmarshalObject(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DataResponse.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp Wed Jul  5 20:17:58 2006
@@ -1,125 +1,125 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObject(connectionId, mode, ostream) ; 
-    size += marshaller->marshalObject(destination, mode, ostream) ; 
-    size += marshaller->marshalByte(operationType, mode, ostream) ; 
-    size += marshaller->marshalLong(timeout, mode, ostream) ; 
-    size += marshaller->marshalObjectArray(brokerPath, mode, ostream) ; 
-    return size ;
-}
-
-void DestinationInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-    connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, istream)) ; 
-    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ; 
-    operationType = (marshaller->unmarshalByte(mode, istream)) ; 
-    timeout = (marshaller->unmarshalLong(mode, istream)) ; 
-    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObject(connectionId, mode, ostream) ; 
+    size += marshaller->marshalObject(destination, mode, ostream) ; 
+    size += marshaller->marshalByte(operationType, mode, ostream) ; 
+    size += marshaller->marshalLong(timeout, mode, ostream) ; 
+    size += marshaller->marshalObjectArray(brokerPath, mode, ostream) ; 
+    return size ;
+}
+
+void DestinationInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+    connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, istream)) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ; 
+    operationType = (marshaller->unmarshalByte(mode, istream)) ; 
+    timeout = (marshaller->unmarshalLong(mode, istream)) ; 
+    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DestinationInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp Wed Jul  5 20:17:58 2006
@@ -1,83 +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/DiscoveryEvent.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalString(serviceName, mode, ostream) ; 
-    size += marshaller->marshalString(brokerName, mode, ostream) ; 
-    return size ;
-}
-
-void DiscoveryEvent::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
-    serviceName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    brokerName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalString(serviceName, mode, ostream) ; 
+    size += marshaller->marshalString(brokerName, mode, ostream) ; 
+    return size ;
+}
+
+void DiscoveryEvent::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
+    serviceName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    brokerName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/DiscoveryEvent.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp Wed Jul  5 20:17:58 2006
@@ -1,69 +1,69 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += Response::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObject(exception, mode, ostream) ; 
-    return size ;
-}
-
-void ExceptionResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    Response::unmarshal(marshaller, mode, istream) ; 
-    exception = p_cast<BrokerError>(marshaller->unmarshalObject(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += Response::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObject(exception, mode, ostream) ; 
+    return size ;
+}
+
+void ExceptionResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    Response::unmarshal(marshaller, mode, istream) ; 
+    exception = p_cast<BrokerError>(marshaller->unmarshalObject(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ExceptionResponse.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp Wed Jul  5 20:17:58 2006
@@ -1,55 +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/FlushCommand.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
-    return size ;
-}
-
-void FlushCommand::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
+    return size ;
+}
+
+void FlushCommand::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/FlushCommand.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp Wed Jul  5 20:17:58 2006
@@ -1,69 +1,69 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += Response::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalInt(result, mode, ostream) ; 
-    return size ;
-}
-
-void IntegerResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    Response::unmarshal(marshaller, mode, istream) ; 
-    result = (marshaller->unmarshalInt(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += Response::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalInt(result, mode, ostream) ; 
+    return size ;
+}
+
+void IntegerResponse::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    Response::unmarshal(marshaller, mode, istream) ; 
+    result = (marshaller->unmarshalInt(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/IntegerResponse.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp Wed Jul  5 20:17:58 2006
@@ -1,83 +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/JournalQueueAck.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObject(destination, mode, ostream) ; 
-    size += marshaller->marshalObject(messageAck, mode, ostream) ; 
-    return size ;
-}
-
-void JournalQueueAck::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
-    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ; 
-    messageAck = p_cast<MessageAck>(marshaller->unmarshalObject(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObject(destination, mode, ostream) ; 
+    size += marshaller->marshalObject(messageAck, mode, ostream) ; 
+    return size ;
+}
+
+void JournalQueueAck::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ; 
+    messageAck = p_cast<MessageAck>(marshaller->unmarshalObject(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalQueueAck.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp Wed Jul  5 20:17:58 2006
@@ -1,139 +1,139 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObject(destination, mode, ostream) ; 
-    size += marshaller->marshalObject(messageId, mode, ostream) ; 
-    size += marshaller->marshalLong(messageSequenceId, mode, ostream) ; 
-    size += marshaller->marshalString(subscritionName, mode, ostream) ; 
-    size += marshaller->marshalString(clientId, mode, ostream) ; 
-    size += marshaller->marshalObject(transactionId, mode, ostream) ; 
-    return size ;
-}
-
-void JournalTopicAck::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
-    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ; 
-    messageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, istream)) ; 
-    messageSequenceId = (marshaller->unmarshalLong(mode, istream)) ; 
-    subscritionName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    clientId = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObject(destination, mode, ostream) ; 
+    size += marshaller->marshalObject(messageId, mode, ostream) ; 
+    size += marshaller->marshalLong(messageSequenceId, mode, ostream) ; 
+    size += marshaller->marshalString(subscritionName, mode, ostream) ; 
+    size += marshaller->marshalString(clientId, mode, ostream) ; 
+    size += marshaller->marshalObject(transactionId, mode, ostream) ; 
+    return size ;
+}
+
+void JournalTopicAck::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
+    destination = p_cast<ActiveMQDestination>(marshaller->unmarshalObject(mode, istream)) ; 
+    messageId = p_cast<MessageId>(marshaller->unmarshalObject(mode, istream)) ; 
+    messageSequenceId = (marshaller->unmarshalLong(mode, istream)) ; 
+    subscritionName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    clientId = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    transactionId = p_cast<TransactionId>(marshaller->unmarshalObject(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTopicAck.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp Wed Jul  5 20:17:58 2006
@@ -1,69 +1,69 @@
-/*
-* 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;
-
-/*
- *
- *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalString(message, mode, ostream) ; 
-    return size ;
-}
-
-void JournalTrace::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
-    message = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-}
+/*
+* 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;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire 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> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalString(message, mode, ostream) ; 
+    return size ;
+}
+
+void JournalTrace::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
+    message = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTrace.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp?rev=419422&r1=419421&r2=419422&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 Wed Jul  5 20:17:58 2006
@@ -1,97 +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;
-
-/*
- *
- *  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)) ; 
-}
+/*
+* 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)) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/JournalTransaction.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp?rev=419422&r1=419421&r2=419422&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 Wed Jul  5 20:17:58 2006
@@ -1,55 +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;
-
-/*
- *
- *  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) ; 
-}
+/*
+* 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) ; 
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/KeepAliveInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message