activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r733509 [1/33] - in /activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire: ./ marshal/ marshal/v1/ marshal/v2/ marshal/v3/ utils/
Date Sun, 11 Jan 2009 20:22:43 GMT
Author: tabish
Date: Sun Jan 11 12:22:34 2009
New Revision: 733509

URL: http://svn.apache.org/viewvc?rev=733509&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-100

Newly generated marshallers and the start of refactoring from connectors to wireformat used in the 3.0 version.

Added:
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/BrokerException.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormatFactory.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormatFactory.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormatNegotiator.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormatNegotiator.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireResponseBuilder.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireResponseBuilder.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/BaseDataStreamMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/BaseDataStreamMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/DataStreamMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/PrimitiveMapMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/PrimitiveMapMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQBlobMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQBlobMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQDestinationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQDestinationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQMapMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQMapMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQQueueMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQQueueMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQStreamMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQStreamMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTempDestinationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTempDestinationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTempQueueMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTempQueueMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTempTopicMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTempTopicMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTextMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTextMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTopicMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ActiveMQTopicMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/BaseCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/BaseCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/BrokerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/BrokerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/BrokerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/BrokerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConnectionControlMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConnectionControlMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConnectionErrorMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConnectionErrorMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConnectionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConnectionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConnectionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConnectionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConsumerControlMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConsumerControlMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConsumerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConsumerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConsumerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ConsumerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ControlCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ControlCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/DataArrayResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/DataArrayResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/DataResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/DataResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/DestinationInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/DestinationInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/DiscoveryEventMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/DiscoveryEventMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ExceptionResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ExceptionResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/FlushCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/FlushCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/IntegerResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/IntegerResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalQueueAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalQueueAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTopicAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTopicAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTraceMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTraceMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTransactionMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTransactionMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchNotificationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchNotificationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessagePullMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessagePullMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/NetworkBridgeFilterMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/NetworkBridgeFilterMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/PartialCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/PartialCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ProducerAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ProducerAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ProducerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ProducerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ProducerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ProducerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/SessionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/SessionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/TransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/TransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/WireFormatInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/WireFormatInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/XATransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/XATransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/srcmakefile.mk
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQBlobMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQBlobMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQBytesMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQBytesMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQDestinationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQDestinationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQMapMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQMapMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQObjectMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQObjectMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQQueueMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQQueueMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQStreamMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQStreamMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTempQueueMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTempQueueMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTempTopicMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTempTopicMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTextMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTextMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTopicMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ActiveMQTopicMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/BaseCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/BaseCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/BrokerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/BrokerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/BrokerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/BrokerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConnectionControlMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConnectionControlMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConnectionErrorMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConnectionErrorMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConnectionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConnectionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConnectionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConnectionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConsumerControlMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConsumerControlMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConsumerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConsumerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConsumerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ConsumerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ControlCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ControlCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/DataArrayResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/DataArrayResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/DataResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/DataResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/DestinationInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/DestinationInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/DiscoveryEventMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/DiscoveryEventMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ExceptionResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ExceptionResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/FlushCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/FlushCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/IntegerResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/IntegerResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/JournalQueueAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/JournalQueueAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/JournalTopicAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/JournalTopicAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/JournalTraceMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/JournalTraceMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/JournalTransactionMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/JournalTransactionMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/KeepAliveInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/KeepAliveInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/LastPartialCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/LastPartialCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/LocalTransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/LocalTransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MarshallerFactory.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MarshallerFactory.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageDispatchMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageDispatchMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageDispatchNotificationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageDispatchNotificationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessagePullMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/MessagePullMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/NetworkBridgeFilterMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/NetworkBridgeFilterMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/PartialCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/PartialCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ProducerAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ProducerAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ProducerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ProducerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ProducerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ProducerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/RemoveInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/RemoveInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/RemoveSubscriptionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/RemoveSubscriptionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ReplayCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ReplayCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/SessionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/SessionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/SessionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/SessionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ShutdownInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/ShutdownInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/SubscriptionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/SubscriptionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/TransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/TransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/TransactionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/TransactionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/srcmakefile.mk
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQObjectMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQObjectMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQQueueMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQQueueMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQStreamMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQStreamMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTempDestinationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTempDestinationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTempQueueMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTempQueueMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTempTopicMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTempTopicMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTextMessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTextMessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTopicMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQTopicMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/BaseCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/BaseCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/BrokerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/BrokerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/BrokerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/BrokerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConnectionControlMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConnectionControlMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConnectionErrorMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConnectionErrorMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConnectionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConnectionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConnectionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConnectionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConsumerControlMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConsumerControlMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConsumerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConsumerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConsumerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ConsumerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ControlCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ControlCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/DataArrayResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/DataArrayResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/DataResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/DataResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/DestinationInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/DestinationInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/DiscoveryEventMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/DiscoveryEventMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ExceptionResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ExceptionResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/FlushCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/FlushCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/IntegerResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/IntegerResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/JournalQueueAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/JournalQueueAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/JournalTopicAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/JournalTopicAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/JournalTraceMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/JournalTraceMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/JournalTransactionMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/JournalTransactionMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/KeepAliveInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/KeepAliveInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/LastPartialCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/LastPartialCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/LocalTransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/LocalTransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MarshallerFactory.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MarshallerFactory.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageDispatchMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageDispatchMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageDispatchNotificationMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageDispatchNotificationMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessageMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessagePullMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/MessagePullMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/NetworkBridgeFilterMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/NetworkBridgeFilterMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/PartialCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/PartialCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ProducerAckMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ProducerAckMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ProducerIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ProducerIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ProducerInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ProducerInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/RemoveInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/RemoveInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/RemoveSubscriptionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/RemoveSubscriptionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ReplayCommandMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ReplayCommandMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ResponseMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ResponseMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/SessionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/SessionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/SessionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/SessionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ShutdownInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ShutdownInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/SubscriptionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/SubscriptionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/TransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/TransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/TransactionInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/TransactionInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/WireFormatInfoMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/WireFormatInfoMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/XATransactionIdMarshaller.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/XATransactionIdMarshaller.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/srcmakefile.mk
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/BooleanStream.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/BooleanStream.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/HexTable.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/HexTable.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/MessagePropertyInterceptor.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/MessagePropertyInterceptor.h   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/OpenwireStringSupport.cpp   (with props)
    activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/utils/OpenwireStringSupport.h   (with props)

Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/BrokerException.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/BrokerException.h?rev=733509&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/BrokerException.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/BrokerException.h Sun Jan 11 12:22:34 2009
@@ -0,0 +1,96 @@
+/*
+ * 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_WIREFORMAT_OPENWIRE_BROKEREXCEPTION_H_
+#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_BROKEREXCEPTION_H_
+
+#include <activemq/util/Config.h>
+#include <activemq/connector/openwire/OpenWireConnectorException.h>
+#include <activemq/commands/BrokerError.h>
+#include <sstream>
+
+namespace activemq{
+namespace wireformat{
+namespace openwire{
+
+    class AMQCPP_API BrokerException : public connector::openwire::OpenWireConnectorException {
+    public:
+
+        BrokerException() throw() {}
+
+        BrokerException( const exceptions::ActiveMQException& ex ) throw()
+            : OpenWireConnectorException(){
+            *( exceptions::ActiveMQException* )this = ex;
+        }
+
+        BrokerException( const BrokerException& ex ) throw()
+            : OpenWireConnectorException(){
+            *( exceptions::ActiveMQException* )this = ex;
+        }
+
+        BrokerException( const char* file,
+                                    const int lineNumber,
+                                    const char* msg, ... ) throw()
+          : OpenWireConnectorException() {
+
+            va_list vargs;
+            va_start( vargs, msg );
+            buildMessage( msg, vargs );
+
+            // Set the first mark for this exception.
+            setMark( file, lineNumber );
+        }
+
+        BrokerException( const char* file,
+                         const int lineNumber,
+                         const commands::BrokerError* error ) throw()
+          : OpenWireConnectorException() {
+
+            std::ostringstream ostream;
+            ostream << "*** BEGIN SERVER-SIDE STACK TRACE ***" << std::endl;
+            ostream << "Message: " << error->getMessage() << std::endl;
+            ostream << "Cause: " << error->getCause() << std::endl;
+            ostream << "Exception Class " << error->getExceptionClass() << std::endl;
+
+            const std::vector<commands::BrokerError::StackTraceElement*>& trace = error->getStackTraceElements();
+            for( std::size_t ix=0; ix<trace.size(); ++ix ){
+                commands::BrokerError::StackTraceElement* element = trace[ix];
+                ostream << "\t[FILE: " << element->FileName << ", LINE: " << element->LineNumber
+                    << "] occurred in: " << element->ClassName << "." << element->MethodName << std::endl;
+            }
+
+            ostream << "*** END SERVER-SIDE STACK TRACE ***";
+
+            setMessage( ostream.str().c_str() );
+            setMark( file, lineNumber );
+        }
+
+        /**
+         * Clones this exception.  This is useful for cases where you need
+         * to preserve the type of the original exception as well as the message.
+         * All subclasses should override.
+         */
+        virtual BrokerException* clone() const{
+            return new BrokerException( *this );
+        }
+
+        virtual ~BrokerException() throw() {}
+    };
+
+}}}
+
+#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_BROKEREXCEPTION_H_*/

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/BrokerException.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.cpp?rev=733509&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.cpp Sun Jan 11 12:22:34 2009
@@ -0,0 +1,541 @@
+/**
+ * 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 "OpenWireFormat.h"
+
+#include <decaf/lang/Boolean.h>
+#include <decaf/lang/Integer.h>
+#include <decaf/lang/Long.h>
+#include <decaf/util/UUID.h>
+#include <decaf/lang/Math.h>
+#include <decaf/io/ByteArrayOutputStream.h>
+#include <activemq/wireformat/openwire/OpenWireFormatNegotiator.h>
+#include <activemq/wireformat/openwire/utils/BooleanStream.h>
+#include <activemq/wireformat/MarshalAware.h>
+#include <activemq/commands/WireFormatInfo.h>
+#include <activemq/commands/DataStructure.h>
+#include <activemq/wireformat/openwire/marshal/DataStreamMarshaller.h>
+#include <activemq/wireformat/openwire/marshal/v3/MarshallerFactory.h>
+#include <activemq/wireformat/openwire/marshal/v2/MarshallerFactory.h>
+#include <activemq/wireformat/openwire/marshal/v1/MarshallerFactory.h>
+#include <activemq/exceptions/ActiveMQException.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::util;
+using namespace activemq::commands;
+using namespace activemq::transport;
+using namespace activemq::exceptions;
+using namespace activemq::wireformat;
+using namespace activemq::wireformat::openwire;
+using namespace activemq::wireformat::openwire::marshal;
+using namespace activemq::wireformat::openwire::utils;
+using namespace decaf::io;
+using namespace decaf::util;
+using namespace decaf::lang;
+using namespace decaf::lang::exceptions;
+
+////////////////////////////////////////////////////////////////////////////////
+const unsigned char OpenWireFormat::NULL_TYPE = 0;
+
+////////////////////////////////////////////////////////////////////////////////
+OpenWireFormat::OpenWireFormat( const decaf::util::Properties& properties ) {
+
+    // Copy config data
+    this->properties.copy( &properties );
+    this->preferedWireFormatInfo = NULL;
+
+    // Fill in that DataStreamMarshallers collection
+    dataMarshallers.resize( 256 );
+
+    // Generate an ID
+    this->id = UUID::randomUUID().toString();
+    // Set defaults for initial WireFormat negotiation
+    this->version = 0;
+    this->stackTraceEnabled = false;
+    this->cacheEnabled = false;
+    this->tcpNoDelayEnabled = false;
+    this->tightEncodingEnabled = false;
+    this->sizePrefixDisabled = false;
+
+    // Set to Default as lowest common denominator, then we will try
+    // and move up to the prefered when the wireformat is negotiated.
+    this->setVersion( DEFAULT_VERSION );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+OpenWireFormat::~OpenWireFormat() {
+    try {
+        this->destroyMarshalers();
+        delete preferedWireFormatInfo;
+    }
+    AMQ_CATCH_NOTHROW( ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+WireFormatNegotiator* OpenWireFormat::createNegotiator( transport::Transport* transport )
+    throw( decaf::lang::exceptions::UnsupportedOperationException ) {
+
+    try{
+        return new OpenWireFormatNegotiator( this, transport, false );
+    }
+    AMQ_CATCH_RETHROW( UnsupportedOperationException )
+    AMQ_CATCHALL_THROW( UnsupportedOperationException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void OpenWireFormat::destroyMarshalers() {
+    try {
+        for( size_t i = 0; i < dataMarshallers.size(); ++i ) {
+            delete dataMarshallers[i];
+            dataMarshallers[i] = NULL;
+        }
+    }
+    AMQ_CATCH_NOTHROW( ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void OpenWireFormat::setVersion( int version ) throw ( IllegalArgumentException ) {
+
+    try{
+        if( version == this->getVersion() ){
+            return;
+        }
+
+        // Clear old marshalers in preparation for the new set.
+        this->destroyMarshalers();
+        this->version = version;
+
+        switch( this->version ){
+        case 1:
+            v1::MarshallerFactory().configure( this );
+            break;
+        case 2:
+            v2::MarshallerFactory().configure( this );
+            break;
+        case 3:
+            v3::MarshallerFactory().configure( this );
+            break;
+        default:
+            throw IllegalArgumentException(
+                __FILE__, __LINE__,
+                "OpenWireFormat::setVersion - "
+                "Given Version: %d , is not supported", version );
+        }
+    }
+    AMQ_CATCH_RETHROW( IllegalArgumentException )
+    AMQ_CATCHALL_THROW( IllegalArgumentException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void OpenWireFormat::addMarshaller( DataStreamMarshaller* marshaller ) {
+    unsigned char type = marshaller->getDataStructureType();
+    dataMarshallers[type & 0xFF] = marshaller;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void OpenWireFormat::setPreferedWireFormatInfo(
+    commands::WireFormatInfo* info ) throw ( IllegalStateException ) {
+
+    delete preferedWireFormatInfo;
+    this->preferedWireFormatInfo = info;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void OpenWireFormat::marshal( transport::Command* command,
+                              decaf::io::DataOutputStream* dataOut )
+    throw ( decaf::io::IOException ) {
+
+    try {
+
+        int size = 1;
+
+        if( command != NULL ) {
+
+            DataStructure* dataStructure =
+                dynamic_cast< DataStructure* >( command );
+
+            unsigned char type = dataStructure->getDataStructureType();
+
+            DataStreamMarshaller* dsm = dataMarshallers[type & 0xFF];
+
+            if( dsm == NULL ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    ( string( "OpenWireFormat::marshal - Unknown data type: " ) +
+                    Integer::toString( type ) ).c_str() );
+            }
+
+            if( tightEncodingEnabled ) {
+                BooleanStream bs;
+                size += dsm->tightMarshal1( this, dataStructure, &bs );
+                size += bs.marshalledSize();
+
+                if( !sizePrefixDisabled ) {
+                    dataOut->writeInt( size );
+                }
+
+                dataOut->writeByte( type );
+                bs.marshal( dataOut );
+                dsm->tightMarshal2( this, dataStructure, dataOut, &bs );
+
+            } else {
+                DataOutputStream* looseOut = dataOut;
+                ByteArrayOutputStream* baos = NULL;
+
+                if( !sizePrefixDisabled ) {
+                    baos = new ByteArrayOutputStream();
+                    looseOut = new DataOutputStream( baos );
+                }
+
+                looseOut->writeByte( type );
+                dsm->looseMarshal( this, dataStructure, looseOut );
+
+                if( !sizePrefixDisabled ) {
+                    looseOut->close();
+                    dataOut->writeInt( (int)baos->size() );
+                    dataOut->write( baos->toByteArray(), 0, baos->size() );
+
+                    // Delete allocated resource
+                    delete baos;
+                    delete looseOut;
+                }
+            }
+        } else {
+            dataOut->writeInt( size );
+            dataOut->writeByte( NULL_TYPE );
+        }
+    }
+    AMQ_CATCH_RETHROW( IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( Exception, IOException )
+    AMQ_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+transport::Command* OpenWireFormat::unmarshal( decaf::io::DataInputStream* dis )
+    throw ( decaf::io::IOException ) {
+
+    try {
+
+        if( !sizePrefixDisabled ) {
+            dis->readInt();
+        }
+
+        // Get the unmarshalled DataStructure
+        DataStructure* data = doUnmarshal( dis );
+
+        if( data == NULL ) {
+            throw IOException(
+                __FILE__, __LINE__,
+                "OpenWireFormat::doUnmarshal - "
+                "Failed to unmarshal an Object" );
+        }
+
+        // Now all unmarshals from this level should result in an object
+        // that is a transport::Command type, if its not then we throw an
+        // exception.
+        transport::Command* command =
+            dynamic_cast< transport::Command* >( data );
+
+        if( command == NULL ) {
+            delete data;
+
+            throw IOException(
+                __FILE__, __LINE__,
+                "OpenWireFormat::doUnmarshal - "
+                "Unmarshalled a non Command Type" );
+        }
+
+        return command;
+    }
+    AMQ_CATCH_RETHROW( IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( Exception, IOException )
+    AMQ_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+commands::DataStructure* OpenWireFormat::doUnmarshal( DataInputStream* dis )
+    throw ( IOException ) {
+
+    try {
+
+        unsigned char dataType = dis->readByte();
+
+        if( dataType != NULL_TYPE ) {
+
+            DataStreamMarshaller* dsm =
+                dynamic_cast< DataStreamMarshaller* >(
+                    dataMarshallers[dataType & 0xFF] );
+
+            if( dsm == NULL ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    ( string( "OpenWireFormat::marshal - Unknown data type: " ) +
+                    Integer::toString( dataType ) ).c_str() );
+            }
+
+            // Ask the DataStreamMarshaller to create a new instance of its
+            // command so that we can fill in its data.
+            DataStructure* data = dsm->createObject();
+
+            if( this->tightEncodingEnabled ) {
+                BooleanStream bs;
+                bs.unmarshal( dis );
+                dsm->tightUnmarshal( this, data, dis, &bs );
+            } else {
+                dsm->looseUnmarshal( this, data, dis );
+            }
+
+            return data;
+        }
+
+        return NULL;
+    }
+    AMQ_CATCH_RETHROW( IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( Exception, IOException )
+    AMQ_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int OpenWireFormat::tightMarshalNestedObject1( commands::DataStructure* object,
+                                               utils::BooleanStream* bs )
+    throw ( decaf::io::IOException ) {
+
+    try {
+
+        bs->writeBoolean( object != NULL );
+        if( object == NULL ) {
+            return 0;
+        }
+
+        if( object->isMarshalAware() ) {
+
+            std::vector<unsigned char> sequence =
+                object->getMarshaledForm(this);
+            bs->writeBoolean( !sequence.empty() );
+            if( !sequence.empty() ) {
+                return (int)(1 + sequence.size());
+            }
+        }
+
+        unsigned char type = object->getDataStructureType();
+        if( type == 0 ) {
+            throw IOException(
+                __FILE__, __LINE__,
+                "No valid data structure type for object of this type");
+        }
+
+        DataStreamMarshaller* dsm = dataMarshallers[type & 0xFF];
+
+        if( dsm == NULL ) {
+            throw IOException(
+                __FILE__, __LINE__,
+                ( string( "OpenWireFormat::marshal - Unknown data type: " ) +
+                Integer::toString( type ) ).c_str() );
+        }
+
+        return 1 + dsm->tightMarshal1( this, object, bs );
+    }
+    AMQ_CATCH_RETHROW( IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( Exception, IOException )
+    AMQ_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void OpenWireFormat::tightMarshalNestedObject2( DataStructure* o,
+                                                DataOutputStream* ds,
+                                                BooleanStream* bs )
+                                                    throw ( IOException ) {
+
+    try {
+
+        if( !bs->readBoolean() ) {
+            return;
+        }
+
+        unsigned char type = o->getDataStructureType();
+
+        ds->writeByte(type);
+
+        if( o->isMarshalAware() && bs->readBoolean() ) {
+
+            MarshalAware* ma = dynamic_cast< MarshalAware* >( o );
+            vector<unsigned char> sequence = ma->getMarshaledForm( this );
+            ds->write( &sequence[0], 0, sequence.size() );
+
+        } else {
+
+            DataStreamMarshaller* dsm = dataMarshallers[type & 0xFF];
+
+            if( dsm == NULL ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    ( string( "OpenWireFormat::marshal - Unknown data type: " ) +
+                    Integer::toString( type ) ).c_str() );
+            }
+
+            dsm->tightMarshal2( this, o, ds, bs );
+        }
+    }
+    AMQ_CATCH_RETHROW( IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( Exception, IOException )
+    AMQ_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DataStructure* OpenWireFormat::tightUnmarshalNestedObject( DataInputStream* dis,
+                                                           BooleanStream* bs )
+    throw ( decaf::io::IOException ) {
+
+    try {
+
+        if( bs->readBoolean() ) {
+
+            const unsigned char dataType = dis->readByte();
+
+            DataStreamMarshaller* dsm = dataMarshallers[dataType & 0xFF];
+
+            if( dsm == NULL ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    ( string( "OpenWireFormat::marshal - Unknown data type: " ) +
+                    Integer::toString( dataType ) ).c_str() );
+            }
+
+            DataStructure* data = dsm->createObject();
+
+            if( data->isMarshalAware() && bs->readBoolean() ) {
+
+                dis->readInt();
+                dis->readByte();
+
+                BooleanStream bs2;
+                bs2.unmarshal( dis );
+                dsm->tightUnmarshal( this, data, dis, &bs2 );
+
+            } else {
+                dsm->tightUnmarshal( this, data, dis, bs );
+            }
+
+            return data;
+        } else {
+            return NULL;
+        }
+    }
+    AMQ_CATCH_RETHROW( IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( Exception, IOException )
+    AMQ_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DataStructure* OpenWireFormat::looseUnmarshalNestedObject( decaf::io::DataInputStream* dis )
+    throw ( IOException ) {
+
+    try{
+
+        if( dis->readBoolean() ) {
+
+            unsigned char dataType = dis->readByte();
+
+            DataStreamMarshaller* dsm = dataMarshallers[dataType & 0xFF];
+
+            if( dsm == NULL ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    ( string( "OpenWireFormat::marshal - Unknown data type: " ) +
+                    Integer::toString( dataType ) ).c_str() );
+            }
+
+            DataStructure* data = dsm->createObject();
+            dsm->looseUnmarshal( this, data, dis );
+
+            return data;
+
+        } else {
+            return NULL;
+        }
+    }
+    AMQ_CATCH_RETHROW( IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( Exception, IOException )
+    AMQ_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void OpenWireFormat::looseMarshalNestedObject( commands::DataStructure* o,
+                                               decaf::io::DataOutputStream* dataOut )
+    throw ( decaf::io::IOException ) {
+
+    try{
+
+        dataOut->writeBoolean( o != NULL );
+        if( o != NULL ) {
+
+            unsigned char dataType = o->getDataStructureType();
+
+            dataOut->writeByte( dataType );
+
+            DataStreamMarshaller* dsm = dataMarshallers[dataType & 0xFF];
+
+            if( dsm == NULL ) {
+                throw IOException(
+                    __FILE__, __LINE__,
+                    ( string( "OpenWireFormat::marshal - Unknown data type: " ) +
+                    Integer::toString( dataType ) ).c_str() );
+            }
+
+            dsm->looseMarshal( this, o, dataOut );
+        }
+    }
+    AMQ_CATCH_RETHROW( IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( Exception, IOException )
+    AMQ_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void OpenWireFormat::renegotiateWireFormat( WireFormatInfo* info )
+    throw ( IllegalStateException ) {
+
+    if( preferedWireFormatInfo == NULL ) {
+        throw IllegalStateException(
+            __FILE__, __LINE__,
+            "OpenWireFormat::renegotiateWireFormat - "
+            "Wireformat cannot not be renegotiated." );
+    }
+
+    this->setVersion( Math::min( preferedWireFormatInfo->getVersion(),
+                                 info->getVersion() ) );
+    this->stackTraceEnabled = info->isStackTraceEnabled() &&
+                              preferedWireFormatInfo->isStackTraceEnabled();
+    this->tcpNoDelayEnabled = info->isTcpNoDelayEnabled() &&
+                              preferedWireFormatInfo->isTcpNoDelayEnabled();
+    this->cacheEnabled = info->isCacheEnabled() &&
+                         preferedWireFormatInfo->isCacheEnabled();
+    this->tightEncodingEnabled = info->isTightEncodingEnabled() &&
+                                 preferedWireFormatInfo->isTightEncodingEnabled();
+    this->sizePrefixDisabled = info->isSizePrefixDisabled() &&
+                               preferedWireFormatInfo->isSizePrefixDisabled();
+}

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.h?rev=733509&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.h Sun Jan 11 12:22:34 2009
@@ -0,0 +1,328 @@
+/**
+ * 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_WIREFORMAT_OPENWIRE_OPENWIREFORMAT_H_
+#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_OPENWIREFORMAT_H_
+
+#include <activemq/util/Config.h>
+#include <activemq/commands/WireFormatInfo.h>
+#include <activemq/commands/DataStructure.h>
+#include <activemq/wireformat/WireFormat.h>
+#include <activemq/wireformat/openwire/utils/BooleanStream.h>
+#include <decaf/util/Properties.h>
+#include <decaf/lang/exceptions/IllegalStateException.h>
+#include <decaf/lang/exceptions/IllegalArgumentException.h>
+
+namespace activemq{
+namespace wireformat{
+namespace openwire{
+
+namespace marshal {
+    class DataStreamMarshaller;
+}
+
+    class AMQCPP_API OpenWireFormat : public wireformat::WireFormat {
+    public:
+
+        /**
+         * Constructs a new OpenWireFormat object
+         * @param properties - can contain optional config params.
+         */
+        OpenWireFormat( const decaf::util::Properties& properties );
+
+        virtual ~OpenWireFormat();
+
+        /**
+         * Returns true if this WireFormat has a Negotiator that needs to wrap the
+         * Transport that uses it.
+         * @returns true if the WireFormat provides a Negotiator.
+         */
+        virtual bool hasNegotiator() const {
+            return true;
+        }
+
+        /**
+         * If the Transport Provides a Negotiator this method will create and return
+         * a news instance of the Negotiator.
+         * @returns new instance of a WireFormatNegotiator.
+         */
+        virtual wireformat::WireFormatNegotiator* createNegotiator( transport::Transport* transport )
+            throw( decaf::lang::exceptions::UnsupportedOperationException );
+
+        /**
+         * Allows an external source to add marshallers to this object for
+         * types that may be marshalled or unmarhsalled.
+         * @param marshaller - the Marshaller to add to the collection.
+         */
+        void addMarshaller( marshal::DataStreamMarshaller* marshaller );
+
+        /**
+         * Stream based marshaling
+         * @param command - The Command to Marshal
+         * @param out - the output stream to write the command to.
+         * @throws IOException
+         */
+        virtual void marshal( transport::Command* command,
+                              decaf::io::DataOutputStream* dataOut )
+            throw ( decaf::io::IOException );
+
+        /**
+         * Packet based un-marshaling
+         * @param dis - the input stream to read the command from.
+         * @returns the newly marshaled Command, caller owns the pointer
+         * @throws IOException
+         */
+        virtual transport::Command* unmarshal( decaf::io::DataInputStream* dis )
+            throw ( decaf::io::IOException );
+
+        /**
+         * Utility method for Tight Marshalling the given object to the boolean
+         * stream passed.
+         * @param object - The DataStructure to marshal
+         * @param bs - the BooleanStream to write to
+         * @returns size of the data returned.
+         */
+        virtual int tightMarshalNestedObject1( commands::DataStructure* object,
+                                               utils::BooleanStream* bs )
+            throw ( decaf::io::IOException );
+
+        /**
+         * Utility method that will Tight marshall some internally nested object
+         * that implements the DataStructure interface.  Writes the data to the
+         * Data Ouput Stream provided.
+         * @param o - DataStructure object
+         * @param ds - DataOuputStream for writing
+         * @param bs - BooleanStream
+         * @throws IOException if an error occurs.
+         */
+        void tightMarshalNestedObject2( commands::DataStructure* o,
+                                        decaf::io::DataOutputStream* ds,
+                                        utils::BooleanStream* bs )
+            throw ( decaf::io::IOException );
+
+        /**
+         * Utility method used to Unmarshal a Nested DataStructure type object
+         * from the given DataInputStream.  The DataStructure instance that is
+         * returned is now the property of the caller.
+         * @param ds - DataInputStream to read from
+         * @param bs - BooleanStream to read from
+         * @returns Newly allocated DataStructure Object
+         * @throws IOException if an error occurs.
+         */
+        commands::DataStructure* tightUnmarshalNestedObject( decaf::io::DataInputStream* dis,
+                                                             utils::BooleanStream* bs )
+            throw ( decaf::io::IOException );
+
+        /**
+         * Utility method to unmarshal an DataStructure object from an
+         * DataInputStream using the Loose Unmarshalling format.  Will read
+         * the Data and construct a new DataStructure based Object, the
+         * pointer to the Object returned is now owned by the caller.
+         * @param dis - the DataInputStream to read the data from
+         * @returns a new DataStructure derived Object pointer
+         * @throws IOException if an error occurs.
+         */
+        commands::DataStructure* looseUnmarshalNestedObject(
+            decaf::io::DataInputStream* dis)
+                throw ( decaf::io::IOException );
+
+        /**
+         * Utility method to loosely Marshal an object that is derived from the
+         * DataStrucutre interface.  The marshalled data is written to the
+         * passed in DataOutputStream.
+         * @param o - DataStructure derived Object to Marshal
+         * @param dataOut - DataOutputStream to write the data to
+         * @throw IOException if an error occurs.
+         */
+        void looseMarshalNestedObject( commands::DataStructure* o,
+                                       decaf::io::DataOutputStream* dataOut )
+                                           throw ( decaf::io::IOException );
+
+        /**
+         * Called to renegotiate the settings for the WireFormatInfo, these
+         * determine how the client and broker communicate.
+         * @param info - The new Wireformat Info settings
+         * @throws IllegalStateException is the params can't be negotiated.
+         */
+        void renegotiateWireFormat( commands::WireFormatInfo* info )
+            throw ( decaf::lang::exceptions::IllegalStateException );
+
+        /**
+         * Configures this object using the provieded WireformatInfo object
+         * @param info - a WireFormatInfo object, takes ownership.
+         */
+        virtual void setPreferedWireFormatInfo( commands::WireFormatInfo* info )
+            throw ( decaf::lang::exceptions::IllegalStateException );
+
+        /**
+         * Gets the Preferend WireFormatInfo object that this class holds
+         * @return pointer to a prefered WireFormatInfo object
+         */
+        virtual commands::WireFormatInfo* getPreferedWireFormatInfo() const {
+            return this->preferedWireFormatInfo;
+        }
+
+        /**
+         * Checks if the stackTraceEnabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isStackTraceEnabled() const {
+            return stackTraceEnabled;
+        }
+
+        /**
+         * Sets if the stackTraceEnabled flag is on
+         * @param stackTraceEnabled - ture to turn flag is on
+         */
+        void setStackTraceEnabled( bool stackTraceEnabled ) {
+            this->stackTraceEnabled = stackTraceEnabled;
+        }
+
+        /**
+         * Checks if the tcpNoDelayEnabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isTcpNoDelayEnabled() const {
+            return tcpNoDelayEnabled;
+        }
+
+        /**
+         * Sets if the tcpNoDelayEnabled flag is on
+         * @param tcpNoDelayEnabled - ture to turn flag is on
+         */
+        void setTcpNoDelayEnabled( bool tcpNoDelayEnabled ) {
+            this->tcpNoDelayEnabled = tcpNoDelayEnabled;
+        }
+
+        /**
+         * Get the current Wireformat Version
+         * @return int that identifies the version
+         */
+        int getVersion() const {
+            return version;
+        }
+
+        /**
+         * Set the current Wireformat Version
+         * @param version - int that identifies the version
+         */
+        void setVersion( int version ) throw ( decaf::lang::exceptions::IllegalArgumentException );
+
+        /**
+         * Checks if the cacheEnabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isCacheEnabled() const {
+            return cacheEnabled;
+        }
+
+        /**
+         * Sets if the cacheEnabled flag is on
+         * @param cacheEnabled - ture to turn flag is on
+         */
+        void setCacheEnabled( bool cacheEnabled ) {
+            this->cacheEnabled = cacheEnabled;
+        }
+
+        /**
+         * Checks if the tightEncodingEnabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isTightEncodingEnabled() const {
+            return tightEncodingEnabled;
+        }
+
+        /**
+         * Sets if the tightEncodingEnabled flag is on
+         * @param tightEncodingEnabled - ture to turn flag is on
+         */
+        void setTightEncodingEnabled( bool tightEncodingEnabled ) {
+            this->tightEncodingEnabled = tightEncodingEnabled;
+        }
+
+        /**
+         * Checks if the sizePrefixDisabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isSizePrefixDisabled() const {
+            return sizePrefixDisabled;
+        }
+
+        /**
+         * Sets if the sizePrefixDisabled flag is on
+         * @param sizePrefixDisabled - ture to turn flag is on
+         */
+        void setSizePrefixDisabled( bool sizePrefixDisabled ) {
+            this->sizePrefixDisabled = sizePrefixDisabled;
+        }
+
+    protected:
+
+        /**
+         * Perform the actual unmarshal of data from the given DataInputStream
+         * return the unmarshalled DataStrucutre object once done, caller takes
+         * ownership of this object.  This method can return null if the type
+         * of the object to unmarshal is NULL, empty data.
+         * @param dis - DataInputStream to read from
+         * @returns new DataStructure* that the caller owns
+         * @throws IOException if an error occurs during the unmarshal
+         */
+        commands::DataStructure* doUnmarshal( decaf::io::DataInputStream* dis )
+            throw ( decaf::io::IOException );
+
+        /**
+         * Cleans up all registered Marshallers and empties the dataMarshallers
+         * vector.  This should be called before a reconfiguration of the version
+         * marshallers, or on destruction of this object
+         */
+        void destroyMarshalers();
+
+    protected:
+
+        // Declared here to make life easier.
+        static const unsigned char NULL_TYPE;
+
+        // V1 if the default version we start at.
+        static const int DEFAULT_VERSION = 1;
+
+    private:
+
+        // This object config data
+        decaf::util::Properties properties;
+
+        // Prefered WireFormatInfo
+        commands::WireFormatInfo* preferedWireFormatInfo;
+
+        // Marshallers
+        std::vector< marshal::DataStreamMarshaller* > dataMarshallers;
+
+        // Uniquely Generated ID, initialize in the Ctor
+        std::string id;
+
+        // WireFormat Data
+        int version;
+        bool stackTraceEnabled;
+        bool tcpNoDelayEnabled;
+        bool cacheEnabled;
+        bool tightEncodingEnabled;
+        bool sizePrefixDisabled;
+
+    };
+
+}}}
+
+#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_OPENWIREFORMAT_H_*/

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/OpenWireFormat.h
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message