activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject 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...
Date Wed, 13 Aug 2008 23:43:02 GMT
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 )
+}
+



Mime
View raw message