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 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + 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 description for TransactionConstants.