You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/07/06 05:18:03 UTC
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/
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