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);
