activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r383295 [1/4] - in /incubator/activemq/trunk/openwire-dotnet: src/ src/ActiveMQ/ src/ActiveMQ/Commands/ src/ActiveMQ/OpenWire/ src/ActiveMQ/OpenWire/Commands/ src/ActiveMQ/OpenWire/V1/ src/ActiveMQ/Transport/ src/JMS/ tests/ tests/ActiveMQ/...
Date Sun, 05 Mar 2006 08:29:09 GMT
Author: chirino
Date: Sun Mar  5 00:28:53 2006
New Revision: 383295

URL: http://svn.apache.org/viewcvs?rev=383295&view=rev
Log:
Some more refactors:
 Moving the jms type interfaces to the JMS namespace, hopefully this will be come a standardized set of interfaces
 for dotnet in the furture.


Added:
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQBytesMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMapMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQObjectMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQStreamMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempDestination.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTextMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BaseCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionError.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ControlCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataArrayResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DestinationInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DiscoveryEvent.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ExceptionResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/FlushCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/IntegerResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalQueueAck.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTopicAck.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTrace.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTransaction.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/KeepAliveInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/LocalTransactionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Message.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageAck.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatch.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatchNotification.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveSubscriptionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Response.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ShutdownInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SubscriptionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/TransactionContext.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/ITransport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/SocketTransport.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageConsumer.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageProducer.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IPrimitiveMap.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ISession.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IStartable.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IStoppable.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryTopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ITextMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ITopic.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/Commands/
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/Commands/CommandTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/CommandTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/EndianTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/EndianTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/AsyncConsumeTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/AsyncConsumeTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/BadConsumeTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BadConsumeTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/BytesMessageTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BytesMessageTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/ConsumerTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ConsumerTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/JMSPropertyTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/JMSPropertyTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/JMSTestSupport.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/MapMessageTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/MapMessageTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/TextMessage.cs
    incubator/activemq/trunk/openwire-dotnet/tests/JMS/TransactionTest.cs
      - copied, changed from r383283, incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TransactionTest.cs
