You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/01/06 18:24:39 UTC
svn commit: r366537 [3/3] - in /incubator/activemq/trunk/openwire-dotnet: ./
src/ src/OpenWire.Core/ src/OpenWire.Core/Commands/ src/OpenWire.Core/IO/
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.