You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2009/07/30 21:06:44 UTC
svn commit: r799407 [1/29] - in
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp: ./
Commands/ OpenWire/ OpenWire/V1/ OpenWire/V2/ OpenWire/V3/ OpenWire/V4/
OpenWire/V5/ State/ Transport/
Author: tabish
Date: Thu Jul 30 19:06:34 2009
New Revision: 799407
URL: http://svn.apache.org/viewvc?rev=799407&view=rev
Log:
Fix for: https://issues.apache.org/activemq/browse/AMQNET-178
New Marshallers and Commands and some minor code cleanup to make things easier for the generated code.
Added:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBlobMessage.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQBlobMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/MessagePullMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ProducerAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQBlobMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ProducerAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQBlobMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQBytesMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQMapMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQObjectMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQStreamMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQTempDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQTempQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQTempTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQTextMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ActiveMQTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/BaseCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/BrokerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/BrokerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ConnectionControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ConnectionErrorMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ConnectionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ConnectionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ConsumerControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ConsumerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ConsumerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ControlCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/DataArrayResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/DataResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/DestinationInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/DiscoveryEventMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ExceptionResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/FlushCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/IntegerResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/JournalQueueAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/JournalTopicAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/JournalTraceMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/JournalTransactionMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/KeepAliveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/LastPartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/LocalTransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/MarshallerFactory.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/MessageAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/MessageDispatchMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/MessageDispatchNotificationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/MessageIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/MessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/MessagePullMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/NetworkBridgeFilterMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/PartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ProducerAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ProducerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ProducerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/RemoveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/RemoveSubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ReplayCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/SessionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/SessionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/ShutdownInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/SubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/TransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/TransactionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/WireFormatInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V3/XATransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQBlobMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQBytesMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQMapMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQObjectMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQStreamMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQTempDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQTempQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQTempTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQTextMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ActiveMQTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/BaseCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/BrokerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/BrokerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ConnectionControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ConnectionErrorMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ConnectionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ConnectionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ConsumerControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ConsumerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ConsumerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ControlCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/DataArrayResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/DataResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/DestinationInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/DiscoveryEventMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ExceptionResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/FlushCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/IntegerResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/JournalQueueAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/JournalTopicAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/JournalTraceMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/JournalTransactionMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/KeepAliveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/LastPartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/LocalTransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/MarshallerFactory.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/MessageAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/MessageDispatchMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/MessageDispatchNotificationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/MessageIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/MessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/MessagePullMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/NetworkBridgeFilterMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/PartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ProducerAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ProducerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ProducerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/RemoveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/RemoveSubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ReplayCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/SessionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/SessionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/ShutdownInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/SubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/TransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/TransactionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/WireFormatInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V4/XATransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQBlobMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQBytesMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQMapMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQObjectMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQStreamMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQTempDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQTempQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQTempTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQTextMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ActiveMQTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/BaseCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/BrokerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/BrokerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ConnectionControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ConnectionErrorMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ConnectionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ConnectionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ConsumerControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ConsumerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ConsumerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ControlCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/DataArrayResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/DataResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/DestinationInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/DiscoveryEventMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ExceptionResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/FlushCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/IntegerResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/JournalQueueAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/JournalTopicAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/JournalTraceMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/JournalTransactionMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/KeepAliveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/LastPartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/LocalTransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/MarshallerFactory.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/MessageAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/MessageDispatchMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/MessageDispatchNotificationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/MessageIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/MessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/MessagePullMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/NetworkBridgeFilterMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/PartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ProducerAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ProducerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ProducerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBytesMessage.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMapMessage.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMessage.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQObjectMessage.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQQueue.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQStreamMessage.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempQueue.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempTopic.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTextMessage.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTopic.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BaseCommand.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DiscoveryEvent.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ExceptionResponse.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/FlushCommand.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/IntegerResponse.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalQueueAck.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTopicAck.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTrace.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTransaction.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/KeepAliveInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LastPartialCommand.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LocalTransactionId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Message.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatch.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatchNotification.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessagePull.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/NetworkBridgeFilter.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerAck.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveSubscriptionInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ReplayCommand.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Response.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ShutdownInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SubscriptionInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/WireFormatInfo.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/OpenWireFormat.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQMapMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQTempQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQTempTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQTextMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ActiveMQTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/BaseCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/BrokerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/BrokerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ConnectionControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ConnectionErrorMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ConnectionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ConnectionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ConsumerControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ConsumerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ConsumerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ControlCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/DataArrayResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/DataResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/DestinationInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/DiscoveryEventMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ExceptionResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/FlushCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/IntegerResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/JournalQueueAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/JournalTopicAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/JournalTraceMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/JournalTransactionMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/KeepAliveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/LastPartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/LocalTransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/MarshallerFactory.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/MessageAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/MessageDispatchMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/MessageDispatchNotificationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/MessageIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/MessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/NetworkBridgeFilterMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/PartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ProducerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ProducerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/RemoveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ReplayCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/SessionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/SessionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/ShutdownInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/SubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/TransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/TransactionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/WireFormatInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V1/XATransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQBytesMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQMapMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQObjectMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQStreamMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQTempDestinationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQTempQueueMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQTempTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQTextMessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ActiveMQTopicMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/BaseCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/BrokerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/BrokerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ConnectionControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ConnectionErrorMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ConnectionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ConnectionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ConsumerControlMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ConsumerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ConsumerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ControlCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/DataArrayResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/DataResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/DestinationInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/DiscoveryEventMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ExceptionResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/FlushCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/IntegerResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/JournalQueueAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/JournalTopicAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/JournalTraceMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/JournalTransactionMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/KeepAliveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/LastPartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/LocalTransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/MarshallerFactory.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/MessageAckMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/MessageDispatchMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/MessageDispatchNotificationMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/MessageIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/MessageMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/MessagePullMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/NetworkBridgeFilterMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/PartialCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ProducerIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ProducerInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/RemoveInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/RemoveSubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ReplayCommandMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ResponseMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/SessionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/SessionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/ShutdownInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/SubscriptionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/TransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/TransactionInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/WireFormatInfoMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V2/XATransactionIdMarshaller.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/State/CommandVisitorAdapter.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/State/ICommandVisitor.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/WireFormatNegotiator.cs
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBlobMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBlobMessage.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBlobMessage.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBlobMessage.cs Thu Jul 30 19:06:34 2009
@@ -0,0 +1,57 @@
+/*
+ * 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.
+ */
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.Commands
+{
+ public class ActiveMQBlobMessage : ActiveMQMessage
+ {
+ public const byte ID_ACTIVEMQBLOBMESSAGE = 29;
+
+ public override byte GetDataStructureType()
+ {
+ return ID_ACTIVEMQBLOBMESSAGE;
+ }
+
+ public string RemoteBlobUrl
+ {
+ get { return ""; }
+ set {}
+ }
+
+ public string MimeType
+ {
+ get { return ""; }
+ set {}
+ }
+
+ public string Name
+ {
+ get { return ""; }
+ set {}
+ }
+
+ public bool DeletedByBroker
+ {
+ get { return false; }
+ set {}
+ }
+
+ }
+}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBytesMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBytesMessage.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBytesMessage.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQBytesMessage.cs Thu Jul 30 19:06:34 2009
@@ -19,14 +19,14 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- public class ActiveMQBytesMessage : ActiveMQMessage, IBytesMessage
+ public class ActiveMQBytesMessage : ActiveMQMessage, IBytesMessage
{
- public const byte ID_ActiveMQBytesMessage = 24;
-
-
+ public const byte ID_ACTIVEMQBYTESMESSAGE = 24;
+
+
public override byte GetDataStructureType()
{
- return ID_ActiveMQBytesMessage;
+ return ID_ACTIVEMQBYTESMESSAGE;
}
}
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMapMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMapMessage.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMapMessage.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMapMessage.cs Thu Jul 30 19:06:34 2009
@@ -21,18 +21,18 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- public class ActiveMQMapMessage : ActiveMQMessage, IMapMessage
+ public class ActiveMQMapMessage : ActiveMQMessage, IMapMessage
{
- public const byte ID_ActiveMQMapMessage = 25;
-
+ public const byte ID_ACTIVEMQMAPMESSAGE = 25;
+
private PrimitiveMap body;
-
-
+
+
public override byte GetDataStructureType()
{
- return ID_ActiveMQMapMessage;
+ return ID_ACTIVEMQMAPMESSAGE;
}
-
+
public IPrimitiveMap Body
{
get {
@@ -43,7 +43,7 @@
return body;
}
}
-
+
public override void BeforeMarshall(OpenWireFormat wireFormat)
{
if (body == null)
@@ -54,12 +54,12 @@
{
Content = body.Marshal();
}
-
+
Tracer.Debug("BeforeMarshalling, content is: " + Content);
-
+
base.BeforeMarshall(wireFormat);
}
-
+
}
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMessage.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMessage.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQMessage.cs Thu Jul 30 19:06:34 2009
@@ -22,267 +22,267 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- public delegate void AcknowledgeHandler(ActiveMQMessage message);
+ public delegate void AcknowledgeHandler(ActiveMQMessage message);
- public class ActiveMQMessage : Message, IMessage, MarshallAware
- {
- public const byte ID_ActiveMQMessage = 23;
-
- private MessagePropertyHelper propertyHelper;
- private PrimitiveMap properties;
-
- public event AcknowledgeHandler Acknowledger;
-
- public static ActiveMQMessage Transform(IMessage message)
- {
- return (ActiveMQMessage) message;
- }
-
- // TODO generate Equals method
- // TODO generate GetHashCode method
-
- public ActiveMQMessage()
- : base()
- {
- Timestamp = DateUtils.ToJavaTimeUtc(DateTime.UtcNow);
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ActiveMQMessage;
- }
-
- public void Acknowledge()
- {
- if(null == Acknowledger)
- {
- throw new NMSException("No Acknowledger has been associated with this message: " + this);
- }
- else
- {
- Acknowledger(this);
- }
- }
-
- #region Properties
-
- public IPrimitiveMap Properties
- {
- get
- {
- if(null == properties)
- {
- properties = PrimitiveMap.Unmarshal(MarshalledProperties);
- propertyHelper = new MessagePropertyHelper(this, properties);
- }
-
- return propertyHelper;
- }
- }
-
- public IDestination FromDestination
- {
- get { return Destination; }
- set { this.Destination = ActiveMQDestination.Transform(value); }
- }
-
- /// <summary>
- /// The correlation ID used to correlate messages with conversations or long running business processes
- /// </summary>
- public string NMSCorrelationID
- {
- get { return CorrelationId; }
- set { CorrelationId = value; }
- }
-
- /// <summary>
- /// The destination of the message
- /// </summary>
- public IDestination NMSDestination
- {
- get { return Destination; }
- }
-
- private TimeSpan timeToLive = TimeSpan.FromMilliseconds(0);
- /// <summary>
- /// The time in milliseconds that this message should expire in
- /// </summary>
- public TimeSpan NMSTimeToLive
- {
- get { return timeToLive; }
-
- set
- {
- timeToLive = value;
- if(timeToLive.TotalMilliseconds > 0)
- {
- Expiration = Timestamp + (long) timeToLive.TotalMilliseconds;
- }
- else
- {
- Expiration = 0;
- }
- }
- }
-
- /// <summary>
- /// The message ID which is set by the provider
- /// </summary>
- public string NMSMessageId
- {
- get
- {
- if(null != MessageId)
- {
- return BaseDataStreamMarshaller.ToString(MessageId);
- }
-
- return String.Empty;
- }
- }
-
- /// <summary>
- /// Whether or not this message is persistent
- /// </summary>
- public MsgDeliveryMode NMSDeliveryMode
- {
- get { return (Persistent ? MsgDeliveryMode.Persistent : MsgDeliveryMode.NonPersistent); }
- set { Persistent = (MsgDeliveryMode.Persistent == value); }
- }
-
- /// <summary>
- /// The Priority on this message
- /// </summary>
- public MsgPriority NMSPriority
- {
- get { return (MsgPriority) Priority; }
- set { Priority = (byte) value; }
- }
-
- /// <summary>
- /// Returns true if this message has been redelivered to this or another consumer before being acknowledged successfully.
- /// </summary>
- public bool NMSRedelivered
- {
- get { return (RedeliveryCounter > 0); }
- }
-
- /// <summary>
- /// The destination that the consumer of this message should send replies to
- /// </summary>
- public IDestination NMSReplyTo
- {
- get { return ReplyTo; }
- set { ReplyTo = ActiveMQDestination.Transform(value); }
- }
-
- /// <summary>
- /// The timestamp the broker added to the message
- /// </summary>
- public DateTime NMSTimestamp
- {
- get { return DateUtils.ToDateTime(Timestamp); }
- set
- {
- Timestamp = DateUtils.ToJavaTimeUtc(value);
- if(timeToLive.TotalMilliseconds > 0)
- {
- Expiration = Timestamp + (long) timeToLive.TotalMilliseconds;
- }
- }
- }
-
- /// <summary>
- /// The type name of this message
- /// </summary>
- public string NMSType
- {
- get { return Type; }
- set { Type = value; }
- }
-
- #endregion
-
- #region NMS Extension headers
-
- /// <summary>
- /// Returns the number of times this message has been redelivered to other consumers without being acknowledged successfully.
- /// </summary>
- public int NMSXDeliveryCount
- {
- get { return RedeliveryCounter + 1; }
- }
-
- /// <summary>
- /// The Message Group ID used to group messages together to the same consumer for the same group ID value
- /// </summary>
- public string NMSXGroupID
- {
- get { return GroupID; }
- set { GroupID = value; }
- }
- /// <summary>
- /// The Message Group Sequence counter to indicate the position in a group
- /// </summary>
- public int NMSXGroupSeq
- {
- get { return GroupSequence; }
- set { GroupSequence = value; }
- }
-
- /// <summary>
- /// Returns the ID of the producers transaction
- /// </summary>
- public string NMSXProducerTXID
- {
- get
- {
- TransactionId txnId = OriginalTransactionId;
- if(null == txnId)
- {
- txnId = TransactionId;
- }
-
- if(null != txnId)
- {
- return BaseDataStreamMarshaller.ToString(txnId);
- }
-
- return String.Empty;
- }
- }
-
- #endregion
-
- public object GetObjectProperty(string name)
- {
- return Properties[name];
- }
-
- public void SetObjectProperty(string name, object value)
- {
- Properties[name] = value;
- }
-
- // MarshallAware interface
- public override bool IsMarshallAware()
- {
- return true;
- }
-
- public override void BeforeMarshall(OpenWireFormat wireFormat)
- {
- MarshalledProperties = null;
- if(properties != null)
- {
- MarshalledProperties = properties.Marshal();
- }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processMessage(this);
- }
- }
+ public class ActiveMQMessage : Message, IMessage, MarshallAware
+ {
+ public const byte ID_ACTIVEMQMESSAGE = 23;
+
+ private MessagePropertyHelper propertyHelper;
+ private PrimitiveMap properties;
+
+ public event AcknowledgeHandler Acknowledger;
+
+ public static ActiveMQMessage Transform(IMessage message)
+ {
+ return (ActiveMQMessage) message;
+ }
+
+ // TODO generate Equals method
+ // TODO generate GetHashCode method
+
+ public ActiveMQMessage()
+ : base()
+ {
+ Timestamp = DateUtils.ToJavaTimeUtc(DateTime.UtcNow);
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return ID_ACTIVEMQMESSAGE;
+ }
+
+ public void Acknowledge()
+ {
+ if(null == Acknowledger)
+ {
+ throw new NMSException("No Acknowledger has been associated with this message: " + this);
+ }
+ else
+ {
+ Acknowledger(this);
+ }
+ }
+
+ #region Properties
+
+ public IPrimitiveMap Properties
+ {
+ get
+ {
+ if(null == properties)
+ {
+ properties = PrimitiveMap.Unmarshal(MarshalledProperties);
+ propertyHelper = new MessagePropertyHelper(this, properties);
+ }
+
+ return propertyHelper;
+ }
+ }
+
+ public IDestination FromDestination
+ {
+ get { return Destination; }
+ set { this.Destination = ActiveMQDestination.Transform(value); }
+ }
+
+ /// <summary>
+ /// The correlation ID used to correlate messages with conversations or long running business processes
+ /// </summary>
+ public string NMSCorrelationID
+ {
+ get { return CorrelationId; }
+ set { CorrelationId = value; }
+ }
+
+ /// <summary>
+ /// The destination of the message
+ /// </summary>
+ public IDestination NMSDestination
+ {
+ get { return Destination; }
+ }
+
+ private TimeSpan timeToLive = TimeSpan.FromMilliseconds(0);
+ /// <summary>
+ /// The time in milliseconds that this message should expire in
+ /// </summary>
+ public TimeSpan NMSTimeToLive
+ {
+ get { return timeToLive; }
+
+ set
+ {
+ timeToLive = value;
+ if(timeToLive.TotalMilliseconds > 0)
+ {
+ Expiration = Timestamp + (long) timeToLive.TotalMilliseconds;
+ }
+ else
+ {
+ Expiration = 0;
+ }
+ }
+ }
+
+ /// <summary>
+ /// The message ID which is set by the provider
+ /// </summary>
+ public string NMSMessageId
+ {
+ get
+ {
+ if(null != MessageId)
+ {
+ return BaseDataStreamMarshaller.ToString(MessageId);
+ }
+
+ return String.Empty;
+ }
+ }
+
+ /// <summary>
+ /// Whether or not this message is persistent
+ /// </summary>
+ public MsgDeliveryMode NMSDeliveryMode
+ {
+ get { return (Persistent ? MsgDeliveryMode.Persistent : MsgDeliveryMode.NonPersistent); }
+ set { Persistent = (MsgDeliveryMode.Persistent == value); }
+ }
+
+ /// <summary>
+ /// The Priority on this message
+ /// </summary>
+ public MsgPriority NMSPriority
+ {
+ get { return (MsgPriority) Priority; }
+ set { Priority = (byte) value; }
+ }
+
+ /// <summary>
+ /// Returns true if this message has been redelivered to this or another consumer before being acknowledged successfully.
+ /// </summary>
+ public bool NMSRedelivered
+ {
+ get { return (RedeliveryCounter > 0); }
+ }
+
+ /// <summary>
+ /// The destination that the consumer of this message should send replies to
+ /// </summary>
+ public IDestination NMSReplyTo
+ {
+ get { return ReplyTo; }
+ set { ReplyTo = ActiveMQDestination.Transform(value); }
+ }
+
+ /// <summary>
+ /// The timestamp the broker added to the message
+ /// </summary>
+ public DateTime NMSTimestamp
+ {
+ get { return DateUtils.ToDateTime(Timestamp); }
+ set
+ {
+ Timestamp = DateUtils.ToJavaTimeUtc(value);
+ if(timeToLive.TotalMilliseconds > 0)
+ {
+ Expiration = Timestamp + (long) timeToLive.TotalMilliseconds;
+ }
+ }
+ }
+
+ /// <summary>
+ /// The type name of this message
+ /// </summary>
+ public string NMSType
+ {
+ get { return Type; }
+ set { Type = value; }
+ }
+
+ #endregion
+
+ #region NMS Extension headers
+
+ /// <summary>
+ /// Returns the number of times this message has been redelivered to other consumers without being acknowledged successfully.
+ /// </summary>
+ public int NMSXDeliveryCount
+ {
+ get { return RedeliveryCounter + 1; }
+ }
+
+ /// <summary>
+ /// The Message Group ID used to group messages together to the same consumer for the same group ID value
+ /// </summary>
+ public string NMSXGroupID
+ {
+ get { return GroupID; }
+ set { GroupID = value; }
+ }
+ /// <summary>
+ /// The Message Group Sequence counter to indicate the position in a group
+ /// </summary>
+ public int NMSXGroupSeq
+ {
+ get { return GroupSequence; }
+ set { GroupSequence = value; }
+ }
+
+ /// <summary>
+ /// Returns the ID of the producers transaction
+ /// </summary>
+ public string NMSXProducerTXID
+ {
+ get
+ {
+ TransactionId txnId = OriginalTransactionId;
+ if(null == txnId)
+ {
+ txnId = TransactionId;
+ }
+
+ if(null != txnId)
+ {
+ return BaseDataStreamMarshaller.ToString(txnId);
+ }
+
+ return String.Empty;
+ }
+ }
+
+ #endregion
+
+ public object GetObjectProperty(string name)
+ {
+ return Properties[name];
+ }
+
+ public void SetObjectProperty(string name, object value)
+ {
+ Properties[name] = value;
+ }
+
+ // MarshallAware interface
+ public override bool IsMarshallAware()
+ {
+ return true;
+ }
+
+ public override void BeforeMarshall(OpenWireFormat wireFormat)
+ {
+ MarshalledProperties = null;
+ if(properties != null)
+ {
+ MarshalledProperties = properties.Marshal();
+ }
+ }
+
+ public override Response visit(ICommandVisitor visitor)
+ {
+ return visitor.processMessage(this);
+ }
+ }
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQObjectMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQObjectMessage.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQObjectMessage.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQObjectMessage.cs Thu Jul 30 19:06:34 2009
@@ -40,29 +40,29 @@
//
public class ActiveMQObjectMessage : ActiveMQMessage, IObjectMessage
{
- public const byte ID_ActiveMQObjectMessage = 26;
-
+ public const byte ID_ACTIVEMQOBJECTMESSAGE = 26;
+
#if !(PocketPC||NETCF||NETCF_2_0)
private object body;
private IFormatter formatter;
#endif
- public override string ToString() {
+ public override string ToString() {
return GetType().Name + "["
+ " ]";
- }
-
+ }
+
public override byte GetDataStructureType() {
- return ID_ActiveMQObjectMessage;
+ return ID_ACTIVEMQOBJECTMESSAGE;
}
// Properties
-
+
public object Body
{
- get
- {
+ get
+ {
#if !(PocketPC||NETCF||NETCF_2_0)
if (body == null)
{
@@ -74,10 +74,10 @@
#endif
}
- set
- {
+ set
+ {
#if !(PocketPC||NETCF||NETCF_2_0)
- body = value;
+ body = value;
#else
throw new NotImplementedException();
#endif
@@ -93,32 +93,32 @@
}
else
{
- MemoryStream stream = new MemoryStream();
- Formatter.Serialize(stream, body);
+ MemoryStream stream = new MemoryStream();
+ Formatter.Serialize(stream, body);
Content = stream.ToArray();
}
-
+
//Console.WriteLine("BeforeMarshalling, content is: " + Content);
-
+
base.BeforeMarshall(wireFormat);
}
- public IFormatter Formatter
- {
- get
- {
- if (formatter == null)
- {
- formatter = new BinaryFormatter();
- }
- return formatter;
- }
-
- set
- {
- formatter = value;
- }
- }
+ public IFormatter Formatter
+ {
+ get
+ {
+ if (formatter == null)
+ {
+ formatter = new BinaryFormatter();
+ }
+ return formatter;
+ }
+
+ set
+ {
+ formatter = value;
+ }
+ }
#endif
}
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQQueue.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQQueue.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQQueue.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQQueue.cs Thu Jul 30 19:06:34 2009
@@ -19,64 +19,64 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// Summary description for ActiveMQQueue.
- /// </summary>
- public class ActiveMQQueue : ActiveMQDestination, IQueue
- {
- public const byte ID_ActiveMQQueue = 100;
-
- public ActiveMQQueue()
- : base()
- {
- }
- public ActiveMQQueue(String name)
- : base(name)
- {
- }
-
- override public DestinationType DestinationType
- {
- get
- {
- return DestinationType.Queue;
- }
- }
-
- public String QueueName
- {
- get { return PhysicalName; }
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ActiveMQQueue;
- }
-
- public override int GetDestinationType()
- {
- return ACTIVEMQ_QUEUE;
- }
-
- public override ActiveMQDestination CreateDestination(String name)
- {
- return new ActiveMQQueue(name);
- }
-
- public override Object Clone()
- {
- // Since we are a derived class use the base's Clone()
- // to perform the shallow copy. Since it is shallow it
- // will include our derived class. Since we are derived,
- // this method is an override.
- ActiveMQQueue o = (ActiveMQQueue) base.Clone();
-
- // Now do the deep work required
- // If any new variables are added then this routine will
- // likely need updating
-
- return o;
- }
- }
+ /// <summary>
+ /// Summary description for ActiveMQQueue.
+ /// </summary>
+ public class ActiveMQQueue : ActiveMQDestination, IQueue
+ {
+ public const byte ID_ACTIVEMQQUEUE = 100;
+
+ public ActiveMQQueue()
+ : base()
+ {
+ }
+ public ActiveMQQueue(String name)
+ : base(name)
+ {
+ }
+
+ override public DestinationType DestinationType
+ {
+ get
+ {
+ return DestinationType.Queue;
+ }
+ }
+
+ public String QueueName
+ {
+ get { return PhysicalName; }
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return ID_ACTIVEMQQUEUE;
+ }
+
+ public override int GetDestinationType()
+ {
+ return ACTIVEMQ_QUEUE;
+ }
+
+ public override ActiveMQDestination CreateDestination(String name)
+ {
+ return new ActiveMQQueue(name);
+ }
+
+ public override Object Clone()
+ {
+ // Since we are a derived class use the base's Clone()
+ // to perform the shallow copy. Since it is shallow it
+ // will include our derived class. Since we are derived,
+ // this method is an override.
+ ActiveMQQueue o = (ActiveMQQueue) base.Clone();
+
+ // Now do the deep work required
+ // If any new variables are added then this routine will
+ // likely need updating
+
+ return o;
+ }
+ }
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQStreamMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQStreamMessage.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQStreamMessage.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQStreamMessage.cs Thu Jul 30 19:06:34 2009
@@ -19,26 +19,26 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- public class ActiveMQStreamMessage : ActiveMQMessage
+ public class ActiveMQStreamMessage : ActiveMQMessage
{
- public const byte ID_ActiveMQStreamMessage = 27;
-
-
-
-
+ public const byte ID_ACTIVEMQSTREAMMESSAGE = 27;
+
+
+
+
// TODO generate Equals method
// TODO generate GetHashCode method
// TODO generate ToString method
-
-
+
+
public override byte GetDataStructureType()
- {
- return ID_ActiveMQStreamMessage;
+ {
+ return ID_ACTIVEMQSTREAMMESSAGE;
}
-
-
+
+
// Properties
-
+
}
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempQueue.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempQueue.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempQueue.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempQueue.cs Thu Jul 30 19:06:34 2009
@@ -19,66 +19,66 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// A Temporary Queue
- /// </summary>
- public class ActiveMQTempQueue : ActiveMQTempDestination, ITemporaryQueue
- {
- public const byte ID_ActiveMQTempQueue = 102;
-
- public ActiveMQTempQueue()
- : base()
- {
- }
-
- public ActiveMQTempQueue(String name)
- : base(name)
- {
- }
-
- override public DestinationType DestinationType
- {
- get
- {
- return DestinationType.TemporaryQueue;
- }
- }
-
- public String GetQueueName()
- {
- return PhysicalName;
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ActiveMQTempQueue;
- }
+ /// <summary>
+ /// A Temporary Queue
+ /// </summary>
+ public class ActiveMQTempQueue : ActiveMQTempDestination, ITemporaryQueue
+ {
+ public const byte ID_ACTIVEMQTEMPQUEUE = 102;
+
+ public ActiveMQTempQueue()
+ : base()
+ {
+ }
+
+ public ActiveMQTempQueue(String name)
+ : base(name)
+ {
+ }
+
+ override public DestinationType DestinationType
+ {
+ get
+ {
+ return DestinationType.TemporaryQueue;
+ }
+ }
+
+ public String GetQueueName()
+ {
+ return PhysicalName;
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return ID_ACTIVEMQTEMPQUEUE;
+ }
- public override int GetDestinationType()
- {
+ public override int GetDestinationType()
+ {
return ACTIVEMQ_TEMPORARY_QUEUE;
- }
+ }
- public override ActiveMQDestination CreateDestination(String name)
- {
- return new ActiveMQTempQueue(name);
- }
-
- public override Object Clone()
- {
- // Since we are a derived class use the base's Clone()
- // to perform the shallow copy. Since it is shallow it
- // will include our derived class. Since we are derived,
- // this method is an override.
- ActiveMQTempQueue o = (ActiveMQTempQueue) base.Clone();
-
- // Now do the deep work required
- // If any new variables are added then this routine will
- // likely need updating
+ public override ActiveMQDestination CreateDestination(String name)
+ {
+ return new ActiveMQTempQueue(name);
+ }
+
+ public override Object Clone()
+ {
+ // Since we are a derived class use the base's Clone()
+ // to perform the shallow copy. Since it is shallow it
+ // will include our derived class. Since we are derived,
+ // this method is an override.
+ ActiveMQTempQueue o = (ActiveMQTempQueue) base.Clone();
+
+ // Now do the deep work required
+ // If any new variables are added then this routine will
+ // likely need updating
- return o;
- }
+ return o;
+ }
- }
+ }
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempTopic.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempTopic.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempTopic.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTempTopic.cs Thu Jul 30 19:06:34 2009
@@ -19,67 +19,67 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// A Temporary Topic
- /// </summary>
- public class ActiveMQTempTopic : ActiveMQTempDestination, ITemporaryTopic
- {
- public const byte ID_ActiveMQTempTopic = 103;
-
- public ActiveMQTempTopic()
- : base()
- {
- }
-
- public ActiveMQTempTopic(String name)
- : base(name)
- {
- }
-
- override public DestinationType DestinationType
- {
- get
- {
- return DestinationType.TemporaryTopic;
- }
- }
-
-
- public String GetTopicName()
- {
- return PhysicalName;
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ActiveMQTempTopic;
- }
+ /// <summary>
+ /// A Temporary Topic
+ /// </summary>
+ public class ActiveMQTempTopic : ActiveMQTempDestination, ITemporaryTopic
+ {
+ public const byte ID_ACTIVEMQTEMPTOPIC = 103;
+
+ public ActiveMQTempTopic()
+ : base()
+ {
+ }
+
+ public ActiveMQTempTopic(String name)
+ : base(name)
+ {
+ }
+
+ override public DestinationType DestinationType
+ {
+ get
+ {
+ return DestinationType.TemporaryTopic;
+ }
+ }
+
+
+ public String GetTopicName()
+ {
+ return PhysicalName;
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return ID_ACTIVEMQTEMPTOPIC;
+ }
- public override int GetDestinationType()
- {
+ public override int GetDestinationType()
+ {
return ACTIVEMQ_TEMPORARY_TOPIC;
- }
+ }
- public override ActiveMQDestination CreateDestination(String name)
- {
- return new ActiveMQTempTopic(name);
- }
-
- public override Object Clone()
- {
- // Since we are a derived class use the base's Clone()
- // to perform the shallow copy. Since it is shallow it
- // will include our derived class. Since we are derived,
- // this method is an override.
- ActiveMQTempTopic o = (ActiveMQTempTopic) base.Clone();
-
- // Now do the deep work required
- // If any new variables are added then this routine will
- // likely need updating
+ public override ActiveMQDestination CreateDestination(String name)
+ {
+ return new ActiveMQTempTopic(name);
+ }
+
+ public override Object Clone()
+ {
+ // Since we are a derived class use the base's Clone()
+ // to perform the shallow copy. Since it is shallow it
+ // will include our derived class. Since we are derived,
+ // this method is an override.
+ ActiveMQTempTopic o = (ActiveMQTempTopic) base.Clone();
+
+ // Now do the deep work required
+ // If any new variables are added then this routine will
+ // likely need updating
- return o;
- }
+ return o;
+ }
- }
+ }
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTextMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTextMessage.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTextMessage.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTextMessage.cs Thu Jul 30 19:06:34 2009
@@ -21,37 +21,37 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- public class ActiveMQTextMessage : ActiveMQMessage, ITextMessage
+ public class ActiveMQTextMessage : ActiveMQMessage, ITextMessage
{
- public const byte ID_ActiveMQTextMessage = 28;
-
+ public const byte ID_ACTIVEMQTEXTMESSAGE = 28;
+
private String text;
-
+
public ActiveMQTextMessage()
{
}
-
+
public ActiveMQTextMessage(String text)
{
this.Text = text;
}
-
+
// TODO generate Equals method
// TODO generate GetHashCode method
// TODO generate ToString method
- public override string ToString()
- {
- return base.ToString() + " Text="+Text;
- }
+ public override string ToString()
+ {
+ return base.ToString() + " Text="+Text;
+ }
- public override byte GetDataStructureType()
+ public override byte GetDataStructureType()
{
- return ID_ActiveMQTextMessage;
+ return ID_ACTIVEMQTEXTMESSAGE;
}
-
+
// Properties
-
+
public string Text
{
get {
@@ -68,13 +68,13 @@
}
return text;
}
-
+
set {
this.text = value;
byte[] data = null;
if (text != null)
{
- // TODO lets make the evaluation of the Content lazy!
+ // TODO lets make the evaluation of the Content lazy!
// Set initial size to the size of the string the UTF-8 encode could
// result in more if there are chars that encode to multibye values.
@@ -84,9 +84,9 @@
writer.WriteString32(text);
data = stream.GetBuffer();
- }
- this.Content = data;
-
+ }
+ this.Content = data;
+
}
}
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTopic.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTopic.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTopic.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ActiveMQTopic.cs Thu Jul 30 19:06:34 2009
@@ -19,65 +19,65 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// Summary description for ActiveMQTopic.
- /// </summary>
- public class ActiveMQTopic : ActiveMQDestination, ITopic
- {
- public const byte ID_ActiveMQTopic = 101;
-
- public ActiveMQTopic()
- : base()
- {
- }
- public ActiveMQTopic(String name)
- : base(name)
- {
- }
-
- override public DestinationType DestinationType
- {
- get
- {
- return DestinationType.Topic;
- }
- }
-
-
- public String TopicName
- {
- get { return PhysicalName; }
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ActiveMQTopic;
- }
-
- public override int GetDestinationType()
- {
- return ACTIVEMQ_TOPIC;
- }
-
- public override ActiveMQDestination CreateDestination(String name)
- {
- return new ActiveMQTopic(name);
- }
-
- public override Object Clone()
- {
- // Since we are a derived class use the base's Clone()
- // to perform the shallow copy. Since it is shallow it
- // will include our derived class. Since we are derived,
- // this method is an override.
- ActiveMQTopic o = (ActiveMQTopic) base.Clone();
-
- // Now do the deep work required
- // If any new variables are added then this routine will
- // likely need updating
-
- return o;
- }
- }
+ /// <summary>
+ /// Summary description for ActiveMQTopic.
+ /// </summary>
+ public class ActiveMQTopic : ActiveMQDestination, ITopic
+ {
+ public const byte ID_ACTIVEMQTOPIC = 101;
+
+ public ActiveMQTopic()
+ : base()
+ {
+ }
+ public ActiveMQTopic(String name)
+ : base(name)
+ {
+ }
+
+ override public DestinationType DestinationType
+ {
+ get
+ {
+ return DestinationType.Topic;
+ }
+ }
+
+
+ public String TopicName
+ {
+ get { return PhysicalName; }
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return ID_ACTIVEMQTOPIC;
+ }
+
+ public override int GetDestinationType()
+ {
+ return ACTIVEMQ_TOPIC;
+ }
+
+ public override ActiveMQDestination CreateDestination(String name)
+ {
+ return new ActiveMQTopic(name);
+ }
+
+ public override Object Clone()
+ {
+ // Since we are a derived class use the base's Clone()
+ // to perform the shallow copy. Since it is shallow it
+ // will include our derived class. Since we are derived,
+ // this method is an override.
+ ActiveMQTopic o = (ActiveMQTopic) base.Clone();
+
+ // Now do the deep work required
+ // If any new variables are added then this routine will
+ // likely need updating
+
+ return o;
+ }
+ }
}