You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/03/09 01:41:58 UTC
svn commit: r384390 [6/11] - in /incubator/activemq/trunk:
activemq-core/src/gram/java/org/apache/activemq/openwire/tool/
activemq-core/src/gram/script/
activemq-core/src/main/java/org/apache/activemq/command/
activemq-core/src/main/java/org/apache/act...
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -56,7 +56,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -75,5 +74,24 @@
base.TightMarshal2(wireFormat, o, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -49,7 +49,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -73,5 +72,32 @@
bs.ReadBoolean();
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ BaseCommand info = (BaseCommand)o;
+ info.CommandId = dataIn.ReadInt16();
+ info.ResponseRequired = dataIn.ReadBoolean();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ BaseCommand info = (BaseCommand)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.CommandId);
+ dataOut.Write(info.ResponseRequired);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -82,5 +81,30 @@
TightMarshalString2(info.Value, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ BrokerId info = (BrokerId)o;
+ info.Value = LooseUnmarshalString(dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ BrokerId info = (BrokerId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.Value, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -74,7 +74,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -105,5 +104,49 @@
bs.ReadBoolean();
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ BrokerInfo info = (BrokerInfo)o;
+ info.BrokerId = (BrokerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.BrokerURL = LooseUnmarshalString(dataIn);
+
+ if (dataIn.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ BrokerInfo[] value = new BrokerInfo[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (BrokerInfo) LooseUnmarshalNestedObject(wireFormat,dataIn);
+ }
+ info.PeerBrokerInfos = value;
+ }
+ else {
+ info.PeerBrokerInfos = null;
+ }
+ info.BrokerName = LooseUnmarshalString(dataIn);
+ info.SlaveBroker = dataIn.ReadBoolean();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ BrokerInfo info = (BrokerInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.BrokerId, dataOut);
+ LooseMarshalString(info.BrokerURL, dataOut);
+ LooseMarshalObjectArray(wireFormat, info.PeerBrokerInfos, dataOut);
+ LooseMarshalString(info.BrokerName, dataOut);
+ dataOut.Write(info.SlaveBroker);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -60,7 +60,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -85,5 +84,32 @@
TightMarshalNestedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ConnectionError info = (ConnectionError)o;
+ info.Exception = LooseUnmarshalBrokerError(wireFormat, dataIn);
+ info.ConnectionId = (ConnectionId) LooseUnmarshalNestedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ConnectionError info = (ConnectionError)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalBrokerError(wireFormat, info.Exception, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -82,5 +81,30 @@
TightMarshalString2(info.Value, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ConnectionId info = (ConnectionId)o;
+ info.Value = LooseUnmarshalString(dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ConnectionId info = (ConnectionId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.Value, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -74,7 +74,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -105,5 +104,49 @@
TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ConnectionInfo info = (ConnectionInfo)o;
+ info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.ClientId = LooseUnmarshalString(dataIn);
+ info.Password = LooseUnmarshalString(dataIn);
+ info.UserName = LooseUnmarshalString(dataIn);
+
+ if (dataIn.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ BrokerId[] value = new BrokerId[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,dataIn);
+ }
+ info.BrokerPath = value;
+ }
+ else {
+ info.BrokerPath = null;
+ }
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ConnectionInfo info = (ConnectionInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
+ LooseMarshalString(info.ClientId, dataOut);
+ LooseMarshalString(info.Password, dataOut);
+ LooseMarshalString(info.UserName, dataOut);
+ LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -61,7 +61,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -88,5 +87,34 @@
TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ConsumerId info = (ConsumerId)o;
+ info.ConnectionId = LooseUnmarshalString(dataIn);
+ info.SessionId = LooseUnmarshalLong(wireFormat, dataIn);
+ info.Value = LooseUnmarshalLong(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ConsumerId info = (ConsumerId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.ConnectionId, dataOut);
+ LooseMarshalLong(wireFormat, info.SessionId, dataOut);
+ LooseMarshalLong(wireFormat, info.Value, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -84,7 +84,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -132,5 +131,69 @@
bs.ReadBoolean();
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ConsumerInfo info = (ConsumerInfo)o;
+ info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Browser = dataIn.ReadBoolean();
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.PrefetchSize = dataIn.ReadInt32();
+ info.MaximumPendingMessageLimit = dataIn.ReadInt32();
+ info.DispatchAsync = dataIn.ReadBoolean();
+ info.Selector = LooseUnmarshalString(dataIn);
+ info.SubcriptionName = LooseUnmarshalString(dataIn);
+ info.NoLocal = dataIn.ReadBoolean();
+ info.Exclusive = dataIn.ReadBoolean();
+ info.Retroactive = dataIn.ReadBoolean();
+ info.Priority = dataIn.ReadByte();
+
+ if (dataIn.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ BrokerId[] value = new BrokerId[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,dataIn);
+ }
+ info.BrokerPath = value;
+ }
+ else {
+ info.BrokerPath = null;
+ }
+ info.AdditionalPredicate = (BooleanExpression) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.NetworkSubscription = dataIn.ReadBoolean();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ConsumerInfo info = (ConsumerInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
+ dataOut.Write(info.Browser);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ dataOut.Write(info.PrefetchSize);
+ dataOut.Write(info.MaximumPendingMessageLimit);
+ dataOut.Write(info.DispatchAsync);
+ LooseMarshalString(info.Selector, dataOut);
+ LooseMarshalString(info.SubcriptionName, dataOut);
+ dataOut.Write(info.NoLocal);
+ dataOut.Write(info.Exclusive);
+ dataOut.Write(info.Retroactive);
+ dataOut.Write(info.Priority);
+ LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.AdditionalPredicate, dataOut);
+ dataOut.Write(info.NetworkSubscription);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -82,5 +81,30 @@
TightMarshalString2(info.Command, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ControlCommand info = (ControlCommand)o;
+ info.Command = LooseUnmarshalString(dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ControlCommand info = (ControlCommand)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.Command, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -70,7 +70,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -93,5 +92,41 @@
TightMarshalObjectArray2(wireFormat, info.Data, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ DataArrayResponse info = (DataArrayResponse)o;
+
+ if (dataIn.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ DataStructure[] value = new DataStructure[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (DataStructure) LooseUnmarshalNestedObject(wireFormat,dataIn);
+ }
+ info.Data = value;
+ }
+ else {
+ info.Data = null;
+ }
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ DataArrayResponse info = (DataArrayResponse)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalObjectArray(wireFormat, info.Data, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -82,5 +81,30 @@
TightMarshalNestedObject2(wireFormat, (DataStructure)info.Data, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ DataResponse info = (DataResponse)o;
+ info.Data = (DataStructure) LooseUnmarshalNestedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ DataResponse info = (DataResponse)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.Data, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -74,7 +74,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -104,5 +103,49 @@
TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ DestinationInfo info = (DestinationInfo)o;
+ info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.OperationType = dataIn.ReadByte();
+ info.Timeout = LooseUnmarshalLong(wireFormat, dataIn);
+
+ if (dataIn.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ BrokerId[] value = new BrokerId[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,dataIn);
+ }
+ info.BrokerPath = value;
+ }
+ else {
+ info.BrokerPath = null;
+ }
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ DestinationInfo info = (DestinationInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ dataOut.Write(info.OperationType);
+ LooseMarshalLong(wireFormat, info.Timeout, dataOut);
+ LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -60,7 +60,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -85,5 +84,32 @@
TightMarshalString2(info.BrokerName, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ DiscoveryEvent info = (DiscoveryEvent)o;
+ info.ServiceName = LooseUnmarshalString(dataIn);
+ info.BrokerName = LooseUnmarshalString(dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ DiscoveryEvent info = (DiscoveryEvent)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.ServiceName, dataOut);
+ LooseMarshalString(info.BrokerName, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -82,5 +81,30 @@
TightMarshalBrokerError2(wireFormat, info.Exception, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ExceptionResponse info = (ExceptionResponse)o;
+ info.Exception = LooseUnmarshalBrokerError(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ExceptionResponse info = (ExceptionResponse)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalBrokerError(wireFormat, info.Exception, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -56,7 +56,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -75,5 +74,24 @@
base.TightMarshal2(wireFormat, o, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -81,5 +80,30 @@
dataOut.Write(info.Result);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ IntegerResponse info = (IntegerResponse)o;
+ info.Result = dataIn.ReadInt32();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ IntegerResponse info = (IntegerResponse)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.Result);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -60,7 +60,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -85,5 +84,32 @@
TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageAck, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ JournalQueueAck info = (JournalQueueAck)o;
+ info.Destination = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.MessageAck = (MessageAck) LooseUnmarshalNestedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ JournalQueueAck info = (JournalQueueAck)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageAck, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -64,7 +64,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -97,5 +96,40 @@
TightMarshalNestedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ JournalTopicAck info = (JournalTopicAck)o;
+ info.Destination = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.MessageSequenceId = LooseUnmarshalLong(wireFormat, dataIn);
+ info.SubscritionName = LooseUnmarshalString(dataIn);
+ info.ClientId = LooseUnmarshalString(dataIn);
+ info.TransactionId = (TransactionId) LooseUnmarshalNestedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ JournalTopicAck info = (JournalTopicAck)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut);
+ LooseMarshalLong(wireFormat, info.MessageSequenceId, dataOut);
+ LooseMarshalString(info.SubscritionName, dataOut);
+ LooseMarshalString(info.ClientId, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -82,5 +81,30 @@
TightMarshalString2(info.Message, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ JournalTrace info = (JournalTrace)o;
+ info.Message = LooseUnmarshalString(dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ JournalTrace info = (JournalTrace)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.Message, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -61,7 +61,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -87,5 +86,34 @@
bs.ReadBoolean();
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ JournalTransaction info = (JournalTransaction)o;
+ info.TransactionId = (TransactionId) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.Type = dataIn.ReadByte();
+ info.WasPrepared = dataIn.ReadBoolean();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ JournalTransaction info = (JournalTransaction)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
+ dataOut.Write(info.Type);
+ dataOut.Write(info.WasPrepared);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -56,7 +56,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -75,5 +74,24 @@
base.TightMarshal2(wireFormat, o, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -60,7 +60,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -85,5 +84,32 @@
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ LocalTransactionId info = (LocalTransactionId)o;
+ info.Value = LooseUnmarshalLong(wireFormat, dataIn);
+ info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ LocalTransactionId info = (LocalTransactionId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalLong(wireFormat, info.Value, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -65,7 +65,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -98,5 +97,42 @@
dataOut.Write(info.MessageCount);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ MessageAck info = (MessageAck)o;
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.AckType = dataIn.ReadByte();
+ info.FirstMessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.LastMessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.MessageCount = dataIn.ReadInt32();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ MessageAck info = (MessageAck)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
+ dataOut.Write(info.AckType);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.FirstMessageId, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.LastMessageId, dataOut);
+ dataOut.Write(info.MessageCount);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -62,7 +62,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -90,5 +89,36 @@
dataOut.Write(info.RedeliveryCounter);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ MessageDispatch info = (MessageDispatch)o;
+ info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Message = (Message) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.RedeliveryCounter = dataIn.ReadInt32();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ MessageDispatch info = (MessageDispatch)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.Message, dataOut);
+ dataOut.Write(info.RedeliveryCounter);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -1 +1,125 @@
-//
//
// Copyright 2005-2006 The Apache Software Foundation
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
using System;
using System.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;
namespace ActiveMQ.OpenWire.V1
{
//
// Marshalling code for Open Wire Format for MessageDispatchNotification
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see
the Groovy scripts in the
// activemq-core module
//
public class MessageDispatchNotificationMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new MessageDispatchNotification();
}
public override byte GetDataStructureType()
{
return MessageDispatchNotification.ID_MessageDispatchNotification;
}
//
// Un-marshal an object instance from the data input stream
//
public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
{
base.TightUnmarshal(wireFormat, o, dataIn, bs);
MessageDispatchNotification info = (MessageDispatchNotification)o;
info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.DeliverySequenceId = TightUnmarshalLong(wireFormat,
dataIn, bs);
info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageDispatchNotification info = (MessageDispatchNotification)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
return rc + 0;
}
//
// Write a object instance to data output stream
//
public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
b
ase.TightMarshal2(wireFormat, o, dataOut, bs);
MessageDispatchNotification info = (MessageDispatchNotification)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
}
}
}
\ No newline at end of file
+//
+//
+// Copyright 2005-2006 The Apache Software Foundation
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+ //
+ // Marshalling code for Open Wire Format for MessageDispatchNotification
+ //
+ //
+ // NOTE!: This file is autogenerated - do not modify!
+ // if you need to make a change, please see the Groovy scripts in the
+ // activemq-core module
+ //
+ public class MessageDispatchNotificationMarshaller : BaseCommandMarshaller
+ {
+
+
+ public override DataStructure CreateObject()
+ {
+ return new MessageDispatchNotification();
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return MessageDispatchNotification.ID_MessageDispatchNotification;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+ MessageDispatchNotification info = (MessageDispatchNotification)o;
+ info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+ info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+ info.DeliverySequenceId = TightUnmarshalLong(wireFormat, dataIn, bs);
+ info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
+
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+ MessageDispatchNotification info = (MessageDispatchNotification)o;
+
+ int rc = base.TightMarshal1(wireFormat, info, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+ rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs);
+ rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+ MessageDispatchNotification info = (MessageDispatchNotification)o;
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+ TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs);
+ TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
+
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ MessageDispatchNotification info = (MessageDispatchNotification)o;
+ info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.DeliverySequenceId = LooseUnmarshalLong(wireFormat, dataIn);
+ info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ MessageDispatchNotification info = (MessageDispatchNotification)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalLong(wireFormat, info.DeliverySequenceId, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut);
+
+ }
+
+ }
+}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -61,7 +61,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -88,5 +87,34 @@
TightMarshalLong2(wireFormat, info.BrokerSequenceId, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ MessageId info = (MessageId)o;
+ info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.ProducerSequenceId = LooseUnmarshalLong(wireFormat, dataIn);
+ info.BrokerSequenceId = LooseUnmarshalLong(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ MessageId info = (MessageId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId, dataOut);
+ LooseMarshalLong(wireFormat, info.ProducerSequenceId, dataOut);
+ LooseMarshalLong(wireFormat, info.BrokerSequenceId, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -83,7 +83,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -159,5 +158,97 @@
bs.ReadBoolean();
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ Message info = (Message)o;
+ info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.OriginalDestination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.OriginalTransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.GroupID = LooseUnmarshalString(dataIn);
+ info.GroupSequence = dataIn.ReadInt32();
+ info.CorrelationId = LooseUnmarshalString(dataIn);
+ info.Persistent = dataIn.ReadBoolean();
+ info.Expiration = LooseUnmarshalLong(wireFormat, dataIn);
+ info.Priority = dataIn.ReadByte();
+ info.ReplyTo = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.Timestamp = LooseUnmarshalLong(wireFormat, dataIn);
+ info.Type = LooseUnmarshalString(dataIn);
+ info.Content = ReadBytes(dataIn, dataIn.ReadBoolean());
+ info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean());
+ info.DataStructure = (DataStructure) LooseUnmarshalNestedObject(wireFormat, dataIn);
+ info.TargetConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Compressed = dataIn.ReadBoolean();
+ info.RedeliveryCounter = dataIn.ReadInt32();
+
+ if (dataIn.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ BrokerId[] value = new BrokerId[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,dataIn);
+ }
+ info.BrokerPath = value;
+ }
+ else {
+ info.BrokerPath = null;
+ }
+ info.Arrival = LooseUnmarshalLong(wireFormat, dataIn);
+ info.UserID = LooseUnmarshalString(dataIn);
+ info.RecievedByDFBridge = dataIn.ReadBoolean();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ Message info = (Message)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.OriginalDestination, dataOut);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut);
+ LooseMarshalString(info.GroupID, dataOut);
+ dataOut.Write(info.GroupSequence);
+ LooseMarshalString(info.CorrelationId, dataOut);
+ dataOut.Write(info.Persistent);
+ LooseMarshalLong(wireFormat, info.Expiration, dataOut);
+ dataOut.Write(info.Priority);
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.ReplyTo, dataOut);
+ LooseMarshalLong(wireFormat, info.Timestamp, dataOut);
+ LooseMarshalString(info.Type, dataOut);
+ dataOut.Write(info.Content!=null);
+ if(info.Content!=null) {
+ dataOut.Write(info.Content.Length);
+ dataOut.Write(info.Content);
+ }
+ dataOut.Write(info.MarshalledProperties!=null);
+ if(info.MarshalledProperties!=null) {
+ dataOut.Write(info.MarshalledProperties.Length);
+ dataOut.Write(info.MarshalledProperties);
+ }
+ LooseMarshalNestedObject(wireFormat, (DataStructure)info.DataStructure, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.TargetConsumerId, dataOut);
+ dataOut.Write(info.Compressed);
+ dataOut.Write(info.RedeliveryCounter);
+ LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut);
+ LooseMarshalLong(wireFormat, info.Arrival, dataOut);
+ LooseMarshalString(info.UserID, dataOut);
+ dataOut.Write(info.RecievedByDFBridge);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/NetworkBridgeFilterMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/NetworkBridgeFilterMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/NetworkBridgeFilterMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/NetworkBridgeFilterMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -1 +1,114 @@
-//
//
// Copyright 2005-2006 The Apache Software Foundation
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
using System;
using System.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;
namespace ActiveMQ.OpenWire.V1
{
//
// Marshalling code for Open Wire Format for NetworkBridgeFilter
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groo
vy scripts in the
// activemq-core module
//
public class NetworkBridgeFilterMarshaller : BaseDataStreamMarshaller
{
public override DataStructure CreateObject()
{
return new NetworkBridgeFilter();
}
public override byte GetDataStructureType()
{
return NetworkBridgeFilter.ID_NetworkBridgeFilter;
}
//
// Un-marshal an object instance from the data input stream
//
public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
{
base.TightUnmarshal(wireFormat, o, dataIn, bs);
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
info.NetworkTTL = dataIn.ReadInt32();
info.NetworkBrokerId = (BrokerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, Boole
anStream bs) {
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.NetworkBrokerId, bs);
return rc + 4;
}
//
// Write a object instance to data output stream
//
public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
base.TightMarshal2(wireFormat, o, dataOut, bs);
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
dataOut.Write(info.NetworkTTL);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut, bs);
}
}
}
\ No newline at end of file
+//
+//
+// Copyright 2005-2006 The Apache Software Foundation
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+ //
+ // Marshalling code for Open Wire Format for NetworkBridgeFilter
+ //
+ //
+ // NOTE!: This file is autogenerated - do not modify!
+ // if you need to make a change, please see the Groovy scripts in the
+ // activemq-core module
+ //
+ public class NetworkBridgeFilterMarshaller : BaseDataStreamMarshaller
+ {
+
+
+ public override DataStructure CreateObject()
+ {
+ return new NetworkBridgeFilter();
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return NetworkBridgeFilter.ID_NetworkBridgeFilter;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+ info.NetworkTTL = dataIn.ReadInt32();
+ info.NetworkBrokerId = (BrokerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+
+ int rc = base.TightMarshal1(wireFormat, info, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.NetworkBrokerId, bs);
+
+ return rc + 4;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+ dataOut.Write(info.NetworkTTL);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut, bs);
+
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+ info.NetworkTTL = dataIn.ReadInt32();
+ info.NetworkBrokerId = (BrokerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.NetworkTTL);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut);
+
+ }
+
+ }
+}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -61,7 +61,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -88,5 +87,34 @@
TightMarshalLong2(wireFormat, info.SessionId, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ProducerId info = (ProducerId)o;
+ info.ConnectionId = LooseUnmarshalString(dataIn);
+ info.Value = LooseUnmarshalLong(wireFormat, dataIn);
+ info.SessionId = LooseUnmarshalLong(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ProducerId info = (ProducerId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.ConnectionId, dataOut);
+ LooseMarshalLong(wireFormat, info.Value, dataOut);
+ LooseMarshalLong(wireFormat, info.SessionId, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -72,7 +72,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -99,5 +98,45 @@
TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ProducerInfo info = (ProducerInfo)o;
+ info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+
+ if (dataIn.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ BrokerId[] value = new BrokerId[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,dataIn);
+ }
+ info.BrokerPath = value;
+ }
+ else {
+ info.BrokerPath = null;
+ }
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ProducerInfo info = (ProducerInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -82,5 +81,30 @@
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ObjectId, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ RemoveInfo info = (RemoveInfo)o;
+ info.ObjectId = (DataStructure) LooseUnmarshalCachedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ RemoveInfo info = (RemoveInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ObjectId, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -61,7 +61,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -88,5 +87,34 @@
TightMarshalString2(info.ClientId, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
+ info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.SubcriptionName = LooseUnmarshalString(dataIn);
+ info.ClientId = LooseUnmarshalString(dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
+ LooseMarshalString(info.SubcriptionName, dataOut);
+ LooseMarshalString(info.ClientId, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -1 +1,97 @@
-//
//
// Copyright 2005-2006 The Apache Software Foundation
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
using System;
using System.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;
namespace ActiveMQ.OpenWire.V1
{
//
// Marshalling code for Open Wire Format for ReplayCommand
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scr
ipts in the
// activemq-core module
//
public class ReplayCommandMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new ReplayCommand();
}
public override byte GetDataStructureType()
{
return ReplayCommand.ID_ReplayCommand;
}
//
// Un-marshal an object instance from the data input stream
//
public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
{
base.TightUnmarshal(wireFormat, o, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
ReplayCommand info = (ReplayCommand)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
return rc + 0;
}
//
// Write a object instance to data output stream
//
public o
verride void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
base.TightMarshal2(wireFormat, o, dataOut, bs);
}
}
}
\ No newline at end of file
+//
+//
+// Copyright 2005-2006 The Apache Software Foundation
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+ //
+ // Marshalling code for Open Wire Format for ReplayCommand
+ //
+ //
+ // NOTE!: This file is autogenerated - do not modify!
+ // if you need to make a change, please see the Groovy scripts in the
+ // activemq-core module
+ //
+ public class ReplayCommandMarshaller : BaseCommandMarshaller
+ {
+
+
+ public override DataStructure CreateObject()
+ {
+ return new ReplayCommand();
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return ReplayCommand.ID_ReplayCommand;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+ ReplayCommand info = (ReplayCommand)o;
+
+ int rc = base.TightMarshal1(wireFormat, info, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+
+ }
+
+ }
+}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -81,5 +80,30 @@
dataOut.Write(info.CorrelationId);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ Response info = (Response)o;
+ info.CorrelationId = dataIn.ReadInt16();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ Response info = (Response)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.CorrelationId);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -60,7 +60,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -85,5 +84,32 @@
TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ SessionId info = (SessionId)o;
+ info.ConnectionId = LooseUnmarshalString(dataIn);
+ info.Value = LooseUnmarshalLong(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ SessionId info = (SessionId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.ConnectionId, dataOut);
+ LooseMarshalLong(wireFormat, info.Value, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -59,7 +59,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -82,5 +81,30 @@
TightMarshalCachedObject2(wireFormat, (DataStructure)info.SessionId, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ SessionInfo info = (SessionInfo)o;
+ info.SessionId = (SessionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ SessionInfo info = (SessionInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.SessionId, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -56,7 +56,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -75,5 +74,24 @@
base.TightMarshal2(wireFormat, o, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+
+ }
+
}
}