Removed:
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IBytesMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnection.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnectionFactory.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IDestination.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMapMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageConsumer.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageProducer.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IPrimitiveMap.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ISession.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IStartable.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryTopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITextMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Commands/
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/ITransport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/SocketTransport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/TransactionContext.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/AsyncConsumeTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BadConsumeTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BytesMessageTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ClientTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/CommandTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ConsumerTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/EndianTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/JMSPropertyTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/MapMessageTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestSupport.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TransactionTest.cs
Modified:
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs
    incubator/activemq/trunk/openwire-dotnet/src/src.csproj
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestMain.cs
    incubator/activemq/trunk/openwire-dotnet/tests/tests.csproj

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQBytesMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQBytesMessage.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQBytesMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQBytesMessage.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,34 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using JMS;
+
+
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQBytesMessage : ActiveMQMessage, IBytesMessage
+    {
+        public const byte ID_ActiveMQBytesMessage = 24;
+        
+        
+        public override byte GetDataStructureType()
+        {
+            return ID_ActiveMQBytesMessage;
+        }
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,532 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ;
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using JMS;
+using System;
+
+
+
+/// <summary>
+/// Summary description for ActiveMQDestination.
+/// </summary>
+namespace ActiveMQ.Commands
+{
+	public abstract class ActiveMQDestination : AbstractCommand, IDestination
+    {
+        
+        /**
+         * Topic Destination object
+         */
+        public const int ACTIVEMQ_TOPIC = 1;
+        /**
+         * Temporary Topic Destination object
+         */
+        public const int ACTIVEMQ_TEMPORARY_TOPIC = 2;
+        
+        /**
+         * Queue Destination object
+         */
+        public const int ACTIVEMQ_QUEUE = 3;
+        /**
+         * Temporary Queue Destination object
+         */
+        public const int ACTIVEMQ_TEMPORARY_QUEUE = 4;
+        
+        /**
+         * prefix for Advisory message destinations
+         */
+        public const String ADVISORY_PREFIX = "ActiveMQ.Advisory.";
+        
+        /**
+         * prefix for consumer advisory destinations
+         */
+        public const String CONSUMER_ADVISORY_PREFIX = ADVISORY_PREFIX + "Consumers.";
+        
+        /**
+         * prefix for producer advisory destinations
+         */
+        public const String PRODUCER_ADVISORY_PREFIX = ADVISORY_PREFIX + "Producers.";
+        
+        /**
+         * prefix for connection advisory destinations
+         */
+        public const String CONNECTION_ADVISORY_PREFIX = ADVISORY_PREFIX + "Connections.";
+        
+        /**
+         * The default target for ordered destinations
+         */
+        public const String DEFAULT_ORDERED_TARGET = "coordinator";
+        
+        private const int NULL_DESTINATION = 10;
+        
+        private const String TEMP_PREFIX = "{TD{";
+        private const String TEMP_POSTFIX = "}TD}";
+        private const String COMPOSITE_SEPARATOR = ",";
+        private const String QUEUE_PREFIX = "queue://";
+        private const String TOPIC_PREFIX = "topic://";
+        
+        
+        private String physicalName = "";
+        
+        // Cached transient data
+        private bool exclusive;
+        private bool ordered;
+        private bool advisory;
+        private String orderedTarget = DEFAULT_ORDERED_TARGET;
+        
+        
+        /**
+         * The Default Constructor
+         */
+        protected ActiveMQDestination()
+        {
+        }
+        
+        /**
+         * Construct the Destination with a defined physical name;
+         *
+         * @param name
+         */
+        protected ActiveMQDestination(String name)
+        {
+            this.physicalName = name;
+            this.advisory = name != null && name.StartsWith(ADVISORY_PREFIX);
+        }
+        
+        
+        
+        /**
+         * @return Returns the advisory.
+         */
+        public bool IsAdvisory()
+        {
+            return advisory;
+        }
+        /**
+         * @param advisory The advisory to set.
+         */
+        public void SetAdvisory(bool advisory)
+        {
+            this.advisory = advisory;
+        }
+        
+        /**
+         * @return true if this is a destination for Consumer advisories
+         */
+        public bool IsConsumerAdvisory()
+        {
+            return IsAdvisory() && physicalName.StartsWith(CONSUMER_ADVISORY_PREFIX);
+        }
+        
+        /**
+         * @return true if this is a destination for Producer advisories
+         */
+        public bool IsProducerAdvisory()
+        {
+            return IsAdvisory() && physicalName.StartsWith(PRODUCER_ADVISORY_PREFIX);
+        }
+        
+        /**
+         * @return true if this is a destination for Connection advisories
+         */
+        public bool IsConnectionAdvisory()
+        {
+            return IsAdvisory() && physicalName.StartsWith(CONNECTION_ADVISORY_PREFIX);
+        }
+        
+        /**
+         * @return Returns the exclusive.
+         */
+        public bool IsExclusive()
+        {
+            return exclusive;
+        }
+        /**
+         * @param exclusive The exclusive to set.
+         */
+        public void SetExclusive(bool exclusive)
+        {
+            this.exclusive = exclusive;
+        }
+        /**
+         * @return Returns the ordered.
+         */
+        public bool IsOrdered()
+        {
+            return ordered;
+        }
+        /**
+         * @param ordered The ordered to set.
+         */
+        public void SetOrdered(bool ordered)
+        {
+            this.ordered = ordered;
+        }
+        /**
+         * @return Returns the orderedTarget.
+         */
+        public String GetOrderedTarget()
+        {
+            return orderedTarget;
+        }
+        /**
+         * @param orderedTarget The orderedTarget to set.
+         */
+        public void SetOrderedTarget(String orderedTarget)
+        {
+            this.orderedTarget = orderedTarget;
+        }
+        /**
+         * A helper method to return a descriptive string for the topic or queue
+         * @param destination
+         *
+         * @return a descriptive string for this queue or topic
+         */
+        public static String Inspect(ActiveMQDestination destination)
+        {
+            if (destination is ITopic)
+            {
+                return "Topic(" + destination.ToString() + ")";
+            }
+            else
+            {
+                return "Queue(" + destination.ToString() + ")";
+            }
+        }
+        
+        /**
+         * @param destination
+         * @return @throws JMSException
+         * @throws javax.jms.JMSException
+         */
+        public static ActiveMQDestination Transform(IDestination destination)
+        {
+            ActiveMQDestination result = null;
+            if (destination != null)
+            {
+                if (destination is ActiveMQDestination)
+                {
+                    result = (ActiveMQDestination) destination;
+                }
+                else
+                {
+                    if (destination is ITemporaryQueue)
+                    {
+                        result = new ActiveMQTempQueue(((IQueue) destination).QueueName);
+                    }
+                    else if (destination is ITemporaryTopic)
+                    {
+                        result = new ActiveMQTempTopic(((ITopic) destination).TopicName);
+                    }
+                    else if (destination is IQueue)
+                    {
+                        result = new ActiveMQQueue(((IQueue) destination).QueueName);
+                    }
+                    else if (destination is ITopic)
+                    {
+                        result = new ActiveMQTopic(((ITopic) destination).TopicName);
+                    }
+                }
+            }
+            return result;
+        }
+        
+        /**
+         * Create a Destination
+         * @param type
+         * @param pyhsicalName
+         * @return
+         */
+        public static ActiveMQDestination CreateDestination(int type, String pyhsicalName)
+        {
+            ActiveMQDestination result = null;
+            if (type == ACTIVEMQ_TOPIC)
+            {
+                result = new ActiveMQTopic(pyhsicalName);
+            }
+            else if (type == ACTIVEMQ_TEMPORARY_TOPIC)
+            {
+                result = new ActiveMQTempTopic(pyhsicalName);
+            }
+            else if (type == ACTIVEMQ_QUEUE)
+            {
+                result = new ActiveMQQueue(pyhsicalName);
+            }
+            else
+            {
+                result = new ActiveMQTempQueue(pyhsicalName);
+            }
+            return result;
+        }
+        
+        /**
+         * Create a temporary name from the clientId
+         *
+         * @param clientId
+         * @return
+         */
+        public static String CreateTemporaryName(String clientId)
+        {
+            return TEMP_PREFIX + clientId + TEMP_POSTFIX;
+        }
+        
+        /**
+         * From a temporary destination find the clientId of the Connection that created it
+         *
+         * @param destination
+         * @return the clientId or null if not a temporary destination
+         */
+        public static String GetClientId(ActiveMQDestination destination)
+        {
+            String answer = null;
+            if (destination != null && destination.IsTemporary())
+            {
+                String name = destination.PhysicalName;
+                int start = name.IndexOf(TEMP_PREFIX);
+                if (start >= 0)
+                {
+                    start += TEMP_PREFIX.Length;
+                    int stop = name.LastIndexOf(TEMP_POSTFIX);
+                    if (stop > start && stop < name.Length)
+                    {
+                        answer = name.Substring(start, stop);
+                    }
+                }
+            }
+            return answer;
+        }
+        
+        
+        /**
+         * @param o object to compare
+         * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
+         */
+        public int CompareTo(Object o)
+        {
+            if (o is ActiveMQDestination)
+            {
+                return CompareTo((ActiveMQDestination) o);
+            }
+            return -1;
+        }
+        
+        /**
+         * Lets sort by name first then lets sort topics greater than queues
+         *
+         * @param that another destination to compare against
+         * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
+         */
+        public int CompareTo(ActiveMQDestination that)
+        {
+            int answer = 0;
+            if (physicalName != that.physicalName)
+            {
+                if (physicalName == null)
+                {
+                    return -1;
+                }
+                else if (that.physicalName == null)
+                {
+                    return 1;
+                }
+                answer = physicalName.CompareTo(that.physicalName);
+            }
+            if (answer == 0)
+            {
+                if (IsTopic())
+                {
+                    if (that.IsQueue())
+                    {
+                        return 1;
+                    }
+                }
+                else
+                {
+                    if (that.IsTopic())
+                    {
+                        return -1;
+                    }
+                }
+            }
+            return answer;
+        }
+        
+        
+        /**
+         * @return Returns the Destination type
+         */
+        
+        public abstract int GetDestinationType();
+        
+        
+        public String PhysicalName
+        {
+            get { return this.physicalName; }
+            set { this.physicalName = value; }
+        }
+        
+        /**
+         * Returns true if a temporary Destination
+         *
+         * @return true/false
+         */
+        
+        public bool IsTemporary()
+        {
+            return GetDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC
+                || GetDestinationType() == ACTIVEMQ_TEMPORARY_QUEUE;
+        }
+        
+        /**
+         * Returns true if a Topic Destination
+         *
+         * @return true/false
+         */
+        
+        public bool IsTopic()
+        {
+            return GetDestinationType() == ACTIVEMQ_TOPIC
+                || GetDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC;
+        }
+        
+        /**
+         * Returns true if a Queue Destination
+         *
+         * @return true/false
+         */
+        public bool IsQueue()
+        {
+            return !IsTopic();
+        }
+        
+        /**
+         * Returns true if this destination represents a collection of
+         * destinations; allowing a set of destinations to be published to or subscribed
+         * from in one JMS operation.
+         * <p/>
+         * If this destination is a composite then you can call {@link #getChildDestinations()}
+         * to return the list of child destinations.
+         *
+         * @return true if this destination represents a collection of child destinations.
+         */
+        public bool IsComposite()
+        {
+            return physicalName.IndexOf(COMPOSITE_SEPARATOR) > 0;
+        }
+        
+        /*
+         * Returns a list of child destinations if this destination represents a composite
+         * destination.
+         *
+         * @return
+         */
+        /*public List GetChildDestinations() {
+         List answer = new ArrayList();
+         StringTokenizer iter = new StringTokenizer(physicalName, COMPOSITE_SEPARATOR);
+         while (iter.hasMoreTokens()) {
+         String name = iter.nextToken();
+         Destination child = null;
+         if (name.StartsWith(QUEUE_PREFIX)) {
+         child = new ActiveMQQueue(name.Substring(QUEUE_PREFIX.Length));
+         }
+         else if (name.StartsWith(TOPIC_PREFIX)) {
+         child = new ActiveMQTopic(name.Substring(TOPIC_PREFIX.Length));
+         }
+         else {
+         child = createDestination(name);
+         }
+         answer.add(child);
+         }
+         if (answer.size() == 1) {
+         // lets put ourselves inside the collection
+         // as we are not really a composite destination
+         answer.set(0, this);
+         }
+         return answer;
+         }*/
+        
+        /**
+         * @return string representation of this instance
+         */
+        
+        public override String ToString()
+        {
+            return this.physicalName;
+        }
+        
+        /**
+         * @return hashCode for this instance
+         */
+        public override int GetHashCode()
+        {
+            int answer = 37;
+            
+            if (this.physicalName != null)
+            {
+                answer = physicalName.GetHashCode();
+            }
+            if (IsTopic())
+            {
+                answer ^= 0xfabfab;
+            }
+            return answer;
+        }
+        
+        /**
+         * if the object passed in is equivalent, return true
+         *
+         * @param obj the object to compare
+         * @return true if this instance and obj are equivalent
+         */
+        public override bool Equals(Object obj)
+        {
+            bool result = this == obj;
+            if (!result && obj != null && obj is ActiveMQDestination)
+            {
+                ActiveMQDestination other = (ActiveMQDestination) obj;
+                result = this.GetDestinationType() == other.GetDestinationType()
+                    && this.physicalName.Equals(other.physicalName);
+            }
+            return result;
+        }
+        
+        
+        /**
+         * @return true if the destination matches multiple possible destinations
+         */
+        public bool IsWildcard()
+        {
+            if (physicalName != null)
+            {
+                return physicalName.IndexOf(DestinationFilter.ANY_CHILD) >= 0
+                    || physicalName.IndexOf(DestinationFilter.ANY_DESCENDENT) >= 0;
+            }
+            return false;
+        }
+        
+        
+        /**
+         * Factory method to create a child destination if this destination is a composite
+         * @param name
+         * @return the created Destination
+         */
+        public abstract ActiveMQDestination CreateDestination(String name);
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMapMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMapMessage.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMapMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMapMessage.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,66 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using JMS;
+using System;
+
+
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQMapMessage : ActiveMQMessage, IMapMessage
+    {
+        public const byte ID_ActiveMQMapMessage = 25;
+        
+        private PrimitiveMap body;
+        
+        
+        public override byte GetDataStructureType()
+        {
+            return ID_ActiveMQMapMessage;
+        }
+        
+        public IPrimitiveMap Body
+        {
+            get {
+                if (body == null)
+                {
+                    body = PrimitiveMap.Unmarshal(Content);
+                }
+                return body;
+            }
+        }
+        
+        public override void BeforeMarshall(OpenWireFormat wireFormat)
+        {
+            if (body == null)
+            {
+                Content = null;
+            }
+            else
+            {
+                Content = body.Marshal();
+            }
+            
+            Console.WriteLine("BeforeMarshalling, content is: " + Content);
+			
+            base.BeforeMarshall(wireFormat);
+        }
+        
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMessage.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQMessage.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,318 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ;
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using JMS;
+
+
+namespace ActiveMQ.Commands
+{
+	public delegate void AcknowledgeHandler(ActiveMQMessage message);
+}
+
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQMessage : Message, IMessage, MarshallAware
+    {
+        public const byte ID_ActiveMQMessage = 23;
+        
+        protected static MessagePropertyHelper propertyHelper = new MessagePropertyHelper();
+        
+        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 override byte GetDataStructureType()
+        {
+            return ID_ActiveMQMessage;
+        }
+        
+        public void Acknowledge()
+        {
+            if (Acknowledger == null)
+			{
+                throw new OpenWireException("No Acknowledger has been associated with this message: " + this);
+			}
+            else
+			{
+                Acknowledger(this);
+            }
+        }
+        
+        
+        // Properties
+        
+        public IPrimitiveMap Properties
+        {
+            get {
+                if (properties == null)
+                {
+                    properties = PrimitiveMap.Unmarshal(MarshalledProperties);
+                }
+                return properties;
+            }
+        }
+        
+        public IDestination FromDestination
+        {
+            get { return Destination; }
+            set { this.Destination = ActiveMQDestination.Transform(value); }
+        }
+        
+        
+        // IMessage interface
+        
+        // JMS headers
+        
+        /// <summary>
+        /// The correlation ID used to correlate messages with conversations or long running business processes
+        /// </summary>
+        public string JMSCorrelationID
+        {
+            get {
+                return CorrelationId;
+            }
+            set {
+                CorrelationId = value;
+            }
+        }
+        
+        /// <summary>
+        /// The destination of the message
+        /// </summary>
+        public IDestination JMSDestination
+        {
+            get {
+                return OriginalDestination;
+            }
+        }
+        
+        /// <summary>
+        /// The time in milliseconds that this message should expire in
+        /// </summary>
+        public long JMSExpiration
+        {
+            get {
+                return Expiration;
+            }
+            set {
+                Expiration = value;
+            }
+        }
+        
+        /// <summary>
+        /// The message ID which is set by the provider
+        /// </summary>
+        public string JMSMessageId
+        {
+            get {
+                return BaseDataStreamMarshaller.ToString(MessageId);
+            }
+        }
+        
+        /// <summary>
+        /// Whether or not this message is persistent
+        /// </summary>
+        public bool JMSPersistent
+        {
+            get {
+                return Persistent;
+            }
+            set {
+                Persistent = value;
+            }
+        }
+        
+        /// <summary>
+        /// The Priority on this message
+        /// </summary>
+        public byte JMSPriority
+        {
+            get {
+                return Priority;
+            }
+            set {
+                Priority = value;
+            }
+        }
+        
+        /// <summary>
+        /// Returns true if this message has been redelivered to this or another consumer before being acknowledged successfully.
+        /// </summary>
+        public bool JMSRedelivered
+        {
+            get {
+                return RedeliveryCounter > 0;
+            }
+        }
+        
+        
+        /// <summary>
+        /// The destination that the consumer of this message should send replies to
+        /// </summary>
+        public IDestination JMSReplyTo
+        {
+            get {
+                return ReplyTo;
+            }
+            set {
+                ReplyTo = ActiveMQDestination.Transform(value);
+            }
+        }
+        
+        
+        /// <summary>
+        /// The timestamp the broker added to the message
+        /// </summary>
+        public long JMSTimestamp
+        {
+            get {
+                return Timestamp;
+            }
+        }
+        
+        /// <summary>
+        /// The type name of this message
+        /// </summary>
+        public string JMSType
+        {
+            get {
+                return Type;
+            }
+            set {
+                Type = value;
+            }
+        }
+        
+        
+        // JMS Extension headers
+        
+        /// <summary>
+        /// Returns the number of times this message has been redelivered to other consumers without being acknowledged successfully.
+        /// </summary>
+        public int JMSXDeliveryCount
+        {
+            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 JMSXGroupID
+        {
+            get {
+                return GroupID;
+            }
+            set {
+                GroupID = value;
+            }
+        }
+        /// <summary>
+        /// The Message Group Sequence counter to indicate the position in a group
+        /// </summary>
+        public int JMSXGroupSeq
+        {
+            get {
+                return GroupSequence;
+            }
+            set {
+                GroupSequence = value;
+            }
+        }
+        
+        /// <summary>
+        /// Returns the ID of the producers transaction
+        /// </summary>
+        public string JMSXProducerTXID
+        {
+            get {
+                TransactionId txnId = OriginalTransactionId;
+                if (txnId == null)
+                {
+                    txnId = TransactionId;
+                }
+                if (txnId != null)
+                {
+                    return BaseDataStreamMarshaller.ToString(txnId);
+                }
+                return null;
+            }
+        }
+        
+        public object GetObjectProperty(string name)
+        {
+            return propertyHelper.GetObjectProperty(this, name);
+        }
+        
+        public void SetObjectProperty(string name, object value)
+        {
+            propertyHelper.SetObjectProperty(this, name, value);
+        }
+        
+        // MarshallAware interface
+        
+        public override bool IsMarshallAware()
+        {
+            return true;
+        }
+        
+        public virtual void BeforeMarshall(OpenWireFormat wireFormat)
+        {
+            MarshalledProperties = null;
+            if (properties != null)
+            {
+                MarshalledProperties = properties.Marshal();
+            }
+        }
+        
+        public virtual void AfterMarshall(OpenWireFormat wireFormat)
+        {
+        }
+        
+        public virtual void BeforeUnmarshall(OpenWireFormat wireFormat)
+        {
+        }
+        
+        public virtual void AfterUnmarshall(OpenWireFormat wireFormat)
+        {
+        }
+        
+        public virtual void SetMarshalledForm(OpenWireFormat wireFormat, byte[] data)
+        {
+        }
+        
+        public virtual byte[] GetMarshalledForm(OpenWireFormat wireFormat)
+        {
+            return null;
+        }
+        
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQObjectMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQObjectMessage.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQObjectMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQObjectMessage.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,55 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  Marshalling code for Open Wire Format for ActiveMQObjectMessage
+    //
+    //
+    //  NOTE!: This file is autogenerated - do not modify!
+    //         if you need to make a change, please see the Groovy scripts in the
+    //         activemq-core module
+    //
+    public class ActiveMQObjectMessage : ActiveMQMessage
+    {
+        public const byte ID_ActiveMQObjectMessage = 26;
+    			
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_ActiveMQObjectMessage;
+        }
+
+
+        // Properties
+
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,59 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using JMS;
+using System;
+
+
+/// <summary>
+/// Summary description for ActiveMQQueue.
+/// </summary>
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQQueue : ActiveMQDestination, IQueue
+    {
+        public const byte ID_ActiveMQQueue = 100;
+        
+        public ActiveMQQueue() : base()
+        {
+        }
+        public ActiveMQQueue(String name) : base(name)
+        {
+        }
+        
+        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);
+        }
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQStreamMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQStreamMessage.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQStreamMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQStreamMessage.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,44 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+
+
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQStreamMessage : ActiveMQMessage
+    {
+		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;
+        }
+		
+		
+        // Properties
+		
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempDestination.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempDestination.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempDestination.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,50 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using System;
+
+
+//
+//  Marshalling code for Open Wire Format for ActiveMQTempDestination
+//
+//
+//  NOTE!: This file is autogenerated - do not modify!
+//         if you need to make a change, please see the Groovy scripts in the
+//         activemq-core module
+//
+namespace ActiveMQ.Commands
+{
+	public abstract class ActiveMQTempDestination : ActiveMQDestination
+    {
+        public const byte ID_ActiveMQTempDestination = 0;
+        
+        public ActiveMQTempDestination() : base()
+        {
+        }
+        
+        public ActiveMQTempDestination(String name) : base(name)
+        {
+        }
+        
+        public override byte GetDataStructureType()
+        {
+            return ID_ActiveMQTempDestination;
+        }
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,60 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using JMS;
+using System;
+
+
+/// <summary>
+/// A Temporary Queue
+/// </summary>
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQTempQueue : ActiveMQTempDestination, ITemporaryQueue
+    {
+        public const byte ID_ActiveMQTempQueue = 102;
+        
+        public ActiveMQTempQueue() : base()
+        {
+        }
+        
+        public ActiveMQTempQueue(String name) : base(name)
+        {
+        }
+        
+        public String GetQueueName()
+        {
+            return PhysicalName;
+        }
+        
+        public override byte GetDataStructureType()
+        {
+            return ID_ActiveMQTempQueue;
+        }
+        
+        public override int GetDestinationType()
+        {
+            return ACTIVEMQ_QUEUE;
+        }
+        
+        public override ActiveMQDestination CreateDestination(String name)
+        {
+            return new ActiveMQTempQueue(name);
+        }
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,60 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using JMS;
+using System;
+
+
+/// <summary>
+/// A Temporary Topic
+/// </summary>
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQTempTopic : ActiveMQTempDestination, ITemporaryTopic
+    {
+        public const byte ID_ActiveMQTempTopic = 103;
+        
+        public ActiveMQTempTopic() : base()
+        {
+        }
+        
+        public ActiveMQTempTopic(String name) : base(name)
+        {
+        }
+        
+        public String GetTopicName()
+        {
+            return PhysicalName;
+        }
+        
+        public override byte GetDataStructureType()
+        {
+            return ID_ActiveMQTempTopic;
+        }
+        
+        public override int GetDestinationType()
+        {
+            return ACTIVEMQ_TOPIC;
+        }
+        
+        public override ActiveMQDestination CreateDestination(String name)
+        {
+            return new ActiveMQTempTopic(name);
+        }
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTextMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTextMessage.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTextMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTextMessage.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,94 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using JMS;
+using System;
+
+
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQTextMessage : ActiveMQMessage, ITextMessage
+    {
+        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 byte GetDataStructureType()
+        {
+            return ID_ActiveMQTextMessage;
+        }
+        
+        
+        // Properties
+        
+        public string Text
+        {
+            get {
+                if (text == null)
+                {
+                    // now lets read the content
+                    
+                    byte[] data = this.Content;
+                    if (data != null)
+                    {
+                        // TODO assume that the text is ASCII
+                        char[] chars = new char[data.Length];
+                        for (int i = 0; i < chars.Length; i++)
+                        {
+                            chars[i] = (char) data[i];
+                        }
+                        text = new String(chars);
+                    }
+                }
+                return text;
+            }
+            
+            set {
+                this.text = value;
+                byte[] data = null;
+                if (text != null)
+                {
+                    // TODO assume that the text is ASCII
+                    data = new byte[text.Length];
+                    
+                    // now lets write the bytes
+                    char[] chars = text.ToCharArray();
+                    for (int i = 0; i < chars.Length; i++)
+                    {
+                        data[i] = (byte) chars[i];
+                    }
+                }
+                this.Content = data;
+            }
+        }
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,59 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using JMS;
+using System;
+
+
+/// <summary>
+/// Summary description for ActiveMQTopic.
+/// </summary>
+namespace ActiveMQ.Commands
+{
+	public class ActiveMQTopic : ActiveMQDestination, ITopic
+    {
+        public const byte ID_ActiveMQTopic = 101;
+        
+        public ActiveMQTopic() : base()
+        {
+        }
+        public ActiveMQTopic(String name) : base(name)
+        {
+        }
+        
+        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);
+        }
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BaseCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BaseCommand.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BaseCommand.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BaseCommand.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,50 @@
+//
+// Marshalling code for Open Wire Format for BaseCommand
+//
+//
+// NOTE!: This file is autogenerated - do not modify!
+//        if you need to make a change, please see the Groovy scripts in the
+//        activemq-openwire module
+//
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using System;
+
+
+
+namespace ActiveMQ.Commands
+{
+	public abstract class BaseCommand : AbstractCommand
+    {
+        
+        public override int GetHashCode()
+        {
+            return (CommandId * 37) + GetDataStructureType();
+        }
+        
+        public override bool Equals(Object that)
+        {
+            if (that is BaseCommand)
+            {
+                BaseCommand thatCommand = (BaseCommand) that;
+                return this.GetDataStructureType() == thatCommand.GetDataStructureType()
+                    && this.CommandId == thatCommand.CommandId;
+            }
+            return false;
+        }
+        
+        public override String ToString()
+        {
+            string answer = GetDataStructureTypeAsString(GetDataStructureType());
+            if (answer.Length == 0)
+            {
+                answer = base.ToString();
+            }
+            return answer + ": id = " + CommandId;
+        }
+        
+        
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerId.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,85 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  Marshalling code for Open Wire Format for BrokerId
+    //
+    //
+    //  NOTE!: This file is autogenerated - do not modify!
+    //         if you need to make a change, please see the Groovy scripts in the
+    //         activemq-core module
+    //
+    public class BrokerId : AbstractCommand
+    {
+        public const byte ID_BrokerId = 124;
+    			
+        string value;
+
+		public override int GetHashCode() {
+            int answer = 0;
+            answer = (answer * 37) + HashCode(Value);
+            return answer;
+
+		}
+	
+
+		public override bool Equals(object that) {
+	    	if (that is BrokerId) {
+	    	    return Equals((BrokerId) that);
+			}
+			return false;
+    	}
+    
+		public virtual bool Equals(BrokerId that) {
+            if (! Equals(this.Value, that.Value)) return false;
+            return true;
+
+		}
+	
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " Value=" + Value
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_BrokerId;
+        }
+
+
+        // Properties
+
+        public string Value
+        {
+            get { return value; }
+            set { this.value = value; }            
+        }
+
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerInfo.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,95 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  Marshalling code for Open Wire Format for BrokerInfo
+    //
+    //
+    //  NOTE!: This file is autogenerated - do not modify!
+    //         if you need to make a change, please see the Groovy scripts in the
+    //         activemq-core module
+    //
+    public class BrokerInfo : BaseCommand
+    {
+        public const byte ID_BrokerInfo = 2;
+    			
+        BrokerId brokerId;
+        string brokerURL;
+        BrokerInfo[] peerBrokerInfos;
+        string brokerName;
+        bool slaveBroker;
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " BrokerId=" + BrokerId
+                + " BrokerURL=" + BrokerURL
+                + " PeerBrokerInfos=" + PeerBrokerInfos
+                + " BrokerName=" + BrokerName
+                + " SlaveBroker=" + SlaveBroker
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_BrokerInfo;
+        }
+
+
+        // Properties
+
+        public BrokerId BrokerId
+        {
+            get { return brokerId; }
+            set { this.brokerId = value; }            
+        }
+
+        public string BrokerURL
+        {
+            get { return brokerURL; }
+            set { this.brokerURL = value; }            
+        }
+
+        public BrokerInfo[] PeerBrokerInfos
+        {
+            get { return peerBrokerInfos; }
+            set { this.peerBrokerInfos = value; }            
+        }
+
+        public string BrokerName
+        {
+            get { return brokerName; }
+            set { this.brokerName = value; }            
+        }
+
+        public bool SlaveBroker
+        {
+            get { return slaveBroker; }
+            set { this.slaveBroker = value; }            
+        }
+
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionError.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionError.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionError.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionError.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  Marshalling code for Open Wire Format for ConnectionError
+    //
+    //
+    //  NOTE!: This file is autogenerated - do not modify!
+    //         if you need to make a change, please see the Groovy scripts in the
+    //         activemq-core module
+    //
+    public class ConnectionError : BaseCommand
+    {
+        public const byte ID_ConnectionError = 16;
+    			
+        BrokerError exception;
+        ConnectionId connectionId;
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " Exception=" + Exception
+                + " ConnectionId=" + ConnectionId
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_ConnectionError;
+        }
+
+
+        // Properties
+
+        public BrokerError Exception
+        {
+            get { return exception; }
+            set { this.exception = value; }            
+        }
+
+        public ConnectionId ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }            
+        }
+
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionId.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,85 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  Marshalling code for Open Wire Format for ConnectionId
+    //
+    //
+    //  NOTE!: This file is autogenerated - do not modify!
+    //         if you need to make a change, please see the Groovy scripts in the
+    //         activemq-core module
+    //
+    public class ConnectionId : AbstractCommand
+    {
+        public const byte ID_ConnectionId = 120;
+    			
+        string value;
+
+		public override int GetHashCode() {
+            int answer = 0;
+            answer = (answer * 37) + HashCode(Value);
+            return answer;
+
+		}
+	
+
+		public override bool Equals(object that) {
+	    	if (that is ConnectionId) {
+	    	    return Equals((ConnectionId) that);
+			}
+			return false;
+    	}
+    
+		public virtual bool Equals(ConnectionId that) {
+            if (! Equals(this.Value, that.Value)) return false;
+            return true;
+
+		}
+	
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " Value=" + Value
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_ConnectionId;
+        }
+
+
+        // Properties
+
+        public string Value
+        {
+            get { return value; }
+            set { this.value = value; }            
+        }
+
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConnectionInfo.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,95 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  Marshalling code for Open Wire Format for ConnectionInfo
+    //
+    //
+    //  NOTE!: This file is autogenerated - do not modify!
+    //         if you need to make a change, please see the Groovy scripts in the
+    //         activemq-core module
+    //
+    public class ConnectionInfo : BaseCommand
+    {
+        public const byte ID_ConnectionInfo = 3;
+    			
+        ConnectionId connectionId;
+        string clientId;
+        string password;
+        string userName;
+        BrokerId[] brokerPath;
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " ConnectionId=" + ConnectionId
+                + " ClientId=" + ClientId
+                + " Password=" + Password
+                + " UserName=" + UserName
+                + " BrokerPath=" + BrokerPath
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_ConnectionInfo;
+        }
+
+
+        // Properties
+
+        public ConnectionId ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }            
+        }
+
+        public string ClientId
+        {
+            get { return clientId; }
+            set { this.clientId = value; }            
+        }
+
+        public string Password
+        {
+            get { return password; }
+            set { this.password = value; }            
+        }
+
+        public string UserName
+        {
+            get { return userName; }
+            set { this.userName = value; }            
+        }
+
+        public BrokerId[] BrokerPath
+        {
+            get { return brokerPath; }
+            set { this.brokerPath = value; }            
+        }
+
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerId.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,105 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  Marshalling code for Open Wire Format for ConsumerId
+    //
+    //
+    //  NOTE!: This file is autogenerated - do not modify!
+    //         if you need to make a change, please see the Groovy scripts in the
+    //         activemq-core module
+    //
+    public class ConsumerId : AbstractCommand
+    {
+        public const byte ID_ConsumerId = 122;
+    			
+        string connectionId;
+        long sessionId;
+        long value;
+
+		public override int GetHashCode() {
+            int answer = 0;
+            answer = (answer * 37) + HashCode(ConnectionId);
+            answer = (answer * 37) + HashCode(SessionId);
+            answer = (answer * 37) + HashCode(Value);
+            return answer;
+
+		}
+	
+
+		public override bool Equals(object that) {
+	    	if (that is ConsumerId) {
+	    	    return Equals((ConsumerId) that);
+			}
+			return false;
+    	}
+    
+		public virtual bool Equals(ConsumerId that) {
+            if (! Equals(this.ConnectionId, that.ConnectionId)) return false;
+            if (! Equals(this.SessionId, that.SessionId)) return false;
+            if (! Equals(this.Value, that.Value)) return false;
+            return true;
+
+		}
+	
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " ConnectionId=" + ConnectionId
+                + " SessionId=" + SessionId
+                + " Value=" + Value
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_ConsumerId;
+        }
+
+
+        // Properties
+
+        public string ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }            
+        }
+
+        public long SessionId
+        {
+            get { return sessionId; }
+            set { this.sessionId = value; }            
+        }
+
+        public long Value
+        {
+            get { return value; }
+            set { this.value = value; }            
+        }
+
+    }
+}



Mime
View raw message