You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2008/08/14 01:43:02 UTC
svn commit: r685729 [1/17] - in /activemq/activemq-cpp/trunk/src: main/
main/activemq/connector/openwire/ main/activemq/connector/openwire/commands/
main/activemq/connector/openwire/marshal/v3/
main/java/org/apache/activemq/openwire/tool/ test/ test/ac...
Author: tabish
Date: Wed Aug 13 16:42:56 2008
New Revision: 685729
URL: http://svn.apache.org/viewvc?rev=685729&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQCPP-179
New Generated V3 Commands
Added:
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQDestinationMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQMapMessageMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQMapMessageMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQMessageMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQMessageMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQObjectMessageMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQObjectMessageMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQQueueMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQQueueMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQStreamMessageMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQStreamMessageMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTempDestinationMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTempDestinationMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTempQueueMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTempQueueMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTempTopicMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTempTopicMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTextMessageMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTextMessageMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTopicMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQTopicMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/BaseCommandMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/BaseCommandMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/BrokerIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/BrokerIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/BrokerInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/BrokerInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConnectionControlMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConnectionControlMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConnectionErrorMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConnectionErrorMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConnectionIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConnectionIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConnectionInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConnectionInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConsumerControlMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConsumerControlMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConsumerIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConsumerIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConsumerInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ConsumerInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ControlCommandMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ControlCommandMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/DataArrayResponseMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/DataArrayResponseMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/DataResponseMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/DataResponseMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/DestinationInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/DestinationInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/DiscoveryEventMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/DiscoveryEventMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ExceptionResponseMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ExceptionResponseMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/FlushCommandMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/FlushCommandMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/IntegerResponseMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/IntegerResponseMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/JournalQueueAckMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/JournalQueueAckMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/JournalTopicAckMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/JournalTopicAckMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/JournalTraceMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/JournalTraceMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/JournalTransactionMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/JournalTransactionMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/KeepAliveInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/KeepAliveInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/LastPartialCommandMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/LastPartialCommandMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/LocalTransactionIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/LocalTransactionIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MarshallerFactory.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MarshallerFactory.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageAckMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageAckMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageDispatchMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageDispatchMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageDispatchNotificationMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageDispatchNotificationMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessageMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessagePullMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/MessagePullMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/NetworkBridgeFilterMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/NetworkBridgeFilterMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/PartialCommandMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/PartialCommandMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ProducerAckMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ProducerAckMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ProducerIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ProducerIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ProducerInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ProducerInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/RemoveInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/RemoveInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/RemoveSubscriptionInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/RemoveSubscriptionInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ReplayCommandMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ReplayCommandMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ResponseMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ResponseMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/SessionIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/SessionIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/SessionInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/SessionInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ShutdownInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ShutdownInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/SubscriptionInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/SubscriptionInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/TransactionIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/TransactionIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/TransactionInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/TransactionInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/WireFormatInfoMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/WireFormatInfoMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/XATransactionIdMarshaller.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/XATransactionIdMarshaller.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/srcmakefile.mk
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQMapMessageMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQMapMessageMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQMessageMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQMessageMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQObjectMessageMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQObjectMessageMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQQueueMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQQueueMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQStreamMessageMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQStreamMessageMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQTempQueueMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQTempQueueMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQTempTopicMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQTempTopicMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQTextMessageMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQTextMessageMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQTopicMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ActiveMQTopicMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/BrokerIdMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/BrokerIdMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/BrokerInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/BrokerInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConnectionControlMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConnectionControlMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConnectionErrorMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConnectionErrorMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConnectionIdMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConnectionIdMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConnectionInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConnectionInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConsumerControlMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConsumerControlMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConsumerIdMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConsumerIdMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConsumerInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ConsumerInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ControlCommandMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ControlCommandMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/DataArrayResponseMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/DataArrayResponseMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/DataResponseMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/DataResponseMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/DestinationInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/DestinationInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/DiscoveryEventMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/DiscoveryEventMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ExceptionResponseMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ExceptionResponseMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/FlushCommandMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/FlushCommandMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/IntegerResponseMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/IntegerResponseMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/JournalQueueAckMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/JournalQueueAckMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/JournalTopicAckMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/JournalTopicAckMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/JournalTraceMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/JournalTraceMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/JournalTransactionMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/JournalTransactionMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/KeepAliveInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/KeepAliveInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/LastPartialCommandMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/LastPartialCommandMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/LocalTransactionIdMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/LocalTransactionIdMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessageAckMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessageAckMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessageDispatchMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessageDispatchMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessageDispatchNotificationMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessageDispatchNotificationMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessageIdMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessageIdMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessagePullMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/MessagePullMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/NetworkBridgeFilterMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/NetworkBridgeFilterMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/PartialCommandMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/PartialCommandMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ProducerAckMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ProducerAckMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ProducerIdMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ProducerIdMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ProducerInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ProducerInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/RemoveInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/RemoveInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/RemoveSubscriptionInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/RemoveSubscriptionInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ReplayCommandMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ReplayCommandMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ResponseMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ResponseMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/SessionIdMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/SessionIdMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/SessionInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/SessionInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ShutdownInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/ShutdownInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/SubscriptionInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/SubscriptionInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/TransactionInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/TransactionInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/WireFormatInfoMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/WireFormatInfoMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/XATransactionIdMarshallerTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/XATransactionIdMarshallerTest.h
activemq/activemq-cpp/trunk/src/test/activemq/connector/openwire/marshal/v3/srcmakefile.mk
Modified:
activemq/activemq-cpp/trunk/src/main/Makefile.am
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireFormat.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/RemoveSubscriptionInfo.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.cpp
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.h
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/srcmakefile.mk
activemq/activemq-cpp/trunk/src/main/java/org/apache/activemq/openwire/tool/AmqCppMarshallingHeadersGenerator.java
activemq/activemq-cpp/trunk/src/test/Makefile.am
activemq/activemq-cpp/trunk/src/test/testRegistry.cpp
Modified: activemq/activemq-cpp/trunk/src/main/Makefile.am
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/Makefile.am?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/Makefile.am (original)
+++ activemq/activemq-cpp/trunk/src/main/Makefile.am Wed Aug 13 16:42:56 2008
@@ -446,6 +446,7 @@
include activemq/connector/openwire/commands/srcmakefile.mk
include activemq/connector/openwire/marshal/v1/srcmakefile.mk
include activemq/connector/openwire/marshal/v2/srcmakefile.mk
+include activemq/connector/openwire/marshal/v3/srcmakefile.mk
##
## Compiler / Linker Info
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireFormat.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireFormat.cpp?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireFormat.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireFormat.cpp Wed Aug 13 16:42:56 2008
@@ -28,6 +28,7 @@
#include <activemq/connector/openwire/commands/DataStructure.h>
#include <activemq/connector/openwire/marshal/MarshalAware.h>
#include <activemq/connector/openwire/marshal/DataStreamMarshaller.h>
+#include <activemq/connector/openwire/marshal/v3/MarshallerFactory.h>
#include <activemq/connector/openwire/marshal/v2/MarshallerFactory.h>
#include <activemq/connector/openwire/marshal/v1/MarshallerFactory.h>
#include <activemq/exceptions/ActiveMQException.h>
@@ -117,6 +118,9 @@
case 2:
v2::MarshallerFactory().configure( this );
break;
+ case 3:
+ v3::MarshallerFactory().configure( this );
+ break;
default:
throw IllegalArgumentException(
__FILE__, __LINE__,
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp Wed Aug 13 16:42:56 2008
@@ -48,6 +48,8 @@
this->duplexConnection = false;
this->networkConnection = false;
this->connectionId = 0;
+ this->brokerUploadUrl = "";
+ this->networkProperties = "";
}
////////////////////////////////////////////////////////////////////////////////
@@ -105,6 +107,8 @@
this->setDuplexConnection( srcPtr->isDuplexConnection() );
this->setNetworkConnection( srcPtr->isNetworkConnection() );
this->setConnectionId( srcPtr->getConnectionId() );
+ this->setBrokerUploadUrl( srcPtr->getBrokerUploadUrl() );
+ this->setNetworkProperties( srcPtr->getNetworkProperties() );
}
////////////////////////////////////////////////////////////////////////////////
@@ -141,6 +145,8 @@
stream << " Value of DuplexConnection = " << this->isDuplexConnection() << std::endl;
stream << " Value of NetworkConnection = " << this->isNetworkConnection() << std::endl;
stream << " Value of ConnectionId = " << this->getConnectionId() << std::endl;
+ stream << " Value of BrokerUploadUrl = " << this->getBrokerUploadUrl() << std::endl;
+ stream << " Value of NetworkProperties = " << this->getNetworkProperties() << std::endl;
stream << BaseCommand<transport::Command>::toString();
stream << "End Class = BrokerInfo" << std::endl;
@@ -194,6 +200,12 @@
if( this->getConnectionId() != valuePtr->getConnectionId() ) {
return false;
}
+ if( this->getBrokerUploadUrl() != valuePtr->getBrokerUploadUrl() ) {
+ return false;
+ }
+ if( this->getNetworkProperties() != valuePtr->getNetworkProperties() ) {
+ return false;
+ }
if( !BaseCommand<transport::Command>::equals( value ) ) {
return false;
}
@@ -320,3 +332,33 @@
this->connectionId = connectionId;
}
+////////////////////////////////////////////////////////////////////////////////
+const std::string& BrokerInfo::getBrokerUploadUrl() const {
+ return brokerUploadUrl;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& BrokerInfo::getBrokerUploadUrl() {
+ return brokerUploadUrl;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setBrokerUploadUrl(const std::string& brokerUploadUrl ) {
+ this->brokerUploadUrl = brokerUploadUrl;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& BrokerInfo::getNetworkProperties() const {
+ return networkProperties;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& BrokerInfo::getNetworkProperties() {
+ return networkProperties;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setNetworkProperties(const std::string& networkProperties ) {
+ this->networkProperties = networkProperties;
+}
+
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.h?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/BrokerInfo.h Wed Aug 13 16:42:56 2008
@@ -58,6 +58,8 @@
bool duplexConnection;
bool networkConnection;
long long connectionId;
+ std::string brokerUploadUrl;
+ std::string networkProperties;
public:
@@ -138,6 +140,14 @@
virtual long long getConnectionId() const;
virtual void setConnectionId( long long connectionId );
+ virtual const std::string& getBrokerUploadUrl() const;
+ virtual std::string& getBrokerUploadUrl();
+ virtual void setBrokerUploadUrl( const std::string& brokerUploadUrl );
+
+ virtual const std::string& getNetworkProperties() const;
+ virtual std::string& getNetworkProperties();
+ virtual void setNetworkProperties( const std::string& networkProperties );
+
};
}}}}
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.cpp?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.cpp Wed Aug 13 16:42:56 2008
@@ -62,6 +62,8 @@
this->userID = "";
this->recievedByDFBridge = false;
this->droppable = false;
+ this->brokerInTime = 0;
+ this->brokerOutTime = 0;
}
////////////////////////////////////////////////////////////////////////////////
@@ -79,6 +81,9 @@
for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) {
delete brokerPath[ibrokerPath];
}
+ for( size_t icluster = 0; icluster < cluster.size(); ++icluster ) {
+ delete cluster[icluster];
+ }
}
////////////////////////////////////////////////////////////////////////////////
@@ -175,6 +180,17 @@
this->setUserID( srcPtr->getUserID() );
this->setRecievedByDFBridge( srcPtr->isRecievedByDFBridge() );
this->setDroppable( srcPtr->isDroppable() );
+ for( size_t icluster = 0; icluster < srcPtr->getCluster().size(); ++icluster ) {
+ if( srcPtr->getCluster()[icluster] != NULL ) {
+ this->getCluster().push_back(
+ dynamic_cast<BrokerId*>(
+ srcPtr->getCluster()[icluster]->cloneDataStructure() ) );
+ } else {
+ this->getCluster().push_back( NULL );
+ }
+ }
+ this->setBrokerInTime( srcPtr->getBrokerInTime() );
+ this->setBrokerOutTime( srcPtr->getBrokerOutTime() );
}
////////////////////////////////////////////////////////////////////////////////
@@ -271,6 +287,16 @@
stream << " Value of UserID = " << this->getUserID() << std::endl;
stream << " Value of RecievedByDFBridge = " << this->isRecievedByDFBridge() << std::endl;
stream << " Value of Droppable = " << this->isDroppable() << std::endl;
+ for( size_t icluster = 0; icluster < this->getCluster().size(); ++icluster ) {
+ stream << " Value of Cluster[" << icluster << "] is Below:" << std::endl;
+ if( this->getCluster()[icluster] != NULL ) {
+ stream << this->getCluster()[icluster]->toString() << std::endl;
+ } else {
+ stream << " Object is NULL" << std::endl;
+ }
+ }
+ stream << " Value of BrokerInTime = " << this->getBrokerInTime() << std::endl;
+ stream << " Value of BrokerOutTime = " << this->getBrokerOutTime() << std::endl;
stream << BaseCommand<transport::Command>::toString();
stream << "End Class = Message" << std::endl;
@@ -408,6 +434,21 @@
if( this->isDroppable() != valuePtr->isDroppable() ) {
return false;
}
+ for( size_t icluster = 0; icluster < this->getCluster().size(); ++icluster ) {
+ if( this->getCluster()[icluster] != NULL ) {
+ if( !this->getCluster()[icluster]->equals( valuePtr->getCluster()[icluster] ) ) {
+ return false;
+ }
+ } else if( valuePtr->getCluster()[icluster] != NULL ) {
+ return false;
+ }
+ }
+ if( this->getBrokerInTime() != valuePtr->getBrokerInTime() ) {
+ return false;
+ }
+ if( this->getBrokerOutTime() != valuePtr->getBrokerOutTime() ) {
+ return false;
+ }
if( !BaseCommand<transport::Command>::equals( value ) ) {
return false;
}
@@ -754,3 +795,38 @@
this->droppable = droppable;
}
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*>& Message::getCluster() const {
+ return cluster;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*>& Message::getCluster() {
+ return cluster;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setCluster(const std::vector<BrokerId*>& cluster ) {
+ this->cluster = cluster;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getBrokerInTime() const {
+ return brokerInTime;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setBrokerInTime(long long brokerInTime ) {
+ this->brokerInTime = brokerInTime;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getBrokerOutTime() const {
+ return brokerOutTime;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setBrokerOutTime(long long brokerOutTime ) {
+ this->brokerOutTime = brokerOutTime;
+}
+
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.h?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/Message.h Wed Aug 13 16:42:56 2008
@@ -34,6 +34,7 @@
#include <activemq/connector/openwire/commands/DataStructure.h>
#include <activemq/connector/openwire/commands/ConsumerId.h>
#include <activemq/connector/openwire/commands/BrokerId.h>
+#include <activemq/connector/openwire/commands/BrokerId.h>
#include <vector>
#include <string>
@@ -82,6 +83,9 @@
std::string userID;
bool recievedByDFBridge;
bool droppable;
+ std::vector<BrokerId*> cluster;
+ long long brokerInTime;
+ long long brokerOutTime;
public:
@@ -222,6 +226,16 @@
virtual bool isDroppable() const;
virtual void setDroppable( bool droppable );
+ virtual const std::vector<BrokerId*>& getCluster() const;
+ virtual std::vector<BrokerId*>& getCluster();
+ virtual void setCluster( const std::vector<BrokerId*>& cluster );
+
+ virtual long long getBrokerInTime() const;
+ virtual void setBrokerInTime( long long brokerInTime );
+
+ virtual long long getBrokerOutTime() const;
+ virtual void setBrokerOutTime( long long brokerOutTime );
+
};
}}}}
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.cpp?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.cpp Wed Aug 13 16:42:56 2008
@@ -42,6 +42,8 @@
this->consumerId = NULL;
this->destination = NULL;
this->timeout = 0;
+ this->correlationId = "";
+ this->messageId = NULL;
}
////////////////////////////////////////////////////////////////////////////////
@@ -49,6 +51,7 @@
{
delete this->consumerId;
delete this->destination;
+ delete this->messageId;
}
////////////////////////////////////////////////////////////////////////////////
@@ -86,6 +89,12 @@
srcPtr->getDestination()->cloneDataStructure() ) );
}
this->setTimeout( srcPtr->getTimeout() );
+ this->setCorrelationId( srcPtr->getCorrelationId() );
+ if( srcPtr->getMessageId() != NULL ) {
+ this->setMessageId(
+ dynamic_cast<MessageId*>(
+ srcPtr->getMessageId()->cloneDataStructure() ) );
+ }
}
////////////////////////////////////////////////////////////////////////////////
@@ -113,6 +122,13 @@
stream << " Object is NULL" << std::endl;
}
stream << " Value of Timeout = " << this->getTimeout() << std::endl;
+ stream << " Value of CorrelationId = " << this->getCorrelationId() << std::endl;
+ stream << " Value of MessageId is Below:" << std::endl;
+ if( this->getMessageId() != NULL ) {
+ stream << this->getMessageId()->toString() << std::endl;
+ } else {
+ stream << " Object is NULL" << std::endl;
+ }
stream << BaseCommand<transport::Command>::toString();
stream << "End Class = MessagePull" << std::endl;
@@ -143,6 +159,16 @@
if( this->getTimeout() != valuePtr->getTimeout() ) {
return false;
}
+ if( this->getCorrelationId() != valuePtr->getCorrelationId() ) {
+ return false;
+ }
+ if( this->getMessageId() != NULL ) {
+ if( !this->getMessageId()->equals( valuePtr->getMessageId() ) ) {
+ return false;
+ }
+ } else if( valuePtr->getMessageId() != NULL ) {
+ return false;
+ }
if( !BaseCommand<transport::Command>::equals( value ) ) {
return false;
}
@@ -189,3 +215,33 @@
this->timeout = timeout;
}
+////////////////////////////////////////////////////////////////////////////////
+const std::string& MessagePull::getCorrelationId() const {
+ return correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& MessagePull::getCorrelationId() {
+ return correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setCorrelationId(const std::string& correlationId ) {
+ this->correlationId = correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* MessagePull::getMessageId() const {
+ return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessagePull::getMessageId() {
+ return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setMessageId(MessageId* messageId ) {
+ this->messageId = messageId;
+}
+
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.h?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/MessagePull.h Wed Aug 13 16:42:56 2008
@@ -26,6 +26,7 @@
#include <activemq/connector/openwire/commands/BaseCommand.h>
#include <activemq/connector/openwire/commands/ConsumerId.h>
#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/MessageId.h>
#include <vector>
#include <string>
@@ -51,6 +52,8 @@
ConsumerId* consumerId;
ActiveMQDestination* destination;
long long timeout;
+ std::string correlationId;
+ MessageId* messageId;
public:
@@ -108,6 +111,14 @@
virtual long long getTimeout() const;
virtual void setTimeout( long long timeout );
+ virtual const std::string& getCorrelationId() const;
+ virtual std::string& getCorrelationId();
+ virtual void setCorrelationId( const std::string& correlationId );
+
+ virtual const MessageId* getMessageId() const;
+ virtual MessageId* getMessageId();
+ virtual void setMessageId( MessageId* messageId );
+
};
}}}}
Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.cpp?rev=685729&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.cpp Wed Aug 13 16:42:56 2008
@@ -0,0 +1,156 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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/connector/openwire/commands/ProducerAck.h>
+#include <activemq/exceptions/ActiveMQException.h>
+#include <decaf/lang/exceptions/NullPointerException.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::exceptions;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+using namespace decaf::lang::exceptions;
+
+/*
+ *
+ * Command and marshaling code for OpenWire format for ProducerAck
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes in the
+ * activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ProducerAck::ProducerAck()
+{
+ this->producerId = NULL;
+ this->size = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerAck::~ProducerAck()
+{
+ delete this->producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerAck* ProducerAck::cloneDataStructure() const {
+ ProducerAck* producerAck = new ProducerAck();
+
+ // Copy the data from the base class or classes
+ producerAck->copyDataStructure( this );
+
+ return producerAck;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerAck::copyDataStructure( const DataStructure* src ) {
+
+ // Copy the data of the base class or classes
+ BaseCommand<transport::Command>::copyDataStructure( src );
+
+ const ProducerAck* srcPtr = dynamic_cast<const ProducerAck*>( src );
+
+ if( srcPtr == NULL || src == NULL ) {
+
+ throw decaf::lang::exceptions::NullPointerException(
+ __FILE__, __LINE__,
+ "ProducerAck::copyDataStructure - src is NULL or invalid" );
+ }
+ if( srcPtr->getProducerId() != NULL ) {
+ this->setProducerId(
+ dynamic_cast<ProducerId*>(
+ srcPtr->getProducerId()->cloneDataStructure() ) );
+ }
+ this->setSize( srcPtr->getSize() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ProducerAck::getDataStructureType() const {
+ return ProducerAck::ID_PRODUCERACK;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ProducerAck::toString() const {
+
+ ostringstream stream;
+
+ stream << "Begin Class = ProducerAck" << std::endl;
+ stream << " Value of ProducerAck::ID_PRODUCERACK = 19" << std::endl;
+ stream << " Value of ProducerId is Below:" << std::endl;
+ if( this->getProducerId() != NULL ) {
+ stream << this->getProducerId()->toString() << std::endl;
+ } else {
+ stream << " Object is NULL" << std::endl;
+ }
+ stream << " Value of Size = " << this->getSize() << std::endl;
+ stream << BaseCommand<transport::Command>::toString();
+ stream << "End Class = ProducerAck" << std::endl;
+
+ return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ProducerAck::equals( const DataStructure* value ) const {
+ const ProducerAck* valuePtr = dynamic_cast<const ProducerAck*>( value );
+
+ if( valuePtr == NULL || value == NULL ) {
+ return false;
+ }
+ if( this->getProducerId() != NULL ) {
+ if( !this->getProducerId()->equals( valuePtr->getProducerId() ) ) {
+ return false;
+ }
+ } else if( valuePtr->getProducerId() != NULL ) {
+ return false;
+ }
+ if( this->getSize() != valuePtr->getSize() ) {
+ return false;
+ }
+ if( !BaseCommand<transport::Command>::equals( value ) ) {
+ return false;
+ }
+ return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ProducerId* ProducerAck::getProducerId() const {
+ return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerId* ProducerAck::getProducerId() {
+ return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerAck::setProducerId(ProducerId* producerId ) {
+ this->producerId = producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ProducerAck::getSize() const {
+ return size;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerAck::setSize(int size ) {
+ this->size = size;
+}
+
Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.h?rev=685729&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerAck.h Wed Aug 13 16:42:56 2008
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_PRODUCERACK_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_PRODUCERACK_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ProducerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshaling code for OpenWire format for ProducerAck
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the activemq-openwire-generator module
+ *
+ */
+ class ProducerAck : public BaseCommand<transport::Command>
+ {
+ protected:
+
+ ProducerId* producerId;
+ int size;
+
+ public:
+
+ const static unsigned char ID_PRODUCERACK = 19;
+
+ public:
+
+ ProducerAck();
+ virtual ~ProducerAck();
+
+ /**
+ * Get the unique identifier that this object and its own
+ * Marshaller share.
+ * @returns new DataStructure type copy.
+ */
+ virtual unsigned char getDataStructureType() const;
+
+ /**
+ * Clone this object and return a new instance that the
+ * caller now owns, this will be an exact copy of this one
+ * @returns new copy of this object.
+ */
+ virtual ProducerAck* cloneDataStructure() const;
+
+ /**
+ * Copy the contents of the passed object into this object's
+ * members, overwriting any existing data.
+ * @param src - Source Object
+ */
+ virtual void copyDataStructure( const DataStructure* src );
+
+ /**
+ * Returns a string containing the information for this DataStructure
+ * such as its type and value of its elements.
+ * @return formatted string useful for debugging.
+ */
+ virtual std::string toString() const;
+
+ /**
+ * Compares the DataStructure passed in to this one, and returns if
+ * they are equivalent. Equivalent here means that they are of the
+ * same type, and that each element of the objects are the same.
+ * @returns true if DataStructure's are Equal.
+ */
+ virtual bool equals( const DataStructure* value ) const;
+
+ virtual const ProducerId* getProducerId() const;
+ virtual ProducerId* getProducerId();
+ virtual void setProducerId( ProducerId* producerId );
+
+ virtual int getSize() const;
+ virtual void setSize( int size );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_PRODUCERACK_H_*/
+
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.cpp?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.cpp Wed Aug 13 16:42:56 2008
@@ -42,6 +42,7 @@
this->producerId = NULL;
this->destination = NULL;
this->dispatchAsync = false;
+ this->windowSize = 0;
}
////////////////////////////////////////////////////////////////////////////////
@@ -98,6 +99,7 @@
}
}
this->setDispatchAsync( srcPtr->isDispatchAsync() );
+ this->setWindowSize( srcPtr->getWindowSize() );
}
////////////////////////////////////////////////////////////////////////////////
@@ -133,6 +135,7 @@
}
}
stream << " Value of DispatchAsync = " << this->isDispatchAsync() << std::endl;
+ stream << " Value of WindowSize = " << this->getWindowSize() << std::endl;
stream << BaseCommand<transport::Command>::toString();
stream << "End Class = ProducerInfo" << std::endl;
@@ -172,6 +175,9 @@
if( this->isDispatchAsync() != valuePtr->isDispatchAsync() ) {
return false;
}
+ if( this->getWindowSize() != valuePtr->getWindowSize() ) {
+ return false;
+ }
if( !BaseCommand<transport::Command>::equals( value ) ) {
return false;
}
@@ -233,3 +239,13 @@
this->dispatchAsync = dispatchAsync;
}
+////////////////////////////////////////////////////////////////////////////////
+int ProducerInfo::getWindowSize() const {
+ return windowSize;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerInfo::setWindowSize(int windowSize ) {
+ this->windowSize = windowSize;
+}
+
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.h?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ProducerInfo.h Wed Aug 13 16:42:56 2008
@@ -53,6 +53,7 @@
ActiveMQDestination* destination;
std::vector<BrokerId*> brokerPath;
bool dispatchAsync;
+ int windowSize;
public:
@@ -114,6 +115,9 @@
virtual bool isDispatchAsync() const;
virtual void setDispatchAsync( bool dispatchAsync );
+ virtual int getWindowSize() const;
+ virtual void setWindowSize( int windowSize );
+
};
}}}}
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/RemoveSubscriptionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/RemoveSubscriptionInfo.cpp?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/RemoveSubscriptionInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/RemoveSubscriptionInfo.cpp Wed Aug 13 16:42:56 2008
@@ -94,7 +94,7 @@
ostringstream stream;
stream << "Begin Class = RemoveSubscriptionInfo" << std::endl;
- stream << " Value of RemoveSubscriptionInfo::ID_REMOVESUBSCRIPTIONINFO = 0" << std::endl;
+ stream << " Value of RemoveSubscriptionInfo::ID_REMOVESUBSCRIPTIONINFO = 9" << std::endl;
stream << " Value of ConnectionId is Below:" << std::endl;
if( this->getConnectionId() != NULL ) {
stream << this->getConnectionId()->toString() << std::endl;
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.cpp?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.cpp Wed Aug 13 16:42:56 2008
@@ -43,12 +43,14 @@
this->destination = NULL;
this->selector = "";
this->subcriptionName = "";
+ this->subscribedDestination = NULL;
}
////////////////////////////////////////////////////////////////////////////////
SubscriptionInfo::~SubscriptionInfo()
{
delete this->destination;
+ delete this->subscribedDestination;
}
////////////////////////////////////////////////////////////////////////////////
@@ -83,6 +85,11 @@
}
this->setSelector( srcPtr->getSelector() );
this->setSubcriptionName( srcPtr->getSubcriptionName() );
+ if( srcPtr->getSubscribedDestination() != NULL ) {
+ this->setSubscribedDestination(
+ dynamic_cast<ActiveMQDestination*>(
+ srcPtr->getSubscribedDestination()->cloneDataStructure() ) );
+ }
}
////////////////////////////////////////////////////////////////////////////////
@@ -106,6 +113,12 @@
}
stream << " Value of Selector = " << this->getSelector() << std::endl;
stream << " Value of SubcriptionName = " << this->getSubcriptionName() << std::endl;
+ stream << " Value of SubscribedDestination is Below:" << std::endl;
+ if( this->getSubscribedDestination() != NULL ) {
+ stream << this->getSubscribedDestination()->toString() << std::endl;
+ } else {
+ stream << " Object is NULL" << std::endl;
+ }
stream << BaseDataStructure::toString();
stream << "End Class = SubscriptionInfo" << std::endl;
@@ -135,6 +148,13 @@
if( this->getSubcriptionName() != valuePtr->getSubcriptionName() ) {
return false;
}
+ if( this->getSubscribedDestination() != NULL ) {
+ if( !this->getSubscribedDestination()->equals( valuePtr->getSubscribedDestination() ) ) {
+ return false;
+ }
+ } else if( valuePtr->getSubscribedDestination() != NULL ) {
+ return false;
+ }
if( !BaseDataStructure::equals( value ) ) {
return false;
}
@@ -201,3 +221,18 @@
this->subcriptionName = subcriptionName;
}
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* SubscriptionInfo::getSubscribedDestination() const {
+ return subscribedDestination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* SubscriptionInfo::getSubscribedDestination() {
+ return subscribedDestination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void SubscriptionInfo::setSubscribedDestination(ActiveMQDestination* subscribedDestination ) {
+ this->subscribedDestination = subscribedDestination;
+}
+
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.h?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/SubscriptionInfo.h Wed Aug 13 16:42:56 2008
@@ -25,6 +25,7 @@
#include <activemq/connector/openwire/commands/BaseDataStructure.h>
#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
#include <vector>
#include <string>
@@ -51,6 +52,7 @@
ActiveMQDestination* destination;
std::string selector;
std::string subcriptionName;
+ ActiveMQDestination* subscribedDestination;
public:
@@ -113,6 +115,10 @@
virtual std::string& getSubcriptionName();
virtual void setSubcriptionName( const std::string& subcriptionName );
+ virtual const ActiveMQDestination* getSubscribedDestination() const;
+ virtual ActiveMQDestination* getSubscribedDestination();
+ virtual void setSubscribedDestination( ActiveMQDestination* subscribedDestination );
+
};
}}}}
Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/srcmakefile.mk
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/srcmakefile.mk?rev=685729&r1=685728&r2=685729&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/srcmakefile.mk (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/srcmakefile.mk Wed Aug 13 16:42:56 2008
@@ -60,6 +60,7 @@
activemq/connector/openwire/commands/MessagePull.cpp \
activemq/connector/openwire/commands/NetworkBridgeFilter.cpp \
activemq/connector/openwire/commands/PartialCommand.cpp \
+ activemq/connector/openwire/commands/ProducerAck.cpp \
activemq/connector/openwire/commands/ProducerId.cpp \
activemq/connector/openwire/commands/ProducerInfo.cpp \
activemq/connector/openwire/commands/RemoveInfo.cpp \
@@ -126,6 +127,7 @@
activemq/connector/openwire/commands/MessagePull.h \
activemq/connector/openwire/commands/NetworkBridgeFilter.h \
activemq/connector/openwire/commands/PartialCommand.h \
+ activemq/connector/openwire/commands/ProducerAck.h \
activemq/connector/openwire/commands/ProducerId.h \
activemq/connector/openwire/commands/ProducerInfo.h \
activemq/connector/openwire/commands/RemoveInfo.h \
Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp?rev=685729&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp Wed Aug 13 16:42:56 2008
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h>
+
+#include <activemq/connector/openwire/commands/ActiveMQBytesMessage.h>
+#include <activemq/exceptions/ActiveMQException.h>
+
+//
+// NOTE!: This file is autogenerated - do not modify!
+// if you need to make a change, please see the Java Classes in the
+// activemq-core module
+//
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::exceptions;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+using namespace activemq::connector::openwire::marshal;
+using namespace activemq::connector::openwire::utils;
+using namespace activemq::connector::openwire::marshal::v3;
+using namespace decaf;
+using namespace decaf::io;
+
+///////////////////////////////////////////////////////////////////////////////
+DataStructure* ActiveMQBytesMessageMarshaller::createObject() const {
+ return new ActiveMQBytesMessage();
+}
+
+///////////////////////////////////////////////////////////////////////////////
+unsigned char ActiveMQBytesMessageMarshaller::getDataStructureType() const {
+ return ActiveMQBytesMessage::ID_ACTIVEMQBYTESMESSAGE;
+}
+
+///////////////////////////////////////////////////////////////////////////////
+void ActiveMQBytesMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) {
+
+ try {
+
+ MessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs );
+
+ ActiveMQBytesMessage* info =
+ dynamic_cast<ActiveMQBytesMessage*>( dataStructure );
+ info->beforeUnmarshal( wireFormat );
+
+
+ info->afterUnmarshal( wireFormat );
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+///////////////////////////////////////////////////////////////////////////////
+int ActiveMQBytesMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) {
+
+ try {
+
+ ActiveMQBytesMessage* info =
+ dynamic_cast<ActiveMQBytesMessage*>( dataStructure );
+
+ info->beforeMarshal( wireFormat );
+ int rc = MessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs );
+
+ return rc + 0;
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+///////////////////////////////////////////////////////////////////////////////
+void ActiveMQBytesMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) {
+
+ try {
+
+ MessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs );
+
+ ActiveMQBytesMessage* info =
+ dynamic_cast<ActiveMQBytesMessage*>( dataStructure );
+ info->afterMarshal( wireFormat );
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+///////////////////////////////////////////////////////////////////////////////
+void ActiveMQBytesMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) {
+
+ try {
+
+ MessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn );
+ ActiveMQBytesMessage* info =
+ dynamic_cast<ActiveMQBytesMessage*>( dataStructure );
+ info->beforeUnmarshal( wireFormat );
+ info->afterUnmarshal( wireFormat );
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+///////////////////////////////////////////////////////////////////////////////
+void ActiveMQBytesMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) {
+
+ try {
+
+ ActiveMQBytesMessage* info =
+ dynamic_cast<ActiveMQBytesMessage*>( dataStructure );
+ info->beforeMarshal( wireFormat );
+ MessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut );
+
+ info->afterMarshal( wireFormat );
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h?rev=685729&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h Wed Aug 13 16:42:56 2008
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V3_ACTIVEMQBYTESMESSAGEMARSHALLER_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V3_ACTIVEMQBYTESMESSAGEMARSHALLER_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/marshal/v3/MessageMarshaller.h>
+
+#include <decaf/io/DataInputStream.h>
+#include <decaf/io/DataOutputStream.h>
+#include <decaf/io/IOException.h>
+#include <activemq/connector/openwire/OpenWireFormat.h>
+#include <activemq/connector/openwire/commands/DataStructure.h>
+#include <activemq/connector/openwire/utils/BooleanStream.h>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace marshal{
+namespace v3{
+
+ /**
+ * Marshalling code for Open Wire Format for ActiveMQBytesMessageMarshaller
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the activemq-openwire-generator module
+ */
+ class ActiveMQBytesMessageMarshaller : public MessageMarshaller
+ {
+ public:
+
+ ActiveMQBytesMessageMarshaller() {}
+ virtual ~ActiveMQBytesMessageMarshaller() {}
+
+ /**
+ * Creates a new instance of this marshalable type.
+ * @return new DataStructure object pointer caller owns it.
+ */
+ virtual commands::DataStructure* createObject() const;
+
+ /**
+ * Get the Data Structure Type that identifies this Marshaller
+ * @return byte holding the data structure type value
+ */
+ virtual unsigned char getDataStructureType() const;
+
+ /**
+ * Un-marshal an object instance from the data input stream
+ * @param wireFormat - describs the wire format of the broker
+ * @param o - Object to be un-marshaled
+ * @param dataIn - BinaryReader that provides that data
+ * @param bs - BooleanStream
+ */
+ virtual void tightUnmarshal( OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataInputStream* dataIn,
+ utils::BooleanStream* bs ) throw( decaf::io::IOException );
+
+ /**
+ * Write the booleans that this object uses to a BooleanStream
+ * @param wireFormat - describis the wire format of the broker
+ * @param o - Object to be marshaled
+ * @param bs - BooleanStream
+ * @returns int
+ */
+ virtual int tightMarshal1( OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ utils::BooleanStream* bs ) throw( decaf::io::IOException );
+
+ /**
+ * Write a object instance to data output stream
+ * @param wireFormat - describs the wire format of the broker
+ * @param o - Object to be marshaled
+ * @param dataOut - BinaryReader that provides that data sink
+ * @param bs - BooleanStream
+ */
+ virtual void tightMarshal2( OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataOutputStream* dataOut,
+ utils::BooleanStream* bs ) throw( decaf::io::IOException );
+
+ /**
+ * Un-marshal an object instance from the data input stream
+ * @param wireFormat - describs the wire format of the broker
+ * @param o - Object to be marshaled
+ * @param dataIn - BinaryReader that provides that data source
+ */
+ virtual void looseUnmarshal( OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataInputStream* dataIn ) throw( decaf::io::IOException );
+
+ /**
+ * Write a object instance to data output stream
+ * @param wireFormat - describs the wire format of the broker
+ * @param o - Object to be marshaled
+ * @param dataOut - BinaryWriter that provides that data sink
+ */
+ virtual void looseMarshal( OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException );
+
+ };
+
+}}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V3_ACTIVEMQBYTESMESSAGEMARSHALLER_H_*/
+
Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp?rev=685729&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp Wed Aug 13 16:42:56 2008
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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/connector/openwire/marshal/v3/ActiveMQDestinationMarshaller.h>
+
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/exceptions/ActiveMQException.h>
+
+//
+// NOTE!: This file is autogenerated - do not modify!
+// if you need to make a change, please see the Java Classes in the
+// activemq-core module
+//
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::exceptions;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+using namespace activemq::connector::openwire::marshal;
+using namespace activemq::connector::openwire::utils;
+using namespace activemq::connector::openwire::marshal::v3;
+using namespace decaf;
+using namespace decaf::io;
+
+///////////////////////////////////////////////////////////////////////////////
+void ActiveMQDestinationMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) {
+
+ try {
+
+ BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs );
+
+ ActiveMQDestination* info =
+ dynamic_cast<ActiveMQDestination*>( dataStructure );
+ info->setPhysicalName( tightUnmarshalString( dataIn, bs ) );
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+///////////////////////////////////////////////////////////////////////////////
+int ActiveMQDestinationMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) {
+
+ try {
+
+ ActiveMQDestination* info =
+ dynamic_cast<ActiveMQDestination*>( dataStructure );
+
+ int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs );
+ rc += tightMarshalString1( info->getPhysicalName(), bs );
+
+ return rc + 0;
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+///////////////////////////////////////////////////////////////////////////////
+void ActiveMQDestinationMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) {
+
+ try {
+
+ BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs );
+
+ ActiveMQDestination* info =
+ dynamic_cast<ActiveMQDestination*>( dataStructure );
+ tightMarshalString2( info->getPhysicalName(), dataOut, bs );
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+///////////////////////////////////////////////////////////////////////////////
+void ActiveMQDestinationMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) {
+
+ try {
+
+ BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn );
+ ActiveMQDestination* info =
+ dynamic_cast<ActiveMQDestination*>( dataStructure );
+ info->setPhysicalName( looseUnmarshalString( dataIn ) );
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+///////////////////////////////////////////////////////////////////////////////
+void ActiveMQDestinationMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) {
+
+ try {
+
+ ActiveMQDestination* info =
+ dynamic_cast<ActiveMQDestination*>( dataStructure );
+ BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut );
+
+ looseMarshalString( info->getPhysicalName(), dataOut );
+ }
+ AMQ_CATCH_RETHROW( decaf::io::IOException )
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+ AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+