activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r419422 [4/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/BaseDataStructure.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseDataStructure.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseDataStructure.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BaseDataStructure.cpp Wed Jul  5 20:17:58 2006
@@ -1,255 +1,255 @@
-/*
- * 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 <string.h>
-#include "activemq/command/BaseDataStructure.hpp"
-
-#include "activemq/command/ActiveMQMessage.hpp"
-#include "activemq/command/ActiveMQBytesMessage.hpp"
-#include "activemq/command/ActiveMQMapMessage.hpp"
-#include "activemq/command/ActiveMQObjectMessage.hpp"
-#include "activemq/command/ActiveMQStreamMessage.hpp"
-#include "activemq/command/ActiveMQTextMessage.hpp"
-#include "activemq/command/ActiveMQQueue.hpp"
-#include "activemq/command/ActiveMQTopic.hpp"
-#include "activemq/command/ActiveMQTempQueue.hpp"
-#include "activemq/command/ActiveMQTempTopic.hpp"
-#include "activemq/command/ExceptionResponse.hpp"
-#include "activemq/command/ConnectionId.hpp"
-#include "activemq/command/ConsumerId.hpp"
-#include "activemq/command/ProducerId.hpp"
-#include "activemq/command/MessageId.hpp"
-#include "activemq/command/LocalTransactionId.hpp"
-#include "activemq/command/MessageAck.hpp"
-#include "activemq/command/MessageDispatch.hpp"
-#include "activemq/command/Response.hpp"
-#include "activemq/command/ConsumerInfo.hpp"
-#include "activemq/command/IntegerResponse.hpp"
-#include "activemq/command/ProducerInfo.hpp"
-#include "activemq/command/BrokerInfo.hpp"
-#include "activemq/command/KeepAliveInfo.hpp"
-#include "activemq/command/ConnectionInfo.hpp"
-#include "activemq/command/RemoveInfo.hpp"
-#include "activemq/command/RemoveSubscriptionInfo.hpp"
-#include "activemq/command/SessionInfo.hpp"
-#include "activemq/command/TransactionInfo.hpp"
-#include "activemq/command/WireFormatInfo.hpp"
-#include "activemq/command/BrokerId.hpp"
-#include "activemq/command/ShutdownInfo.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- * 
- */
-unsigned char BaseDataStructure::getDataStructureType()
-{
-    return 0 ;
-}
-
-/*
- * 
- */
-int BaseDataStructure::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw(IOException)
-{
-    return 0 ;
-}
-
-/*
- * 
- */
-void BaseDataStructure::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw(IOException)
-{
-}
-
-/*
- * 
- */
-p<IDataStructure> BaseDataStructure::createObject(unsigned char type)
-{
-    switch( type )
-    {
-        case ActiveMQMessage::TYPE:
-            return new ActiveMQMessage() ;
-        case ActiveMQTextMessage::TYPE:
-            return new ActiveMQTextMessage() ;
-        case ActiveMQObjectMessage::TYPE:
-            return new ActiveMQObjectMessage() ;
-        case ActiveMQBytesMessage::TYPE:
-            return new ActiveMQBytesMessage() ;
-        case ActiveMQStreamMessage::TYPE:
-            return new ActiveMQStreamMessage() ;
-        case ActiveMQMapMessage::TYPE:
-            return new ActiveMQMapMessage() ;
-        case ActiveMQQueue::TYPE:
-            return new ActiveMQQueue() ;
-        case ActiveMQTopic::TYPE:
-            return new ActiveMQTopic() ;
-        case ActiveMQTempQueue::TYPE:
-            return new ActiveMQTempQueue() ;
-        case ActiveMQTempTopic::TYPE:
-            return new ActiveMQTempTopic() ;
-        case ExceptionResponse::TYPE:
-            return new ExceptionResponse() ;
-        case ConnectionId::TYPE:
-            return new ConnectionId() ;
-        case ConsumerId::TYPE:
-            return new ConsumerId() ;
-        case ProducerId::TYPE:
-            return new ProducerId() ;
-        case MessageId::TYPE:
-            return new MessageId() ;
-        case LocalTransactionId::TYPE:
-            return new LocalTransactionId() ;
-        case MessageAck::TYPE:
-            return new MessageAck() ;
-        case MessageDispatch::TYPE:
-            return new MessageDispatch() ;
-        case Response::TYPE:
-            return new Response() ;
-        case ConsumerInfo::TYPE:
-            return new ConsumerInfo() ;
-        case ProducerInfo::TYPE:
-            return new ProducerInfo() ;
-        case TransactionInfo::TYPE:
-            return new TransactionInfo() ;
-        case BrokerInfo::TYPE:
-            return new BrokerInfo() ;
-        case BrokerId::TYPE:
-            return new BrokerId() ;
-        case ConnectionInfo::TYPE:
-            return new ConnectionInfo() ;
-        case SessionInfo::TYPE:
-            return new SessionInfo() ;
-        case RemoveSubscriptionInfo::TYPE:
-            return new RemoveSubscriptionInfo() ;
-        case IntegerResponse::TYPE:
-            return new IntegerResponse() ;
-        case WireFormatInfo::TYPE:
-            return new WireFormatInfo() ;
-        case RemoveInfo::TYPE:
-            return new RemoveInfo() ;
-        case KeepAliveInfo::TYPE:
-            return new KeepAliveInfo() ;
-        case ShutdownInfo::TYPE:
-            return new ShutdownInfo() ;
-        default:
-            return NULL ;
-    }
- }
-
-/*
- * 
- */
-p<string> BaseDataStructure::getDataStructureTypeAsString(unsigned char type)
-{
-    p<string> packetType = new string() ;
-
-    switch( type )
-    {
-        case ActiveMQMessage::TYPE:
-            packetType->assign("ACTIVEMQ_MESSAGE") ;
-            break ;
-        case ActiveMQTextMessage::TYPE:
-            packetType->assign("ACTIVEMQ_TEXT_MESSAGE") ;
-            break ;
-        case ActiveMQObjectMessage::TYPE:
-            packetType->assign("ACTIVEMQ_OBJECT_MESSAGE") ;
-            break ;
-        case ActiveMQBytesMessage::TYPE:
-            packetType->assign("ACTIVEMQ_BYTES_MESSAGE") ;
-            break ;
-        case ActiveMQStreamMessage::TYPE:
-            packetType->assign("ACTIVEMQ_STREAM_MESSAGE") ;
-            break ;
-        case ActiveMQMapMessage::TYPE:
-            packetType->assign("ACTIVEMQ_MAP_MESSAGE") ;
-            break ;
-        case ActiveMQQueue::TYPE:
-            packetType->assign("ACTIVEMQ_QUEUE") ;
-            break ;
-        case ActiveMQTopic::TYPE:
-            packetType->assign("ACTIVEMQ_TOPIC") ;
-            break ;
-        case ConnectionId::TYPE:
-            packetType->assign("CONNECTION_ID") ;
-            break ;
-        case ConsumerId::TYPE:
-            packetType->assign("CONSUMER_ID") ;
-            break ;
-        case ProducerId::TYPE:
-            packetType->assign("PRODUCER_ID") ;
-            break ;
-        case MessageId::TYPE:
-            packetType->assign("MESSAGE_ID") ;
-            break ;
-        case LocalTransactionId::TYPE:
-            packetType->assign("LOCAL_TRANSACTION_ID") ;
-            break ;
-        case MessageAck::TYPE:
-            packetType->assign("ACTIVEMQ_MSG_ACK") ;
-            break ;
-        case MessageDispatch::TYPE:
-            packetType->assign("ACTIVEMQ_MSG_DISPATCH") ;
-            break ;
-        case Response::TYPE:
-            packetType->assign("RESPONSE") ;
-            break ;
-        case ExceptionResponse::TYPE:
-            packetType->assign("EXCEPTION_RESPONSE") ;
-            break ;
-        case ConsumerInfo::TYPE:
-            packetType->assign("CONSUMER_INFO") ;
-            break ;
-        case ProducerInfo::TYPE:
-            packetType->assign("PRODUCER_INFO") ;
-            break;
-        case TransactionInfo::TYPE:
-            packetType->assign("TRANSACTION_INFO") ;
-            break ;
-        case BrokerInfo::TYPE:
-            packetType->assign("BROKER_INFO") ;
-            break ;
-        case ConnectionInfo::TYPE:
-            packetType->assign("CONNECTION_INFO") ;
-            break ;
-        case SessionInfo::TYPE:
-            packetType->assign("SESSION_INFO") ;
-            break ;
-        case RemoveSubscriptionInfo::TYPE:
-            packetType->assign("DURABLE_UNSUBSCRIBE") ;
-            break ;
-        case IntegerResponse::TYPE:
-            packetType->assign("INT_RESPONSE_RECEIPT_INFO") ;
-            break ;
-        case WireFormatInfo::TYPE:
-            packetType->assign("WIRE_FORMAT_INFO") ;
-            break ;
-        case RemoveInfo::TYPE:
-            packetType->assign("REMOVE_INFO") ;
-            break ;
-        case KeepAliveInfo::TYPE:
-            packetType->assign("KEEP_ALIVE") ;
-            break ;
-        case ShutdownInfo::TYPE:
-            packetType->assign("SHUTDOWN") ;
-            break ;
-        default:
-            packetType->assign("UNDEFINED") ;
-            break ;
-    }
-    return packetType ;
-}
+/*
+ * 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 <string.h>
+#include "activemq/command/BaseDataStructure.hpp"
+
+#include "activemq/command/ActiveMQMessage.hpp"
+#include "activemq/command/ActiveMQBytesMessage.hpp"
+#include "activemq/command/ActiveMQMapMessage.hpp"
+#include "activemq/command/ActiveMQObjectMessage.hpp"
+#include "activemq/command/ActiveMQStreamMessage.hpp"
+#include "activemq/command/ActiveMQTextMessage.hpp"
+#include "activemq/command/ActiveMQQueue.hpp"
+#include "activemq/command/ActiveMQTopic.hpp"
+#include "activemq/command/ActiveMQTempQueue.hpp"
+#include "activemq/command/ActiveMQTempTopic.hpp"
+#include "activemq/command/ExceptionResponse.hpp"
+#include "activemq/command/ConnectionId.hpp"
+#include "activemq/command/ConsumerId.hpp"
+#include "activemq/command/ProducerId.hpp"
+#include "activemq/command/MessageId.hpp"
+#include "activemq/command/LocalTransactionId.hpp"
+#include "activemq/command/MessageAck.hpp"
+#include "activemq/command/MessageDispatch.hpp"
+#include "activemq/command/Response.hpp"
+#include "activemq/command/ConsumerInfo.hpp"
+#include "activemq/command/IntegerResponse.hpp"
+#include "activemq/command/ProducerInfo.hpp"
+#include "activemq/command/BrokerInfo.hpp"
+#include "activemq/command/KeepAliveInfo.hpp"
+#include "activemq/command/ConnectionInfo.hpp"
+#include "activemq/command/RemoveInfo.hpp"
+#include "activemq/command/RemoveSubscriptionInfo.hpp"
+#include "activemq/command/SessionInfo.hpp"
+#include "activemq/command/TransactionInfo.hpp"
+#include "activemq/command/WireFormatInfo.hpp"
+#include "activemq/command/BrokerId.hpp"
+#include "activemq/command/ShutdownInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+unsigned char BaseDataStructure::getDataStructureType()
+{
+    return 0 ;
+}
+
+/*
+ * 
+ */
+int BaseDataStructure::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw(IOException)
+{
+    return 0 ;
+}
+
+/*
+ * 
+ */
+void BaseDataStructure::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw(IOException)
+{
+}
+
+/*
+ * 
+ */
+p<IDataStructure> BaseDataStructure::createObject(unsigned char type)
+{
+    switch( type )
+    {
+        case ActiveMQMessage::TYPE:
+            return new ActiveMQMessage() ;
+        case ActiveMQTextMessage::TYPE:
+            return new ActiveMQTextMessage() ;
+        case ActiveMQObjectMessage::TYPE:
+            return new ActiveMQObjectMessage() ;
+        case ActiveMQBytesMessage::TYPE:
+            return new ActiveMQBytesMessage() ;
+        case ActiveMQStreamMessage::TYPE:
+            return new ActiveMQStreamMessage() ;
+        case ActiveMQMapMessage::TYPE:
+            return new ActiveMQMapMessage() ;
+        case ActiveMQQueue::TYPE:
+            return new ActiveMQQueue() ;
+        case ActiveMQTopic::TYPE:
+            return new ActiveMQTopic() ;
+        case ActiveMQTempQueue::TYPE:
+            return new ActiveMQTempQueue() ;
+        case ActiveMQTempTopic::TYPE:
+            return new ActiveMQTempTopic() ;
+        case ExceptionResponse::TYPE:
+            return new ExceptionResponse() ;
+        case ConnectionId::TYPE:
+            return new ConnectionId() ;
+        case ConsumerId::TYPE:
+            return new ConsumerId() ;
+        case ProducerId::TYPE:
+            return new ProducerId() ;
+        case MessageId::TYPE:
+            return new MessageId() ;
+        case LocalTransactionId::TYPE:
+            return new LocalTransactionId() ;
+        case MessageAck::TYPE:
+            return new MessageAck() ;
+        case MessageDispatch::TYPE:
+            return new MessageDispatch() ;
+        case Response::TYPE:
+            return new Response() ;
+        case ConsumerInfo::TYPE:
+            return new ConsumerInfo() ;
+        case ProducerInfo::TYPE:
+            return new ProducerInfo() ;
+        case TransactionInfo::TYPE:
+            return new TransactionInfo() ;
+        case BrokerInfo::TYPE:
+            return new BrokerInfo() ;
+        case BrokerId::TYPE:
+            return new BrokerId() ;
+        case ConnectionInfo::TYPE:
+            return new ConnectionInfo() ;
+        case SessionInfo::TYPE:
+            return new SessionInfo() ;
+        case RemoveSubscriptionInfo::TYPE:
+            return new RemoveSubscriptionInfo() ;
+        case IntegerResponse::TYPE:
+            return new IntegerResponse() ;
+        case WireFormatInfo::TYPE:
+            return new WireFormatInfo() ;
+        case RemoveInfo::TYPE:
+            return new RemoveInfo() ;
+        case KeepAliveInfo::TYPE:
+            return new KeepAliveInfo() ;
+        case ShutdownInfo::TYPE:
+            return new ShutdownInfo() ;
+        default:
+            return NULL ;
+    }
+ }
+
+/*
+ * 
+ */
+p<string> BaseDataStructure::getDataStructureTypeAsString(unsigned char type)
+{
+    p<string> packetType = new string() ;
+
+    switch( type )
+    {
+        case ActiveMQMessage::TYPE:
+            packetType->assign("ACTIVEMQ_MESSAGE") ;
+            break ;
+        case ActiveMQTextMessage::TYPE:
+            packetType->assign("ACTIVEMQ_TEXT_MESSAGE") ;
+            break ;
+        case ActiveMQObjectMessage::TYPE:
+            packetType->assign("ACTIVEMQ_OBJECT_MESSAGE") ;
+            break ;
+        case ActiveMQBytesMessage::TYPE:
+            packetType->assign("ACTIVEMQ_BYTES_MESSAGE") ;
+            break ;
+        case ActiveMQStreamMessage::TYPE:
+            packetType->assign("ACTIVEMQ_STREAM_MESSAGE") ;
+            break ;
+        case ActiveMQMapMessage::TYPE:
+            packetType->assign("ACTIVEMQ_MAP_MESSAGE") ;
+            break ;
+        case ActiveMQQueue::TYPE:
+            packetType->assign("ACTIVEMQ_QUEUE") ;
+            break ;
+        case ActiveMQTopic::TYPE:
+            packetType->assign("ACTIVEMQ_TOPIC") ;
+            break ;
+        case ConnectionId::TYPE:
+            packetType->assign("CONNECTION_ID") ;
+            break ;
+        case ConsumerId::TYPE:
+            packetType->assign("CONSUMER_ID") ;
+            break ;
+        case ProducerId::TYPE:
+            packetType->assign("PRODUCER_ID") ;
+            break ;
+        case MessageId::TYPE:
+            packetType->assign("MESSAGE_ID") ;
+            break ;
+        case LocalTransactionId::TYPE:
+            packetType->assign("LOCAL_TRANSACTION_ID") ;
+            break ;
+        case MessageAck::TYPE:
+            packetType->assign("ACTIVEMQ_MSG_ACK") ;
+            break ;
+        case MessageDispatch::TYPE:
+            packetType->assign("ACTIVEMQ_MSG_DISPATCH") ;
+            break ;
+        case Response::TYPE:
+            packetType->assign("RESPONSE") ;
+            break ;
+        case ExceptionResponse::TYPE:
+            packetType->assign("EXCEPTION_RESPONSE") ;
+            break ;
+        case ConsumerInfo::TYPE:
+            packetType->assign("CONSUMER_INFO") ;
+            break ;
+        case ProducerInfo::TYPE:
+            packetType->assign("PRODUCER_INFO") ;
+            break;
+        case TransactionInfo::TYPE:
+            packetType->assign("TRANSACTION_INFO") ;
+            break ;
+        case BrokerInfo::TYPE:
+            packetType->assign("BROKER_INFO") ;
+            break ;
+        case ConnectionInfo::TYPE:
+            packetType->assign("CONNECTION_INFO") ;
+            break ;
+        case SessionInfo::TYPE:
+            packetType->assign("SESSION_INFO") ;
+            break ;
+        case RemoveSubscriptionInfo::TYPE:
+            packetType->assign("DURABLE_UNSUBSCRIBE") ;
+            break ;
+        case IntegerResponse::TYPE:
+            packetType->assign("INT_RESPONSE_RECEIPT_INFO") ;
+            break ;
+        case WireFormatInfo::TYPE:
+            packetType->assign("WIRE_FORMAT_INFO") ;
+            break ;
+        case RemoveInfo::TYPE:
+            packetType->assign("REMOVE_INFO") ;
+            break ;
+        case KeepAliveInfo::TYPE:
+            packetType->assign("KEEP_ALIVE") ;
+            break ;
+        case ShutdownInfo::TYPE:
+            packetType->assign("SHUTDOWN") ;
+            break ;
+        default:
+            packetType->assign("UNDEFINED") ;
+            break ;
+    }
+    return packetType ;
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp Wed Jul  5 20:17:58 2006
@@ -1,126 +1,126 @@
-/*
- * 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/BrokerError.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- * 
- */
-BrokerError::BrokerError()
-{
-    message            = new string() ;
-    exceptionClass     = new string() ;
-    stackTraceElements = NULL ;
-    cause              = NULL ;
-}
-
-/*
- * 
- */
-p<string> BrokerError::getMessage()
-{
-    return message ;
-}
-
-/*
- * 
- */
-void BrokerError::setMessage(const char* msg)
-{
-    this->message->assign(msg) ;
-}
-
-/*
- * 
- */
-p<string> BrokerError::getExceptionClass()
-{
-    return exceptionClass ;
-}
-
-/*
- * 
- */
-void BrokerError::setExceptionClass(const char* exClass)
-{
-    this->exceptionClass->assign(exClass) ;
-}
-
-/*
- * 
- */
-array<StackTraceElement> BrokerError::getStackTraceElements()
-{
-    return stackTraceElements ;
-}
-
-/*
- * 
- */
-void BrokerError::setStackTraceElements(array<StackTraceElement> elements)
-{
-    this->stackTraceElements = elements ;
-}
-
-/*
- * 
- */
-p<BrokerError> BrokerError::getCause()
-{
-    return cause ;
-}
-
-/*
- * 
- */
-void BrokerError::setCause(p<BrokerError> cause)
-{
-    this->cause = cause ;
-}
-
-/*
- * 
- */
-p<string> BrokerError::getStackTrace()
-{
-    ostringstream sstream ;
-    p<string> trace ;
-    printStackTrace(sstream) ;
-    trace = new string (sstream.str());
-    return trace ;
-}
-
-/*
- * 
- */
-void BrokerError::printStackTrace(ostream& out)
-{
-    out << getptr(exceptionClass) << ": " << getptr(message) << endl ;
-
-    for( size_t i = 0; i < sizeof(stackTraceElements)/sizeof(stackTraceElements[0]); i++ )
-    {
-        p<StackTraceElement> element = stackTraceElements[i] ;
-        out << "    at " << getptr(element->className) << "." << getptr(element->methodName) << "(" << getptr(element->fileName) << ":" << element->lineNumber << ")" << endl ;
-    }
-    // Dump any nested exceptions
-    if( cause != NULL )
-    {
-        out << "Nested Exception:" << endl ;
-        cause->printStackTrace(out) ;
-    }
-}
+/*
+ * 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/BrokerError.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+BrokerError::BrokerError()
+{
+    message            = new string() ;
+    exceptionClass     = new string() ;
+    stackTraceElements = NULL ;
+    cause              = NULL ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getMessage()
+{
+    return message ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setMessage(const char* msg)
+{
+    this->message->assign(msg) ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getExceptionClass()
+{
+    return exceptionClass ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setExceptionClass(const char* exClass)
+{
+    this->exceptionClass->assign(exClass) ;
+}
+
+/*
+ * 
+ */
+array<StackTraceElement> BrokerError::getStackTraceElements()
+{
+    return stackTraceElements ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setStackTraceElements(array<StackTraceElement> elements)
+{
+    this->stackTraceElements = elements ;
+}
+
+/*
+ * 
+ */
+p<BrokerError> BrokerError::getCause()
+{
+    return cause ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setCause(p<BrokerError> cause)
+{
+    this->cause = cause ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getStackTrace()
+{
+    ostringstream sstream ;
+    p<string> trace ;
+    printStackTrace(sstream) ;
+    trace = new string (sstream.str());
+    return trace ;
+}
+
+/*
+ * 
+ */
+void BrokerError::printStackTrace(ostream& out)
+{
+    out << getptr(exceptionClass) << ": " << getptr(message) << endl ;
+
+    for( size_t i = 0; i < sizeof(stackTraceElements)/sizeof(stackTraceElements[0]); i++ )
+    {
+        p<StackTraceElement> element = stackTraceElements[i] ;
+        out << "    at " << getptr(element->className) << "." << getptr(element->methodName) << "(" << getptr(element->fileName) << ":" << element->lineNumber << ")" << endl ;
+    }
+    // Dump any nested exceptions
+    if( cause != NULL )
+    {
+        out << "Nested Exception:" << endl ;
+        cause->printStackTrace(out) ;
+    }
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerId.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/BrokerId.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for BrokerId
- *
- *
- *  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
- *
- */
-BrokerId::BrokerId()
-{
-    this->value = NULL ;
-}
-
-BrokerId::~BrokerId()
-{
-}
-
-unsigned char BrokerId::getDataStructureType()
-{
-    return BrokerId::TYPE ; 
-}
-
-        
-p<string> BrokerId::getValue()
-{
-    return value ;
-}
-
-void BrokerId::setValue(p<string> value)
-{
-    this->value = value ;
-}
-
-int BrokerId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalString(value, mode, ostream) ; 
-    return size ;
-}
-
-void BrokerId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
-    value = 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/BrokerId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for BrokerId
+ *
+ *
+ *  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
+ *
+ */
+BrokerId::BrokerId()
+{
+    this->value = NULL ;
+}
+
+BrokerId::~BrokerId()
+{
+}
+
+unsigned char BrokerId::getDataStructureType()
+{
+    return BrokerId::TYPE ; 
+}
+
+        
+p<string> BrokerId::getValue()
+{
+    return value ;
+}
+
+void BrokerId::setValue(p<string> value)
+{
+    this->value = value ;
+}
+
+int BrokerId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalString(value, mode, ostream) ; 
+    return size ;
+}
+
+void BrokerId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
+    value = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/BrokerInfo.cpp Wed Jul  5 20:17:58 2006
@@ -1,153 +1,153 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#include "activemq/command/BrokerInfo.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for BrokerInfo
- *
- *
- *  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
- *
- */
-BrokerInfo::BrokerInfo()
-{
-    this->brokerId = NULL ;
-    this->brokerURL = NULL ;
-    this->peerBrokerInfos = NULL ;
-    this->brokerName = NULL ;
-    this->slaveBroker = false ;
-    this->masterBroker = false ;
-    this->faultTolerantConfiguration = false ;
-}
-
-BrokerInfo::~BrokerInfo()
-{
-}
-
-unsigned char BrokerInfo::getDataStructureType()
-{
-    return BrokerInfo::TYPE ; 
-}
-
-        
-p<BrokerId> BrokerInfo::getBrokerId()
-{
-    return brokerId ;
-}
-
-void BrokerInfo::setBrokerId(p<BrokerId> brokerId)
-{
-    this->brokerId = brokerId ;
-}
-
-        
-p<string> BrokerInfo::getBrokerURL()
-{
-    return brokerURL ;
-}
-
-void BrokerInfo::setBrokerURL(p<string> brokerURL)
-{
-    this->brokerURL = brokerURL ;
-}
-
-        
-array<BrokerInfo> BrokerInfo::getPeerBrokerInfos()
-{
-    return peerBrokerInfos ;
-}
-
-void BrokerInfo::setPeerBrokerInfos(array<BrokerInfo> peerBrokerInfos)
-{
-    this->peerBrokerInfos = peerBrokerInfos ;
-}
-
-        
-p<string> BrokerInfo::getBrokerName()
-{
-    return brokerName ;
-}
-
-void BrokerInfo::setBrokerName(p<string> brokerName)
-{
-    this->brokerName = brokerName ;
-}
-
-        
-bool BrokerInfo::getSlaveBroker()
-{
-    return slaveBroker ;
-}
-
-void BrokerInfo::setSlaveBroker(bool slaveBroker)
-{
-    this->slaveBroker = slaveBroker ;
-}
-
-        
-bool BrokerInfo::getMasterBroker()
-{
-    return masterBroker ;
-}
-
-void BrokerInfo::setMasterBroker(bool masterBroker)
-{
-    this->masterBroker = masterBroker ;
-}
-
-        
-bool BrokerInfo::getFaultTolerantConfiguration()
-{
-    return faultTolerantConfiguration ;
-}
-
-void BrokerInfo::setFaultTolerantConfiguration(bool faultTolerantConfiguration)
-{
-    this->faultTolerantConfiguration = faultTolerantConfiguration ;
-}
-
-int BrokerInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObject(brokerId, mode, ostream) ; 
-    size += marshaller->marshalString(brokerURL, mode, ostream) ; 
-    size += marshaller->marshalObjectArray(peerBrokerInfos, mode, ostream) ; 
-    size += marshaller->marshalString(brokerName, mode, ostream) ; 
-    size += marshaller->marshalBoolean(slaveBroker, mode, ostream) ; 
-    size += marshaller->marshalBoolean(masterBroker, mode, ostream) ; 
-    size += marshaller->marshalBoolean(faultTolerantConfiguration, mode, ostream) ; 
-    return size ;
-}
-
-void BrokerInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-    brokerId = p_cast<BrokerId>(marshaller->unmarshalObject(mode, istream)) ; 
-    brokerURL = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    peerBrokerInfos = array_cast<BrokerInfo>(marshaller->unmarshalObjectArray(mode, istream)) ; 
-    brokerName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    slaveBroker = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    masterBroker = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    faultTolerantConfiguration = (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/BrokerInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for BrokerInfo
+ *
+ *
+ *  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
+ *
+ */
+BrokerInfo::BrokerInfo()
+{
+    this->brokerId = NULL ;
+    this->brokerURL = NULL ;
+    this->peerBrokerInfos = NULL ;
+    this->brokerName = NULL ;
+    this->slaveBroker = false ;
+    this->masterBroker = false ;
+    this->faultTolerantConfiguration = false ;
+}
+
+BrokerInfo::~BrokerInfo()
+{
+}
+
+unsigned char BrokerInfo::getDataStructureType()
+{
+    return BrokerInfo::TYPE ; 
+}
+
+        
+p<BrokerId> BrokerInfo::getBrokerId()
+{
+    return brokerId ;
+}
+
+void BrokerInfo::setBrokerId(p<BrokerId> brokerId)
+{
+    this->brokerId = brokerId ;
+}
+
+        
+p<string> BrokerInfo::getBrokerURL()
+{
+    return brokerURL ;
+}
+
+void BrokerInfo::setBrokerURL(p<string> brokerURL)
+{
+    this->brokerURL = brokerURL ;
+}
+
+        
+array<BrokerInfo> BrokerInfo::getPeerBrokerInfos()
+{
+    return peerBrokerInfos ;
+}
+
+void BrokerInfo::setPeerBrokerInfos(array<BrokerInfo> peerBrokerInfos)
+{
+    this->peerBrokerInfos = peerBrokerInfos ;
+}
+
+        
+p<string> BrokerInfo::getBrokerName()
+{
+    return brokerName ;
+}
+
+void BrokerInfo::setBrokerName(p<string> brokerName)
+{
+    this->brokerName = brokerName ;
+}
+
+        
+bool BrokerInfo::getSlaveBroker()
+{
+    return slaveBroker ;
+}
+
+void BrokerInfo::setSlaveBroker(bool slaveBroker)
+{
+    this->slaveBroker = slaveBroker ;
+}
+
+        
+bool BrokerInfo::getMasterBroker()
+{
+    return masterBroker ;
+}
+
+void BrokerInfo::setMasterBroker(bool masterBroker)
+{
+    this->masterBroker = masterBroker ;
+}
+
+        
+bool BrokerInfo::getFaultTolerantConfiguration()
+{
+    return faultTolerantConfiguration ;
+}
+
+void BrokerInfo::setFaultTolerantConfiguration(bool faultTolerantConfiguration)
+{
+    this->faultTolerantConfiguration = faultTolerantConfiguration ;
+}
+
+int BrokerInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObject(brokerId, mode, ostream) ; 
+    size += marshaller->marshalString(brokerURL, mode, ostream) ; 
+    size += marshaller->marshalObjectArray(peerBrokerInfos, mode, ostream) ; 
+    size += marshaller->marshalString(brokerName, mode, ostream) ; 
+    size += marshaller->marshalBoolean(slaveBroker, mode, ostream) ; 
+    size += marshaller->marshalBoolean(masterBroker, mode, ostream) ; 
+    size += marshaller->marshalBoolean(faultTolerantConfiguration, mode, ostream) ; 
+    return size ;
+}
+
+void BrokerInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+    brokerId = p_cast<BrokerId>(marshaller->unmarshalObject(mode, istream)) ; 
+    brokerURL = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    peerBrokerInfos = array_cast<BrokerInfo>(marshaller->unmarshalObjectArray(mode, istream)) ; 
+    brokerName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    slaveBroker = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    masterBroker = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    faultTolerantConfiguration = (marshaller->unmarshalBoolean(mode, istream)) ; 
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionControl.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionControl.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionControl.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionControl.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/ConnectionControl.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for ConnectionControl
- *
- *
- *  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
- *
- */
-ConnectionControl::ConnectionControl()
-{
-    this->close = false ;
-    this->exit = false ;
-    this->faultTolerant = false ;
-    this->resume = false ;
-    this->suspend = false ;
-}
-
-ConnectionControl::~ConnectionControl()
-{
-}
-
-unsigned char ConnectionControl::getDataStructureType()
-{
-    return ConnectionControl::TYPE ; 
-}
-
-        
-bool ConnectionControl::getClose()
-{
-    return close ;
-}
-
-void ConnectionControl::setClose(bool close)
-{
-    this->close = close ;
-}
-
-        
-bool ConnectionControl::getExit()
-{
-    return exit ;
-}
-
-void ConnectionControl::setExit(bool exit)
-{
-    this->exit = exit ;
-}
-
-        
-bool ConnectionControl::getFaultTolerant()
-{
-    return faultTolerant ;
-}
-
-void ConnectionControl::setFaultTolerant(bool faultTolerant)
-{
-    this->faultTolerant = faultTolerant ;
-}
-
-        
-bool ConnectionControl::getResume()
-{
-    return resume ;
-}
-
-void ConnectionControl::setResume(bool resume)
-{
-    this->resume = resume ;
-}
-
-        
-bool ConnectionControl::getSuspend()
-{
-    return suspend ;
-}
-
-void ConnectionControl::setSuspend(bool suspend)
-{
-    this->suspend = suspend ;
-}
-
-int ConnectionControl::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalBoolean(close, mode, ostream) ; 
-    size += marshaller->marshalBoolean(exit, mode, ostream) ; 
-    size += marshaller->marshalBoolean(faultTolerant, mode, ostream) ; 
-    size += marshaller->marshalBoolean(resume, mode, ostream) ; 
-    size += marshaller->marshalBoolean(suspend, mode, ostream) ; 
-    return size ;
-}
-
-void ConnectionControl::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-    close = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    exit = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    faultTolerant = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    resume = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    suspend = (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/ConnectionControl.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for ConnectionControl
+ *
+ *
+ *  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
+ *
+ */
+ConnectionControl::ConnectionControl()
+{
+    this->close = false ;
+    this->exit = false ;
+    this->faultTolerant = false ;
+    this->resume = false ;
+    this->suspend = false ;
+}
+
+ConnectionControl::~ConnectionControl()
+{
+}
+
+unsigned char ConnectionControl::getDataStructureType()
+{
+    return ConnectionControl::TYPE ; 
+}
+
+        
+bool ConnectionControl::getClose()
+{
+    return close ;
+}
+
+void ConnectionControl::setClose(bool close)
+{
+    this->close = close ;
+}
+
+        
+bool ConnectionControl::getExit()
+{
+    return exit ;
+}
+
+void ConnectionControl::setExit(bool exit)
+{
+    this->exit = exit ;
+}
+
+        
+bool ConnectionControl::getFaultTolerant()
+{
+    return faultTolerant ;
+}
+
+void ConnectionControl::setFaultTolerant(bool faultTolerant)
+{
+    this->faultTolerant = faultTolerant ;
+}
+
+        
+bool ConnectionControl::getResume()
+{
+    return resume ;
+}
+
+void ConnectionControl::setResume(bool resume)
+{
+    this->resume = resume ;
+}
+
+        
+bool ConnectionControl::getSuspend()
+{
+    return suspend ;
+}
+
+void ConnectionControl::setSuspend(bool suspend)
+{
+    this->suspend = suspend ;
+}
+
+int ConnectionControl::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalBoolean(close, mode, ostream) ; 
+    size += marshaller->marshalBoolean(exit, mode, ostream) ; 
+    size += marshaller->marshalBoolean(faultTolerant, mode, ostream) ; 
+    size += marshaller->marshalBoolean(resume, mode, ostream) ; 
+    size += marshaller->marshalBoolean(suspend, mode, ostream) ; 
+    return size ;
+}
+
+void ConnectionControl::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+    close = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    exit = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    faultTolerant = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    resume = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    suspend = (marshaller->unmarshalBoolean(mode, istream)) ; 
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionError.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/ConnectionError.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for ConnectionError
- *
- *
- *  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
- *
- */
-ConnectionError::ConnectionError()
-{
-    this->exception = NULL ;
-    this->connectionId = NULL ;
-}
-
-ConnectionError::~ConnectionError()
-{
-}
-
-unsigned char ConnectionError::getDataStructureType()
-{
-    return ConnectionError::TYPE ; 
-}
-
-        
-p<BrokerError> ConnectionError::getException()
-{
-    return exception ;
-}
-
-void ConnectionError::setException(p<BrokerError> exception)
-{
-    this->exception = exception ;
-}
-
-        
-p<ConnectionId> ConnectionError::getConnectionId()
-{
-    return connectionId ;
-}
-
-void ConnectionError::setConnectionId(p<ConnectionId> connectionId)
-{
-    this->connectionId = connectionId ;
-}
-
-int ConnectionError::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalObject(exception, mode, ostream) ; 
-    size += marshaller->marshalObject(connectionId, mode, ostream) ; 
-    return size ;
-}
-
-void ConnectionError::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-    exception = p_cast<BrokerError>(marshaller->unmarshalObject(mode, istream)) ; 
-    connectionId = p_cast<ConnectionId>(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/ConnectionError.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for ConnectionError
+ *
+ *
+ *  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
+ *
+ */
+ConnectionError::ConnectionError()
+{
+    this->exception = NULL ;
+    this->connectionId = NULL ;
+}
+
+ConnectionError::~ConnectionError()
+{
+}
+
+unsigned char ConnectionError::getDataStructureType()
+{
+    return ConnectionError::TYPE ; 
+}
+
+        
+p<BrokerError> ConnectionError::getException()
+{
+    return exception ;
+}
+
+void ConnectionError::setException(p<BrokerError> exception)
+{
+    this->exception = exception ;
+}
+
+        
+p<ConnectionId> ConnectionError::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ConnectionError::setConnectionId(p<ConnectionId> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+int ConnectionError::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalObject(exception, mode, ostream) ; 
+    size += marshaller->marshalObject(connectionId, mode, ostream) ; 
+    return size ;
+}
+
+void ConnectionError::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+    exception = p_cast<BrokerError>(marshaller->unmarshalObject(mode, istream)) ; 
+    connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, istream)) ; 
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionId.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/ConnectionId.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for ConnectionId
- *
- *
- *  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
- *
- */
-ConnectionId::ConnectionId()
-{
-    this->value = NULL ;
-}
-
-ConnectionId::~ConnectionId()
-{
-}
-
-unsigned char ConnectionId::getDataStructureType()
-{
-    return ConnectionId::TYPE ; 
-}
-
-        
-p<string> ConnectionId::getValue()
-{
-    return value ;
-}
-
-void ConnectionId::setValue(p<string> value)
-{
-    this->value = value ;
-}
-
-int ConnectionId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalString(value, mode, ostream) ; 
-    return size ;
-}
-
-void ConnectionId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
-    value = 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/ConnectionId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for ConnectionId
+ *
+ *
+ *  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
+ *
+ */
+ConnectionId::ConnectionId()
+{
+    this->value = NULL ;
+}
+
+ConnectionId::~ConnectionId()
+{
+}
+
+unsigned char ConnectionId::getDataStructureType()
+{
+    return ConnectionId::TYPE ; 
+}
+
+        
+p<string> ConnectionId::getValue()
+{
+    return value ;
+}
+
+void ConnectionId::setValue(p<string> value)
+{
+    this->value = value ;
+}
+
+int ConnectionId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalString(value, mode, ostream) ; 
+    return size ;
+}
+
+void ConnectionId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
+    value = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConnectionInfo.cpp Wed Jul  5 20:17:58 2006
@@ -1,153 +1,153 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#include "activemq/command/ConnectionInfo.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for ConnectionInfo
- *
- *
- *  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
- *
- */
-ConnectionInfo::ConnectionInfo()
-{
-    this->connectionId = NULL ;
-    this->clientId = NULL ;
-    this->password = NULL ;
-    this->userName = NULL ;
-    this->brokerPath = NULL ;
-    this->brokerMasterConnector = false ;
-    this->manageable = false ;
-}
-
-ConnectionInfo::~ConnectionInfo()
-{
-}
-
-unsigned char ConnectionInfo::getDataStructureType()
-{
-    return ConnectionInfo::TYPE ; 
-}
-
-        
-p<ConnectionId> ConnectionInfo::getConnectionId()
-{
-    return connectionId ;
-}
-
-void ConnectionInfo::setConnectionId(p<ConnectionId> connectionId)
-{
-    this->connectionId = connectionId ;
-}
-
-        
-p<string> ConnectionInfo::getClientId()
-{
-    return clientId ;
-}
-
-void ConnectionInfo::setClientId(p<string> clientId)
-{
-    this->clientId = clientId ;
-}
-
-        
-p<string> ConnectionInfo::getPassword()
-{
-    return password ;
-}
-
-void ConnectionInfo::setPassword(p<string> password)
-{
-    this->password = password ;
-}
-
-        
-p<string> ConnectionInfo::getUserName()
-{
-    return userName ;
-}
-
-void ConnectionInfo::setUserName(p<string> userName)
-{
-    this->userName = userName ;
-}
-
-        
-array<BrokerId> ConnectionInfo::getBrokerPath()
-{
-    return brokerPath ;
-}
-
-void ConnectionInfo::setBrokerPath(array<BrokerId> brokerPath)
-{
-    this->brokerPath = brokerPath ;
-}
-
-        
-bool ConnectionInfo::getBrokerMasterConnector()
-{
-    return brokerMasterConnector ;
-}
-
-void ConnectionInfo::setBrokerMasterConnector(bool brokerMasterConnector)
-{
-    this->brokerMasterConnector = brokerMasterConnector ;
-}
-
-        
-bool ConnectionInfo::getManageable()
-{
-    return manageable ;
-}
-
-void ConnectionInfo::setManageable(bool manageable)
-{
-    this->manageable = manageable ;
-}
-
-int ConnectionInfo::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->marshalString(clientId, mode, ostream) ; 
-    size += marshaller->marshalString(password, mode, ostream) ; 
-    size += marshaller->marshalString(userName, mode, ostream) ; 
-    size += marshaller->marshalObjectArray(brokerPath, mode, ostream) ; 
-    size += marshaller->marshalBoolean(brokerMasterConnector, mode, ostream) ; 
-    size += marshaller->marshalBoolean(manageable, mode, ostream) ; 
-    return size ;
-}
-
-void ConnectionInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-    connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, istream)) ; 
-    clientId = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    password = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    userName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, istream)) ; 
-    brokerMasterConnector = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    manageable = (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/ConnectionInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for ConnectionInfo
+ *
+ *
+ *  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
+ *
+ */
+ConnectionInfo::ConnectionInfo()
+{
+    this->connectionId = NULL ;
+    this->clientId = NULL ;
+    this->password = NULL ;
+    this->userName = NULL ;
+    this->brokerPath = NULL ;
+    this->brokerMasterConnector = false ;
+    this->manageable = false ;
+}
+
+ConnectionInfo::~ConnectionInfo()
+{
+}
+
+unsigned char ConnectionInfo::getDataStructureType()
+{
+    return ConnectionInfo::TYPE ; 
+}
+
+        
+p<ConnectionId> ConnectionInfo::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ConnectionInfo::setConnectionId(p<ConnectionId> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+        
+p<string> ConnectionInfo::getClientId()
+{
+    return clientId ;
+}
+
+void ConnectionInfo::setClientId(p<string> clientId)
+{
+    this->clientId = clientId ;
+}
+
+        
+p<string> ConnectionInfo::getPassword()
+{
+    return password ;
+}
+
+void ConnectionInfo::setPassword(p<string> password)
+{
+    this->password = password ;
+}
+
+        
+p<string> ConnectionInfo::getUserName()
+{
+    return userName ;
+}
+
+void ConnectionInfo::setUserName(p<string> userName)
+{
+    this->userName = userName ;
+}
+
+        
+array<BrokerId> ConnectionInfo::getBrokerPath()
+{
+    return brokerPath ;
+}
+
+void ConnectionInfo::setBrokerPath(array<BrokerId> brokerPath)
+{
+    this->brokerPath = brokerPath ;
+}
+
+        
+bool ConnectionInfo::getBrokerMasterConnector()
+{
+    return brokerMasterConnector ;
+}
+
+void ConnectionInfo::setBrokerMasterConnector(bool brokerMasterConnector)
+{
+    this->brokerMasterConnector = brokerMasterConnector ;
+}
+
+        
+bool ConnectionInfo::getManageable()
+{
+    return manageable ;
+}
+
+void ConnectionInfo::setManageable(bool manageable)
+{
+    this->manageable = manageable ;
+}
+
+int ConnectionInfo::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->marshalString(clientId, mode, ostream) ; 
+    size += marshaller->marshalString(password, mode, ostream) ; 
+    size += marshaller->marshalString(userName, mode, ostream) ; 
+    size += marshaller->marshalObjectArray(brokerPath, mode, ostream) ; 
+    size += marshaller->marshalBoolean(brokerMasterConnector, mode, ostream) ; 
+    size += marshaller->marshalBoolean(manageable, mode, ostream) ; 
+    return size ;
+}
+
+void ConnectionInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+    connectionId = p_cast<ConnectionId>(marshaller->unmarshalObject(mode, istream)) ; 
+    clientId = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    password = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    userName = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    brokerPath = array_cast<BrokerId>(marshaller->unmarshalObjectArray(mode, istream)) ; 
+    brokerMasterConnector = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    manageable = (marshaller->unmarshalBoolean(mode, istream)) ; 
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerControl.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerControl.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerControl.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerControl.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/ConsumerControl.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for ConsumerControl
- *
- *
- *  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
- *
- */
-ConsumerControl::ConsumerControl()
-{
-    this->close = false ;
-    this->consumerId = NULL ;
-    this->prefetch = 0 ;
-}
-
-ConsumerControl::~ConsumerControl()
-{
-}
-
-unsigned char ConsumerControl::getDataStructureType()
-{
-    return ConsumerControl::TYPE ; 
-}
-
-        
-bool ConsumerControl::getClose()
-{
-    return close ;
-}
-
-void ConsumerControl::setClose(bool close)
-{
-    this->close = close ;
-}
-
-        
-p<ConsumerId> ConsumerControl::getConsumerId()
-{
-    return consumerId ;
-}
-
-void ConsumerControl::setConsumerId(p<ConsumerId> consumerId)
-{
-    this->consumerId = consumerId ;
-}
-
-        
-int ConsumerControl::getPrefetch()
-{
-    return prefetch ;
-}
-
-void ConsumerControl::setPrefetch(int prefetch)
-{
-    this->prefetch = prefetch ;
-}
-
-int ConsumerControl::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalBoolean(close, mode, ostream) ; 
-    size += marshaller->marshalObject(consumerId, mode, ostream) ; 
-    size += marshaller->marshalInt(prefetch, mode, ostream) ; 
-    return size ;
-}
-
-void ConsumerControl::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseCommand::unmarshal(marshaller, mode, istream) ; 
-    close = (marshaller->unmarshalBoolean(mode, istream)) ; 
-    consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, istream)) ; 
-    prefetch = (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/ConsumerControl.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for ConsumerControl
+ *
+ *
+ *  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
+ *
+ */
+ConsumerControl::ConsumerControl()
+{
+    this->close = false ;
+    this->consumerId = NULL ;
+    this->prefetch = 0 ;
+}
+
+ConsumerControl::~ConsumerControl()
+{
+}
+
+unsigned char ConsumerControl::getDataStructureType()
+{
+    return ConsumerControl::TYPE ; 
+}
+
+        
+bool ConsumerControl::getClose()
+{
+    return close ;
+}
+
+void ConsumerControl::setClose(bool close)
+{
+    this->close = close ;
+}
+
+        
+p<ConsumerId> ConsumerControl::getConsumerId()
+{
+    return consumerId ;
+}
+
+void ConsumerControl::setConsumerId(p<ConsumerId> consumerId)
+{
+    this->consumerId = consumerId ;
+}
+
+        
+int ConsumerControl::getPrefetch()
+{
+    return prefetch ;
+}
+
+void ConsumerControl::setPrefetch(int prefetch)
+{
+    this->prefetch = prefetch ;
+}
+
+int ConsumerControl::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseCommand::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalBoolean(close, mode, ostream) ; 
+    size += marshaller->marshalObject(consumerId, mode, ostream) ; 
+    size += marshaller->marshalInt(prefetch, mode, ostream) ; 
+    return size ;
+}
+
+void ConsumerControl::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseCommand::unmarshal(marshaller, mode, istream) ; 
+    close = (marshaller->unmarshalBoolean(mode, istream)) ; 
+    consumerId = p_cast<ConsumerId>(marshaller->unmarshalObject(mode, istream)) ; 
+    prefetch = (marshaller->unmarshalInt(mode, istream)) ; 
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.cpp?rev=419422&r1=419421&r2=419422&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ConsumerId.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/ConsumerId.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for ConsumerId
- *
- *
- *  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
- *
- */
-ConsumerId::ConsumerId()
-{
-    this->connectionId = NULL ;
-    this->sessionId = 0 ;
-    this->value = 0 ;
-}
-
-ConsumerId::~ConsumerId()
-{
-}
-
-unsigned char ConsumerId::getDataStructureType()
-{
-    return ConsumerId::TYPE ; 
-}
-
-        
-p<string> ConsumerId::getConnectionId()
-{
-    return connectionId ;
-}
-
-void ConsumerId::setConnectionId(p<string> connectionId)
-{
-    this->connectionId = connectionId ;
-}
-
-        
-long long ConsumerId::getSessionId()
-{
-    return sessionId ;
-}
-
-void ConsumerId::setSessionId(long long sessionId)
-{
-    this->sessionId = sessionId ;
-}
-
-        
-long long ConsumerId::getValue()
-{
-    return value ;
-}
-
-void ConsumerId::setValue(long long value)
-{
-    this->value = value ;
-}
-
-int ConsumerId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
-{
-    int size = 0 ;
-
-    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
-    size += marshaller->marshalString(connectionId, mode, ostream) ; 
-    size += marshaller->marshalLong(sessionId, mode, ostream) ; 
-    size += marshaller->marshalLong(value, mode, ostream) ; 
-    return size ;
-}
-
-void ConsumerId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
-{
-    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
-    connectionId = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
-    sessionId = (marshaller->unmarshalLong(mode, istream)) ; 
-    value = (marshaller->unmarshalLong(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/ConsumerId.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for ConsumerId
+ *
+ *
+ *  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
+ *
+ */
+ConsumerId::ConsumerId()
+{
+    this->connectionId = NULL ;
+    this->sessionId = 0 ;
+    this->value = 0 ;
+}
+
+ConsumerId::~ConsumerId()
+{
+}
+
+unsigned char ConsumerId::getDataStructureType()
+{
+    return ConsumerId::TYPE ; 
+}
+
+        
+p<string> ConsumerId::getConnectionId()
+{
+    return connectionId ;
+}
+
+void ConsumerId::setConnectionId(p<string> connectionId)
+{
+    this->connectionId = connectionId ;
+}
+
+        
+long long ConsumerId::getSessionId()
+{
+    return sessionId ;
+}
+
+void ConsumerId::setSessionId(long long sessionId)
+{
+    this->sessionId = sessionId ;
+}
+
+        
+long long ConsumerId::getValue()
+{
+    return value ;
+}
+
+void ConsumerId::setValue(long long value)
+{
+    this->value = value ;
+}
+
+int ConsumerId::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException)
+{
+    int size = 0 ;
+
+    size += BaseDataStructure::marshal(marshaller, mode, ostream) ; 
+    size += marshaller->marshalString(connectionId, mode, ostream) ; 
+    size += marshaller->marshalLong(sessionId, mode, ostream) ; 
+    size += marshaller->marshalLong(value, mode, ostream) ; 
+    return size ;
+}
+
+void ConsumerId::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException)
+{
+    BaseDataStructure::unmarshal(marshaller, mode, istream) ; 
+    connectionId = p_cast<string>(marshaller->unmarshalString(mode, istream)) ; 
+    sessionId = (marshaller->unmarshalLong(mode, istream)) ; 
+    value = (marshaller->unmarshalLong(mode, istream)) ; 
+}

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



Mime
View raw message