activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r366543 [2/2] - in /incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core: ./ Commands/ IO/
Date Fri, 06 Jan 2006 18:00:17 GMT
Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs?rev=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             ConsumerId info = (ConsumerId) command;
             info.setConnectionId(dataIn.readUTF());
             info.setSessionId(dataIn.readLong());
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             ConsumerId info = (ConsumerId) command;
             writeUTF(info.getConnectionId(), dataOut);
             dataOut.writeLong(info.getSessionId());

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             ConsumerInfo info = (ConsumerInfo) command;
             info.setConsumerId((org.apache.activemq.command.ConsumerId) readObject(dataIn));
             info.setBrowser(dataIn.readBoolean());
@@ -44,7 +44,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             ConsumerInfo info = (ConsumerInfo) command;
             writeObject(info.getConsumerId(), dataOut);
             dataOut.writeBoolean(info.isBrowser());

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ControlCommandMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ControlCommandMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             ControlCommand info = (ControlCommand) command;
             info.setCommand(dataIn.readUTF());
 
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             ControlCommand info = (ControlCommand) command;
             writeUTF(info.getCommand(), dataOut);
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataArrayResponseMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataArrayResponseMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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);
+            base.WriteCommand(command, dataOut);
             DataArrayResponse info = (DataArrayResponse) command;
             writeObject(info.getData(), dataOut);
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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);
+            base.WriteCommand(command, dataOut);
             DataResponse info = (DataResponse) command;
             writeObject(info.getData(), dataOut);
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DestinationInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DestinationInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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));
@@ -36,7 +36,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             DestinationInfo info = (DestinationInfo) command;
             writeObject(info.getConnectionId(), dataOut);
             writeObject(info.getDestination(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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);
+            base.WriteCommand(command, dataOut);
             ExceptionResponse info = (ExceptionResponse) command;
             writeObject(info.getException(), dataOut);
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/FlushCommandMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/FlushCommandMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,13 +25,13 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             FlushCommand info = (FlushCommand) command;
 
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             FlushCommand info = (FlushCommand) command;
 
         }

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/IntegerResponseMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/IntegerResponseMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             IntegerResponse info = (IntegerResponse) command;
             info.setResult(dataIn.readInt());
 
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             IntegerResponse info = (IntegerResponse) command;
             dataOut.writeInt(info.getResult());
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalQueueAckMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalQueueAckMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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));
@@ -33,7 +33,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             JournalQueueAck info = (JournalQueueAck) command;
             writeObject(info.getDestination(), dataOut);
             writeObject(info.getMessageAck(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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));
