activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject 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...
Date Thu, 09 Mar 2006 00:41:58 GMT
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);
+
+    }
+    
   }
 }



Mime
View raw message