activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r366537 [3/3] - in /incubator/activemq/trunk/openwire-dotnet: ./ src/ src/OpenWire.Core/ src/OpenWire.Core/Commands/ src/OpenWire.Core/IO/
Date Fri, 06 Jan 2006 17:24:39 GMT
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,65 @@
+//
+// Marshalling code for Open Wire Format for ConsumerInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class ConsumerInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new ConsumerInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            ConsumerInfo info = (ConsumerInfo) command;
+            info.setConsumerId((org.apache.activemq.command.ConsumerId) readObject(dataIn));
+            info.setBrowser(dataIn.readBoolean());
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setPrefetchSize(dataIn.readInt());
+            info.setDispatchAsync(dataIn.readBoolean());
+            info.setSelector(dataIn.readUTF());
+            info.setSubcriptionName(dataIn.readUTF());
+            info.setNoLocal(dataIn.readBoolean());
+            info.setExclusive(dataIn.readBoolean());
+            info.setRetroactive(dataIn.readBoolean());
+            info.setPriority(dataIn.readByte());
+            info.setBrokerPath((org.apache.activemq.command.BrokerId[]) readObject(dataIn));
+            info.setNetworkSubscription(dataIn.readBoolean());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            ConsumerInfo info = (ConsumerInfo) command;
+            writeObject(info.getConsumerId(), dataOut);
+            dataOut.writeBoolean(info.isBrowser());
+            writeObject(info.getDestination(), dataOut);
+            dataOut.writeInt(info.getPrefetchSize());
+            dataOut.writeBoolean(info.isDispatchAsync());
+            writeUTF(info.getSelector(), dataOut);
+            writeUTF(info.getSubcriptionName(), dataOut);
+            dataOut.writeBoolean(info.isNoLocal());
+            dataOut.writeBoolean(info.isExclusive());
+            dataOut.writeBoolean(info.isRetroactive());
+            dataOut.writeByte(info.getPriority());
+            writeObject(info.getBrokerPath(), dataOut);
+            dataOut.writeBoolean(info.isNetworkSubscription());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ControlCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ControlCommandMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ControlCommandMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ControlCommandMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for ControlCommand
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class ControlCommandMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new ControlCommand();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            ControlCommand info = (ControlCommand) command;
+            info.setCommand(dataIn.readUTF());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            ControlCommand info = (ControlCommand) command;
+            writeUTF(info.getCommand(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataArrayResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataArrayResponseMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataArrayResponseMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataArrayResponseMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for DataArrayResponse
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class DataArrayResponseMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new DataArrayResponse();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            DataArrayResponse info = (DataArrayResponse) command;
+            info.setData((org.apache.activemq.command.DataStructure[]) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            DataArrayResponse info = (DataArrayResponse) command;
+            writeObject(info.getData(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for DataResponse
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class DataResponseMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new DataResponse();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            DataResponse info = (DataResponse) command;
+            info.setData((org.apache.activemq.command.DataStructure) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            DataResponse info = (DataResponse) command;
+            writeObject(info.getData(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DestinationInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DestinationInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DestinationInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DestinationInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for DestinationInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class DestinationInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new DestinationInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            DestinationInfo info = (DestinationInfo) command;
+            info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setOperationType(dataIn.readByte());
+            info.setTimeout(dataIn.readLong());
+            info.setBrokerPath((org.apache.activemq.command.BrokerId[]) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            DestinationInfo info = (DestinationInfo) command;
+            writeObject(info.getConnectionId(), dataOut);
+            writeObject(info.getDestination(), dataOut);
+            dataOut.writeByte(info.getOperationType());
+            dataOut.writeLong(info.getTimeout());
+            writeObject(info.getBrokerPath(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for ExceptionResponse
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class ExceptionResponseMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new ExceptionResponse();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            ExceptionResponse info = (ExceptionResponse) command;
+            info.setException((java.lang.Throwable) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            ExceptionResponse info = (ExceptionResponse) command;
+            writeObject(info.getException(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/FlushCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/FlushCommandMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/FlushCommandMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/FlushCommandMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for FlushCommand
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class FlushCommandMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new FlushCommand();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            FlushCommand info = (FlushCommand) command;
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            FlushCommand info = (FlushCommand) command;
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/IntegerResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/IntegerResponseMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/IntegerResponseMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/IntegerResponseMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for IntegerResponse
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class IntegerResponseMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new IntegerResponse();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            IntegerResponse info = (IntegerResponse) command;
+            info.setResult(dataIn.readInt());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            IntegerResponse info = (IntegerResponse) command;
+            dataOut.writeInt(info.getResult());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalQueueAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalQueueAckMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalQueueAckMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalQueueAckMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,43 @@
+//
+// Marshalling code for Open Wire Format for JournalQueueAck
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class JournalQueueAckMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new JournalQueueAck();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            JournalQueueAck info = (JournalQueueAck) command;
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setMessageAck((org.apache.activemq.command.MessageAck) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            JournalQueueAck info = (JournalQueueAck) command;
+            writeObject(info.getDestination(), dataOut);
+            writeObject(info.getMessageAck(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,51 @@
+//
+// Marshalling code for Open Wire Format for JournalTopicAck
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class JournalTopicAckMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new JournalTopicAck();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            JournalTopicAck info = (JournalTopicAck) command;
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setMessageId((org.apache.activemq.command.MessageId) readObject(dataIn));
+            info.setMessageSequenceId(dataIn.readLong());
+            info.setSubscritionName(dataIn.readUTF());
+            info.setClientId(dataIn.readUTF());
+            info.setTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            JournalTopicAck info = (JournalTopicAck) command;
+            writeObject(info.getDestination(), dataOut);
+            writeObject(info.getMessageId(), dataOut);
+            dataOut.writeLong(info.getMessageSequenceId());
+            writeUTF(info.getSubscritionName(), dataOut);
+            writeUTF(info.getClientId(), dataOut);
+            writeObject(info.getTransactionId(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTraceMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTraceMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTraceMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTraceMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for JournalTrace
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class JournalTraceMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new JournalTrace();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            JournalTrace info = (JournalTrace) command;
+            info.setMessage(dataIn.readUTF());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            JournalTrace info = (JournalTrace) command;
+            writeUTF(info.getMessage(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for JournalTransaction
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class JournalTransactionMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new JournalTransaction();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            JournalTransaction info = (JournalTransaction) command;
+            info.setTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
+            info.setType(dataIn.readByte());
+            info.setWasPrepared(dataIn.readBoolean());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            JournalTransaction info = (JournalTransaction) command;
+            writeObject(info.getTransactionId(), dataOut);
+            dataOut.writeByte(info.getType());
+            dataOut.writeBoolean(info.getWasPrepared());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/KeepAliveInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/KeepAliveInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/KeepAliveInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/KeepAliveInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for KeepAliveInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class KeepAliveInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new KeepAliveInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            KeepAliveInfo info = (KeepAliveInfo) command;
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            KeepAliveInfo info = (KeepAliveInfo) command;
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/LocalTransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/LocalTransactionIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/LocalTransactionIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/LocalTransactionIdMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,43 @@
+//
+// Marshalling code for Open Wire Format for LocalTransactionId
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class LocalTransactionIdMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new LocalTransactionId();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            LocalTransactionId info = (LocalTransactionId) command;
+            info.setTransactionId(dataIn.readLong());
+            info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            LocalTransactionId info = (LocalTransactionId) command;
+            dataOut.writeLong(info.getTransactionId());
+            writeObject(info.getConnectionId(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,53 @@
+//
+// Marshalling code for Open Wire Format for MessageAck
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class MessageAckMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new MessageAck();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            MessageAck info = (MessageAck) command;
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
+            info.setConsumerId((org.apache.activemq.command.ConsumerId) readObject(dataIn));
+            info.setAckType(dataIn.readByte());
+            info.setFirstMessageId((org.apache.activemq.command.MessageId) readObject(dataIn));
+            info.setLastMessageId((org.apache.activemq.command.MessageId) readObject(dataIn));
+            info.setMessageCount(dataIn.readInt());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            MessageAck info = (MessageAck) command;
+            writeObject(info.getDestination(), dataOut);
+            writeObject(info.getTransactionId(), dataOut);
+            writeObject(info.getConsumerId(), dataOut);
+            dataOut.writeByte(info.getAckType());
+            writeObject(info.getFirstMessageId(), dataOut);
+            writeObject(info.getLastMessageId(), dataOut);
+            dataOut.writeInt(info.getMessageCount());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,47 @@
+//
+// Marshalling code for Open Wire Format for MessageDispatch
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class MessageDispatchMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new MessageDispatch();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            MessageDispatch info = (MessageDispatch) command;
+            info.setConsumerId((org.apache.activemq.command.ConsumerId) readObject(dataIn));
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setMessage((org.apache.activemq.command.Message) readObject(dataIn));
+            info.setRedeliveryCounter(dataIn.readInt());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            MessageDispatch info = (MessageDispatch) command;
+            writeObject(info.getConsumerId(), dataOut);
+            writeObject(info.getDestination(), dataOut);
+            writeObject(info.getMessage(), dataOut);
+            dataOut.writeInt(info.getRedeliveryCounter());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageIdMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for MessageId
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class MessageIdMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new MessageId();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            MessageId info = (MessageId) command;
+            info.setProducerId((org.apache.activemq.command.ProducerId) readObject(dataIn));
+            info.setProducerSequenceId(dataIn.readLong());
+            info.setBrokerSequenceId(dataIn.readLong());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            MessageId info = (MessageId) command;
+            writeObject(info.getProducerId(), dataOut);
+            dataOut.writeLong(info.getProducerSequenceId());
+            dataOut.writeLong(info.getBrokerSequenceId());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,89 @@
+//
+// Marshalling code for Open Wire Format for Message
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class MessageMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new Message();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            Message info = (Message) command;
+            info.setProducerId((org.apache.activemq.command.ProducerId) readObject(dataIn));
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
+            info.setOriginalDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setMessageId((org.apache.activemq.command.MessageId) readObject(dataIn));
+            info.setOriginalTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
+            info.setGroupID(dataIn.readUTF());
+            info.setGroupSequence(dataIn.readInt());
+            info.setCorrelationId(dataIn.readUTF());
+            info.setPersistent(dataIn.readBoolean());
+            info.setExpiration(dataIn.readLong());
+            info.setPriority(dataIn.readByte());
+            info.setReplyTo((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setTimestamp(dataIn.readLong());
+            info.setType(dataIn.readUTF());
+            info.setContent((org.activeio.ByteSequence) readObject(dataIn));
+            info.setMarshalledProperties((org.activeio.ByteSequence) readObject(dataIn));
+            info.setDataStructure((org.apache.activemq.command.DataStructure) readObject(dataIn));
+            info.setTargetConsumerId((org.apache.activemq.command.ConsumerId) readObject(dataIn));
+            info.setCompressed(dataIn.readBoolean());
+            info.setRedeliveryCounter(dataIn.readInt());
+            info.setBrokerPath((org.apache.activemq.command.BrokerId[]) readObject(dataIn));
+            info.setArrival(dataIn.readLong());
+            info.setUserID(dataIn.readUTF());
+            info.setRecievedByDFBridge(dataIn.readBoolean());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            Message info = (Message) command;
+            writeObject(info.getProducerId(), dataOut);
+            writeObject(info.getDestination(), dataOut);
+            writeObject(info.getTransactionId(), dataOut);
+            writeObject(info.getOriginalDestination(), dataOut);
+            writeObject(info.getMessageId(), dataOut);
+            writeObject(info.getOriginalTransactionId(), dataOut);
+            writeUTF(info.getGroupID(), dataOut);
+            dataOut.writeInt(info.getGroupSequence());
+            writeUTF(info.getCorrelationId(), dataOut);
+            dataOut.writeBoolean(info.isPersistent());
+            dataOut.writeLong(info.getExpiration());
+            dataOut.writeByte(info.getPriority());
+            writeObject(info.getReplyTo(), dataOut);
+            dataOut.writeLong(info.getTimestamp());
+            writeUTF(info.getType(), dataOut);
+            writeObject(info.getContent(), dataOut);
+            writeObject(info.getMarshalledProperties(), dataOut);
+            writeObject(info.getDataStructure(), dataOut);
+            writeObject(info.getTargetConsumerId(), dataOut);
+            dataOut.writeBoolean(info.isCompressed());
+            dataOut.writeInt(info.getRedeliveryCounter());
+            writeObject(info.getBrokerPath(), dataOut);
+            dataOut.writeLong(info.getArrival());
+            writeUTF(info.getUserID(), dataOut);
+            dataOut.writeBoolean(info.isRecievedByDFBridge());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for ProducerId
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class ProducerIdMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new ProducerId();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            ProducerId info = (ProducerId) command;
+            info.setConnectionId(dataIn.readUTF());
+            info.setProducerId(dataIn.readLong());
+            info.setSessionId(dataIn.readLong());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            ProducerId info = (ProducerId) command;
+            writeUTF(info.getConnectionId(), dataOut);
+            dataOut.writeLong(info.getProducerId());
+            dataOut.writeLong(info.getSessionId());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for ProducerInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class ProducerInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new ProducerInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            ProducerInfo info = (ProducerInfo) command;
+            info.setProducerId((org.apache.activemq.command.ProducerId) readObject(dataIn));
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setBrokerPath((org.apache.activemq.command.BrokerId[]) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            ProducerInfo info = (ProducerInfo) command;
+            writeObject(info.getProducerId(), dataOut);
+            writeObject(info.getDestination(), dataOut);
+            writeObject(info.getBrokerPath(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for RemoveInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class RemoveInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new RemoveInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            RemoveInfo info = (RemoveInfo) command;
+            info.setObjectId((org.apache.activemq.command.DataStructure) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            RemoveInfo info = (RemoveInfo) command;
+            writeObject(info.getObjectId(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveSubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveSubscriptionInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveSubscriptionInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveSubscriptionInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for RemoveSubscriptionInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class RemoveSubscriptionInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new RemoveSubscriptionInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            RemoveSubscriptionInfo info = (RemoveSubscriptionInfo) command;
+            info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
+            info.setSubcriptionName(dataIn.readUTF());
+            info.setClientId(dataIn.readUTF());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            RemoveSubscriptionInfo info = (RemoveSubscriptionInfo) command;
+            writeObject(info.getConnectionId(), dataOut);
+            writeUTF(info.getSubcriptionName(), dataOut);
+            writeUTF(info.getClientId(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ResponseMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ResponseMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ResponseMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for Response
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class ResponseMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new Response();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            Response info = (Response) command;
+            info.setCorrelationId(dataIn.readShort());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            Response info = (Response) command;
+            dataOut.writeShort(info.getCorrelationId());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionIdMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,43 @@
+//
+// Marshalling code for Open Wire Format for SessionId
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class SessionIdMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new SessionId();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            SessionId info = (SessionId) command;
+            info.setConnectionId(dataIn.readUTF());
+            info.setSessionId(dataIn.readLong());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            SessionId info = (SessionId) command;
+            writeUTF(info.getConnectionId(), dataOut);
+            dataOut.writeLong(info.getSessionId());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for SessionInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class SessionInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new SessionInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            SessionInfo info = (SessionInfo) command;
+            info.setSessionId((org.apache.activemq.command.SessionId) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            SessionInfo info = (SessionInfo) command;
+            writeObject(info.getSessionId(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ShutdownInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ShutdownInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ShutdownInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ShutdownInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ShutdownInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class ShutdownInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new ShutdownInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            ShutdownInfo info = (ShutdownInfo) command;
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            ShutdownInfo info = (ShutdownInfo) command;
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SubscriptionInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SubscriptionInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SubscriptionInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,47 @@
+//
+// Marshalling code for Open Wire Format for SubscriptionInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class SubscriptionInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new SubscriptionInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            SubscriptionInfo info = (SubscriptionInfo) command;
+            info.setClientId(dataIn.readUTF());
+            info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
+            info.setSelector(dataIn.readUTF());
+            info.setSubcriptionName(dataIn.readUTF());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            SubscriptionInfo info = (SubscriptionInfo) command;
+            writeUTF(info.getClientId(), dataOut);
+            writeObject(info.getDestination(), dataOut);
+            writeUTF(info.getSelector(), dataOut);
+            writeUTF(info.getSubcriptionName(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionIdMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for TransactionId
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class TransactionIdMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new TransactionId();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            TransactionId info = (TransactionId) command;
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            TransactionId info = (TransactionId) command;
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for TransactionInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class TransactionInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new TransactionInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            TransactionInfo info = (TransactionInfo) command;
+            info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
+            info.setTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
+            info.setType(dataIn.readByte());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            TransactionInfo info = (TransactionInfo) command;
+            writeObject(info.getConnectionId(), dataOut);
+            writeObject(info.getTransactionId(), dataOut);
+            dataOut.writeByte(info.getType());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/WireFormatInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/WireFormatInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/WireFormatInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/WireFormatInfoMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for WireFormatInfo
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class WireFormatInfoMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new WireFormatInfo();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            WireFormatInfo info = (WireFormatInfo) command;
+            info.setMagic((byte[]) readObject(dataIn));
+            info.setVersion(dataIn.readInt());
+            info.setOptions(dataIn.readInt());
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            WireFormatInfo info = (WireFormatInfo) command;
+            writeObject(info.getMagic(), dataOut);
+            dataOut.writeInt(info.getVersion());
+            dataOut.writeInt(info.getOptions());
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/XATransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/XATransactionIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/XATransactionIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/XATransactionIdMarshaller.cs Fri Jan  6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for XATransactionId
+//
+//
+// 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 System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+    public class XATransactionIdMarshaller : AbstractCommandMarshaller
+    {
+
+        public override Command CreateCommand() {
+            return new XATransactionId();
+        }
+
+        public override void BuildCommand(Command command, BinaryReader dataIn) {
+            super.buildCommand(command, dataIn);
+            XATransactionId info = (XATransactionId) command;
+            info.setFormatId(dataIn.readInt());
+            info.setGlobalTransactionId((byte[]) readObject(dataIn));
+            info.setBranchQualifier((byte[]) readObject(dataIn));
+
+        }
+
+        public override void WriteCommand(Command command, BinaryWriter dataOut) {
+            super.writeCommand(command, dataOut);
+            XATransactionId info = (XATransactionId) command;
+            dataOut.writeInt(info.getFormatId());
+            writeObject(info.getGlobalTransactionId(), dataOut);
+            writeObject(info.getBranchQualifier(), dataOut);
+
+        }
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/OpenWire.Core.build
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/OpenWire.Core.build?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/OpenWire.Core.build (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/OpenWire.Core.build Fri Jan  6 09:24:01 2006
@@ -0,0 +1,32 @@
+<?xml version="1.0"?>
+<project name="OpenWire.Core" default="build">
+    <!--
+        Required properties:
+            * build.dir             - (path) root level to build to, assemblies will go in ${build.dir}/bin
+            * build.debug           - (true|false) debug build?
+            * current.build.defines - framework-specific build defines
+    -->
+    <target name="build">
+        <!-- build OpenWire.Core -->
+        <csc target="library" define="${current.build.defines}" warnaserror="true" debug="${build.debug}" output="${build.dir}/bin/${project.name}.dll" doc="${build.dir}/bin/${project.name}.xml">
+            <nowarn>
+                <!-- do not report warnings for missing XML comments -->
+                <warning number="1591" />
+                <!-- do not report deprecation warnings -->
+                <warning number="0618" />
+            </nowarn>
+            <sources failonempty="true">
+                <include name="**/*.cs" />
+                <!-- common assembly-level attributes -->
+                <include name="../CommonAssemblyInfo.cs" />               
+            </sources>                       
+            <resources basedir="Resources">
+                <include name="**/*" />
+            </resources>
+            <references>
+                <include name="${build.dir}/bin/log4net.dll"/>
+                <include name="System.Web.dll"/>
+            </references>
+        </csc>
+    </target>
+</project>

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/OpenWire.Core.build
------------------------------------------------------------------------------
    svn:executable = *

Copied: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs (from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/TransactionConstants.cs)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs&p1=incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/TransactionConstants.cs&r1=366455&r2=366537&rev=366537&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/TransactionConstants.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs Fri Jan  6 09:24:01 2006
@@ -1,6 +1,6 @@
 using System;
 
-namespace ActiveMQ
+namespace OpenWire.Core
 {
 	/// <summary>
 	/// Summary description for TransactionConstants.



Mime
View raw message