@@ -37,7 +37,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             JournalTopicAck info = (JournalTopicAck) command;
             writeObject(info.getDestination(), dataOut);
             writeObject(info.getMessageId(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTraceMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTraceMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             JournalTrace info = (JournalTrace) command;
             info.setMessage(dataIn.readUTF());
 
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             JournalTrace info = (JournalTrace) command;
             writeUTF(info.getMessage(), dataOut);
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             JournalTransaction info = (JournalTransaction) command;
             info.setTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
             info.setType(dataIn.readByte());
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             JournalTransaction info = (JournalTransaction) command;
             writeObject(info.getTransactionId(), dataOut);
             dataOut.writeByte(info.getType());

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/KeepAliveInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/KeepAliveInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,13 +25,13 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             KeepAliveInfo info = (KeepAliveInfo) command;
 
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             KeepAliveInfo info = (KeepAliveInfo) command;
 
         }

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/LocalTransactionIdMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/LocalTransactionIdMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             LocalTransactionId info = (LocalTransactionId) command;
             info.setTransactionId(dataIn.readLong());
             info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
@@ -33,7 +33,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             LocalTransactionId info = (LocalTransactionId) command;
             dataOut.writeLong(info.getTransactionId());
             writeObject(info.getConnectionId(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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));
@@ -38,7 +38,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             MessageAck info = (MessageAck) command;
             writeObject(info.getDestination(), dataOut);
             writeObject(info.getTransactionId(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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));
@@ -35,7 +35,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             MessageDispatch info = (MessageDispatch) command;
             writeObject(info.getConsumerId(), dataOut);
             writeObject(info.getDestination(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageIdMarshaller.cs Fri
Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             MessageId info = (MessageId) command;
             info.setProducerId((org.apache.activemq.command.ProducerId) readObject(dataIn));
             info.setProducerSequenceId(dataIn.readLong());
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             MessageId info = (MessageId) command;
             writeObject(info.getProducerId(), dataOut);
             dataOut.writeLong(info.getProducerSequenceId());

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs Fri
Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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));
@@ -56,7 +56,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             Message info = (Message) command;
             writeObject(info.getProducerId(), dataOut);
             writeObject(info.getDestination(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             ProducerId info = (ProducerId) command;
             info.setConnectionId(dataIn.readUTF());
             info.setProducerId(dataIn.readLong());
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             ProducerId info = (ProducerId) command;
             writeUTF(info.getConnectionId(), dataOut);
             dataOut.writeLong(info.getProducerId());

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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));
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             ProducerInfo info = (ProducerInfo) command;
             writeObject(info.getProducerId(), dataOut);
             writeObject(info.getDestination(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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);
+            base.WriteCommand(command, dataOut);
             RemoveInfo info = (RemoveInfo) command;
             writeObject(info.getObjectId(), dataOut);
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveSubscriptionInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveSubscriptionInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             RemoveSubscriptionInfo info = (RemoveSubscriptionInfo) command;
             info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
             info.setSubcriptionName(dataIn.readUTF());
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             RemoveSubscriptionInfo info = (RemoveSubscriptionInfo) command;
             writeObject(info.getConnectionId(), dataOut);
             writeUTF(info.getSubcriptionName(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ResponseMarshaller.cs Fri
Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             Response info = (Response) command;
             info.setCorrelationId(dataIn.readShort());
 
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             Response info = (Response) command;
             dataOut.writeShort(info.getCorrelationId());
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionIdMarshaller.cs Fri
Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             SessionId info = (SessionId) command;
             info.setConnectionId(dataIn.readUTF());
             info.setSessionId(dataIn.readLong());
@@ -33,7 +33,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             SessionId info = (SessionId) command;
             writeUTF(info.getConnectionId(), dataOut);
             dataOut.writeLong(info.getSessionId());

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,14 +25,14 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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);
+            base.WriteCommand(command, dataOut);
             SessionInfo info = (SessionInfo) command;
             writeObject(info.getSessionId(), dataOut);
 

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ShutdownInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ShutdownInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,13 +25,13 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             ShutdownInfo info = (ShutdownInfo) command;
 
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             ShutdownInfo info = (ShutdownInfo) command;
 
         }

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SubscriptionInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SubscriptionInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             SubscriptionInfo info = (SubscriptionInfo) command;
             info.setClientId(dataIn.readUTF());
             info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
@@ -35,7 +35,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             SubscriptionInfo info = (SubscriptionInfo) command;
             writeUTF(info.getClientId(), dataOut);
             writeObject(info.getDestination(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionIdMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionIdMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,13 +25,13 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             TransactionId info = (TransactionId) command;
 
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             TransactionId info = (TransactionId) command;
 
         }

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.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));
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             TransactionInfo info = (TransactionInfo) command;
             writeObject(info.getConnectionId(), dataOut);
             writeObject(info.getTransactionId(), dataOut);

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/WireFormatInfoMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/WireFormatInfoMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             WireFormatInfo info = (WireFormatInfo) command;
             info.setMagic((byte[]) readObject(dataIn));
             info.setVersion(dataIn.readInt());
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             WireFormatInfo info = (WireFormatInfo) command;
             writeObject(info.getMagic(), dataOut);
             dataOut.writeInt(info.getVersion());

Modified: 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=366543&r1=366542&r2=366543&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/XATransactionIdMarshaller.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/XATransactionIdMarshaller.cs
Fri Jan  6 09:56:09 2006
@@ -25,7 +25,7 @@
         }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
-            super.buildCommand(command, dataIn);
+            base.BuildCommand(command, dataIn);
             XATransactionId info = (XATransactionId) command;
             info.setFormatId(dataIn.readInt());
             info.setGlobalTransactionId((byte[]) readObject(dataIn));
@@ -34,7 +34,7 @@
         }
 
         public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            super.writeCommand(command, dataOut);
+            base.WriteCommand(command, dataOut);
             XATransactionId info = (XATransactionId) command;
             dataOut.writeInt(info.getFormatId());
             writeObject(info.getGlobalTransactionId(), dataOut);



Mime
View raw message