activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject 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/
Date Thu, 30 Jul 2009 19:06:44 GMT
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;
+        }
+    }
 }
 



Mime
View raw message