activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r379827 [3/5] - in /incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client: Commands/ Core/ IO/
Date Wed, 22 Feb 2006 17:45:20 GMT
Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQStreamMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQStreamMessageMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQStreamMessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQStreamMessageMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ActiveMQStreamMessage
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,22 +26,55 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ActiveMQStreamMessageMarshaller : ActiveMQMessageMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ActiveMQStreamMessage
+  //
+  //
+  //  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 ActiveMQStreamMessageMarshaller : ActiveMQMessageMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ActiveMQStreamMessage();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ActiveMQStreamMessage.ID_ActiveMQStreamMessage;
+    }
 
-        public override Command CreateCommand() {
-            return new ActiveMQStreamMessage();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+    }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ActiveMQStreamMessage info = (ActiveMQStreamMessage)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempDestinationMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempDestinationMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempDestinationMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempDestinationMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ActiveMQTempDestination
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,18 +26,44 @@
 
 namespace OpenWire.Client.IO
 {
-    public abstract class ActiveMQTempDestinationMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ActiveMQTempDestination
+  //
+  //
+  //  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 abstract class ActiveMQTempDestinationMarshaller : ActiveMQDestinationMarshaller
+  {
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
     {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+    }
+
 
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ActiveMQTempDestination info = (ActiveMQTempDestination)o;
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+        int rc = base.Marshal1(wireFormat, info, bs);
 
-        }
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempQueueMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempQueueMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempQueueMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempQueueMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ActiveMQTempQueue
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,22 +26,55 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ActiveMQTempQueueMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ActiveMQTempQueue
+  //
+  //
+  //  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 ActiveMQTempQueueMarshaller : ActiveMQTempDestinationMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ActiveMQTempQueue();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ActiveMQTempQueue.ID_ActiveMQTempQueue;
+    }
 
-        public override Command CreateCommand() {
-            return new ActiveMQTempQueue();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+    }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ActiveMQTempQueue info = (ActiveMQTempQueue)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempTopicMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempTopicMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempTopicMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempTopicMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ActiveMQTempTopic
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,22 +26,55 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ActiveMQTempTopicMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ActiveMQTempTopic
+  //
+  //
+  //  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 ActiveMQTempTopicMarshaller : ActiveMQTempDestinationMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ActiveMQTempTopic();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ActiveMQTempTopic.ID_ActiveMQTempTopic;
+    }
 
-        public override Command CreateCommand() {
-            return new ActiveMQTempTopic();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+    }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ActiveMQTempTopic info = (ActiveMQTempTopic)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTextMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTextMessageMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTextMessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTextMessageMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ActiveMQTextMessage
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,22 +26,55 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ActiveMQTextMessageMarshaller : ActiveMQMessageMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ActiveMQTextMessage
+  //
+  //
+  //  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 ActiveMQTextMessageMarshaller : ActiveMQMessageMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ActiveMQTextMessage();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ActiveMQTextMessage.ID_ActiveMQTextMessage;
+    }
 
-        public override Command CreateCommand() {
-            return new ActiveMQTextMessage();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+    }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ActiveMQTextMessage info = (ActiveMQTextMessage)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTopicMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTopicMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTopicMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTopicMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ActiveMQTopic
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,22 +26,55 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ActiveMQTopicMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ActiveMQTopic
+  //
+  //
+  //  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 ActiveMQTopicMarshaller : ActiveMQDestinationMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ActiveMQTopic();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ActiveMQTopic.ID_ActiveMQTopic;
+    }
 
-        public override Command CreateCommand() {
-            return new ActiveMQTopic();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+    }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ActiveMQTopic info = (ActiveMQTopic)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BaseCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BaseCommandMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BaseCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BaseCommandMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for BaseCommand
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,26 +26,53 @@
 
 namespace OpenWire.Client.IO
 {
-    public abstract class BaseCommandMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for BaseCommand
+  //
+  //
+  //  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 abstract class BaseCommandMarshaller : DataStreamMarshaller
+  {
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
     {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
+        BaseCommand info = (BaseCommand)o;
+        info.CommandId = dataIn.ReadInt16();
+        info.ResponseRequired = bs.ReadBoolean();
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    }
 
-            BaseCommand info = (BaseCommand) command;
-            info.CommandId = dataIn.ReadInt16();
-            info.ResponseRequired = dataIn.ReadBoolean();
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        BaseCommand info = (BaseCommand)o;
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+        int rc = base.Marshal1(wireFormat, info, bs);
+                bs.WriteBoolean(info.ResponseRequired);
+
+        return rc + 1;
+    }
 
-            BaseCommand info = (BaseCommand) command;
-            dataOut.Write(info.CommandId);
-            dataOut.Write(info.ResponseRequired);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        BaseCommand info = (BaseCommand)o;
+        dataOut.Write((short)info.CommandId);
+        bs.ReadBoolean();
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerIdMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerIdMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for BrokerId
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,28 +26,62 @@
 
 namespace OpenWire.Client.IO
 {
-    public class BrokerIdMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for BrokerId
+  //
+  //
+  //  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 BrokerIdMarshaller : DataStreamMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new BrokerId();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return BrokerId.ID_BrokerId;
+    }
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+        BrokerId info = (BrokerId)o;
+        info.Value = ReadString(dataIn, bs);
+
+    }
 
-        public override Command CreateCommand() {
-            return new BrokerId();
-        }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        BrokerId info = (BrokerId)o;
 
-            BrokerId info = (BrokerId) command;
-            info.Value = dataIn.ReadString();
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += WriteString(info.Value, bs);
 
-        }
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-            BrokerId info = (BrokerId) command;
-            dataOut.Write(info.Value);
+        BrokerId info = (BrokerId)o;
+        WriteString(info.Value, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerInfoMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerInfoMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for BrokerInfo
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,34 +26,85 @@
 
 namespace OpenWire.Client.IO
 {
-    public class BrokerInfoMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for BrokerInfo
+  //
+  //
+  //  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 BrokerInfoMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new BrokerInfo();
+    }
+
+    public override byte GetDataStructureType() 
     {
+        return BrokerInfo.ID_BrokerInfo;
+    }
 
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
-        public override Command CreateCommand() {
-            return new BrokerInfo();
+        BrokerInfo info = (BrokerInfo)o;
+        info.BrokerId = (BrokerId) UnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.BrokerURL = ReadString(dataIn, bs);
+
+        if (bs.ReadBoolean()) {
+            short size = dataIn.ReadInt16();
+            BrokerInfo[] value = new BrokerInfo[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (BrokerInfo) UnmarshalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.PeerBrokerInfos = value;
         }
+        else {
+            info.PeerBrokerInfos = null;
+        }
+        info.BrokerName = ReadString(dataIn, bs);
+        info.SlaveBroker = bs.ReadBoolean();
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    }
 
-            BrokerInfo info = (BrokerInfo) command;
-            info.BrokerId = (BrokerId) CommandMarshallerRegistry.BrokerIdMarshaller.ReadCommand(dataIn);
-            info.BrokerURL = dataIn.ReadString();
-            info.PeerBrokerInfos = ReadBrokerInfos(dataIn);
-            info.BrokerName = dataIn.ReadString();
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        BrokerInfo info = (BrokerInfo)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += Marshal1CachedObject(wireFormat, info.BrokerId, bs);
+        rc += WriteString(info.BrokerURL, bs);
+        rc += MarshalObjectArray(wireFormat, info.PeerBrokerInfos, bs);
+        rc += WriteString(info.BrokerName, bs);
+        bs.WriteBoolean(info.SlaveBroker);
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+        return rc + 0;
+    }
 
-            BrokerInfo info = (BrokerInfo) command;
-            CommandMarshallerRegistry.BrokerIdMarshaller.WriteCommand(info.BrokerId, dataOut);
-            dataOut.Write(info.BrokerURL);
-            WriteBrokerInfos(info.PeerBrokerInfos, dataOut);
-            dataOut.Write(info.BrokerName);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        BrokerInfo info = (BrokerInfo)o;
+        Marshal2CachedObject(wireFormat, info.BrokerId, dataOut, bs);
+        WriteString(info.BrokerURL, dataOut, bs);
+        MarshalObjectArray(wireFormat, info.PeerBrokerInfos, dataOut, bs);
+        WriteString(info.BrokerName, dataOut, bs);
+        bs.ReadBoolean();
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionErrorMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionErrorMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionErrorMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionErrorMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ConnectionError
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,30 +26,65 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ConnectionErrorMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ConnectionError
+  //
+  //
+  //  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 ConnectionErrorMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ConnectionError();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ConnectionError.ID_ConnectionError;
+    }
 
-        public override Command CreateCommand() {
-            return new ConnectionError();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+        ConnectionError info = (ConnectionError)o;
+        info.Exception = UnmarshalBrokerError(wireFormat, dataIn, bs);
+        info.ConnectionId = (ConnectionId) UnmarshalNestedObject(wireFormat, dataIn, bs);
 
-            ConnectionError info = (ConnectionError) command;
-            info.Exception = ReadBrokerError(dataIn);
-            info.ConnectionId = (ConnectionId) CommandMarshallerRegistry.ConnectionIdMarshaller.ReadCommand(dataIn);
+    }
 
-        }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ConnectionError info = (ConnectionError)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += MarshalBrokerError(wireFormat, info.Exception, bs);
+        rc += Marshal1NestedObject(wireFormat, info.ConnectionId, bs);
+
+        return rc + 0;
+    }
 
-            ConnectionError info = (ConnectionError) command;
-            WriteBrokerError(info.Exception, dataOut);
-            CommandMarshallerRegistry.ConnectionIdMarshaller.WriteCommand(info.ConnectionId, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        ConnectionError info = (ConnectionError)o;
+        MarshalBrokerError(wireFormat, info.Exception, dataOut, bs);
+        Marshal2NestedObject(wireFormat, info.ConnectionId, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionIdMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionIdMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ConnectionId
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,28 +26,62 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ConnectionIdMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ConnectionId
+  //
+  //
+  //  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 ConnectionIdMarshaller : DataStreamMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ConnectionId();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ConnectionId.ID_ConnectionId;
+    }
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+        ConnectionId info = (ConnectionId)o;
+        info.Value = ReadString(dataIn, bs);
+
+    }
 
-        public override Command CreateCommand() {
-            return new ConnectionId();
-        }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ConnectionId info = (ConnectionId)o;
 
-            ConnectionId info = (ConnectionId) command;
-            info.Value = dataIn.ReadString();
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += WriteString(info.Value, bs);
 
-        }
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-            ConnectionId info = (ConnectionId) command;
-            dataOut.Write(info.Value);
+        ConnectionId info = (ConnectionId)o;
+        WriteString(info.Value, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionInfoMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionInfoMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ConnectionInfo
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,36 +26,85 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ConnectionInfoMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ConnectionInfo
+  //
+  //
+  //  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 ConnectionInfoMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new ConnectionInfo();
+    }
+
+    public override byte GetDataStructureType() 
     {
+        return ConnectionInfo.ID_ConnectionInfo;
+    }
 
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
-        public override Command CreateCommand() {
-            return new ConnectionInfo();
+        ConnectionInfo info = (ConnectionInfo)o;
+        info.ConnectionId = (ConnectionId) UnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.ClientId = ReadString(dataIn, bs);
+        info.Password = ReadString(dataIn, bs);
+        info.UserName = ReadString(dataIn, bs);
+
+        if (bs.ReadBoolean()) {
+            short size = dataIn.ReadInt16();
+            BrokerId[] value = new BrokerId[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (BrokerId) UnmarshalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.BrokerPath = value;
+        }
+        else {
+            info.BrokerPath = null;
         }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    }
 
-            ConnectionInfo info = (ConnectionInfo) command;
-            info.ConnectionId = (ConnectionId) CommandMarshallerRegistry.ConnectionIdMarshaller.ReadCommand(dataIn);
-            info.ClientId = dataIn.ReadString();
-            info.Password = dataIn.ReadString();
-            info.UserName = dataIn.ReadString();
-            info.BrokerPath = ReadBrokerIds(dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ConnectionInfo info = (ConnectionInfo)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += Marshal1CachedObject(wireFormat, info.ConnectionId, bs);
+        rc += WriteString(info.ClientId, bs);
+        rc += WriteString(info.Password, bs);
+        rc += WriteString(info.UserName, bs);
+        rc += MarshalObjectArray(wireFormat, info.BrokerPath, bs);
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+        return rc + 0;
+    }
 
-            ConnectionInfo info = (ConnectionInfo) command;
-            CommandMarshallerRegistry.ConnectionIdMarshaller.WriteCommand(info.ConnectionId, dataOut);
-            dataOut.Write(info.ClientId);
-            dataOut.Write(info.Password);
-            dataOut.Write(info.UserName);
-            WriteBrokerIds(info.BrokerPath, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        ConnectionInfo info = (ConnectionInfo)o;
+        Marshal2CachedObject(wireFormat, info.ConnectionId, dataOut, bs);
+        WriteString(info.ClientId, dataOut, bs);
+        WriteString(info.Password, dataOut, bs);
+        WriteString(info.UserName, dataOut, bs);
+        MarshalObjectArray(wireFormat, info.BrokerPath, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerIdMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerIdMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ConsumerId
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,32 +26,68 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ConsumerIdMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ConsumerId
+  //
+  //
+  //  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 ConsumerIdMarshaller : DataStreamMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ConsumerId();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ConsumerId.ID_ConsumerId;
+    }
 
-        public override Command CreateCommand() {
-            return new ConsumerId();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+        ConsumerId info = (ConsumerId)o;
+        info.ConnectionId = ReadString(dataIn, bs);
+        info.SessionId = UnmarshalLong(wireFormat, dataIn, bs);
+        info.Value = UnmarshalLong(wireFormat, dataIn, bs);
 
-            ConsumerId info = (ConsumerId) command;
-            info.ConnectionId = dataIn.ReadString();
-            info.SessionId = dataIn.ReadInt64();
-            info.Value = dataIn.ReadInt64();
+    }
 
-        }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ConsumerId info = (ConsumerId)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += WriteString(info.ConnectionId, bs);
+        rc += Marshal1Long(wireFormat, info.SessionId, bs);
+        rc += Marshal1Long(wireFormat, info.Value, bs);
+
+        return rc + 0;
+    }
 
-            ConsumerId info = (ConsumerId) command;
-            dataOut.Write(info.ConnectionId);
-            dataOut.Write(info.SessionId);
-            dataOut.Write(info.Value);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        ConsumerId info = (ConsumerId)o;
+        WriteString(info.ConnectionId, dataOut, bs);
+        Marshal2Long(wireFormat, info.SessionId, dataOut, bs);
+        Marshal2Long(wireFormat, info.Value, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerInfoMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerInfoMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ConsumerInfo
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,52 +26,107 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ConsumerInfoMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ConsumerInfo
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class ConsumerInfoMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new ConsumerInfo();
+    }
+
+    public override byte GetDataStructureType() 
     {
+        return ConsumerInfo.ID_ConsumerInfo;
+    }
 
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
-        public override Command CreateCommand() {
-            return new ConsumerInfo();
+        ConsumerInfo info = (ConsumerInfo)o;
+        info.ConsumerId = (ConsumerId) UnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.Browser = bs.ReadBoolean();
+        info.Destination = (ActiveMQDestination) UnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.PrefetchSize = dataIn.ReadInt32();
+        info.DispatchAsync = bs.ReadBoolean();
+        info.Selector = ReadString(dataIn, bs);
+        info.SubcriptionName = ReadString(dataIn, bs);
+        info.NoLocal = bs.ReadBoolean();
+        info.Exclusive = bs.ReadBoolean();
+        info.Retroactive = bs.ReadBoolean();
+        info.Priority = dataIn.ReadByte();
+
+        if (bs.ReadBoolean()) {
+            short size = dataIn.ReadInt16();
+            BrokerId[] value = new BrokerId[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (BrokerId) UnmarshalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.BrokerPath = value;
         }
+        else {
+            info.BrokerPath = null;
+        }
+        info.NetworkSubscription = bs.ReadBoolean();
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    }
 
-            ConsumerInfo info = (ConsumerInfo) command;
-            info.ConsumerId = (ConsumerId) CommandMarshallerRegistry.ConsumerIdMarshaller.ReadCommand(dataIn);
-            info.Browser = dataIn.ReadBoolean();
-            info.Destination = ReadDestination(dataIn);
-            info.PrefetchSize = dataIn.ReadInt32();
-            info.DispatchAsync = dataIn.ReadBoolean();
-            info.Selector = dataIn.ReadString();
-            info.SubcriptionName = dataIn.ReadString();
-            info.NoLocal = dataIn.ReadBoolean();
-            info.Exclusive = dataIn.ReadBoolean();
-            info.Retroactive = dataIn.ReadBoolean();
-            info.Priority = dataIn.ReadByte();
-            info.BrokerPath = ReadBrokerIds(dataIn);
-            info.NetworkSubscription = dataIn.ReadBoolean();
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ConsumerInfo info = (ConsumerInfo)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += Marshal1CachedObject(wireFormat, info.ConsumerId, bs);
+        bs.WriteBoolean(info.Browser);
+        rc += Marshal1CachedObject(wireFormat, info.Destination, bs);
+                bs.WriteBoolean(info.DispatchAsync);
+        rc += WriteString(info.Selector, bs);
+        rc += WriteString(info.SubcriptionName, bs);
+        bs.WriteBoolean(info.NoLocal);
+        bs.WriteBoolean(info.Exclusive);
+        bs.WriteBoolean(info.Retroactive);
+                rc += MarshalObjectArray(wireFormat, info.BrokerPath, bs);
+        bs.WriteBoolean(info.NetworkSubscription);
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+        return rc + 2;
+    }
 
-            ConsumerInfo info = (ConsumerInfo) command;
-            CommandMarshallerRegistry.ConsumerIdMarshaller.WriteCommand(info.ConsumerId, dataOut);
-            dataOut.Write(info.Browser);
-            WriteDestination(info.Destination, dataOut);
-            dataOut.Write(info.PrefetchSize);
-            dataOut.Write(info.DispatchAsync);
-            dataOut.Write(info.Selector);
-            dataOut.Write(info.SubcriptionName);
-            dataOut.Write(info.NoLocal);
-            dataOut.Write(info.Exclusive);
-            dataOut.Write(info.Retroactive);
-            dataOut.Write(info.Priority);
-            WriteBrokerIds(info.BrokerPath, dataOut);
-            dataOut.Write(info.NetworkSubscription);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        ConsumerInfo info = (ConsumerInfo)o;
+        Marshal2CachedObject(wireFormat, info.ConsumerId, dataOut, bs);
+        bs.ReadBoolean();
+        Marshal2CachedObject(wireFormat, info.Destination, dataOut, bs);
+        dataOut.Write((int) info.PrefetchSize);
+        bs.ReadBoolean();
+        WriteString(info.Selector, dataOut, bs);
+        WriteString(info.SubcriptionName, dataOut, bs);
+        bs.ReadBoolean();
+        bs.ReadBoolean();
+        bs.ReadBoolean();
+        dataOut.Write((byte) info.Priority);
+        MarshalObjectArray(wireFormat, info.BrokerPath, dataOut, bs);
+        bs.ReadBoolean();
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ControlCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ControlCommandMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ControlCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ControlCommandMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ControlCommand
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,28 +26,62 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ControlCommandMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ControlCommand
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class ControlCommandMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ControlCommand();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ControlCommand.ID_ControlCommand;
+    }
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+        ControlCommand info = (ControlCommand)o;
+        info.Command = ReadString(dataIn, bs);
+
+    }
 
-        public override Command CreateCommand() {
-            return new ControlCommand();
-        }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ControlCommand info = (ControlCommand)o;
 
-            ControlCommand info = (ControlCommand) command;
-            info.Command = dataIn.ReadString();
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += WriteString(info.Command, bs);
 
-        }
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-            ControlCommand info = (ControlCommand) command;
-            dataOut.Write(info.Command);
+        ControlCommand info = (ControlCommand)o;
+        WriteString(info.Command, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataArrayResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataArrayResponseMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataArrayResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataArrayResponseMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for DataArrayResponse
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,28 +26,73 @@
 
 namespace OpenWire.Client.IO
 {
-    public class DataArrayResponseMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for DataArrayResponse
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class DataArrayResponseMarshaller : ResponseMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new DataArrayResponse();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return DataArrayResponse.ID_DataArrayResponse;
+    }
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
-        public override Command CreateCommand() {
-            return new DataArrayResponse();
+        DataArrayResponse info = (DataArrayResponse)o;
+
+        if (bs.ReadBoolean()) {
+            short size = dataIn.ReadInt16();
+            DataStructure[] value = new DataStructure[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (DataStructure) UnmarshalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.Data = value;
+        }
+        else {
+            info.Data = null;
         }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    }
 
-            DataArrayResponse info = (DataArrayResponse) command;
-            info.Data = ReadDataStructures(dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        DataArrayResponse info = (DataArrayResponse)o;
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += MarshalObjectArray(wireFormat, info.Data, bs);
 
-            DataArrayResponse info = (DataArrayResponse) command;
-            WriteDataStructures(info.Data, dataOut);
+        return rc + 0;
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        DataArrayResponse info = (DataArrayResponse)o;
+        MarshalObjectArray(wireFormat, info.Data, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataResponseMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataResponseMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for DataResponse
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,28 +26,62 @@
 
 namespace OpenWire.Client.IO
 {
-    public class DataResponseMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for DataResponse
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class DataResponseMarshaller : ResponseMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new DataResponse();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return DataResponse.ID_DataResponse;
+    }
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+        DataResponse info = (DataResponse)o;
+        info.Data = (DataStructure) UnmarshalNestedObject(wireFormat, dataIn, bs);
+
+    }
 
-        public override Command CreateCommand() {
-            return new DataResponse();
-        }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        DataResponse info = (DataResponse)o;
 
-            DataResponse info = (DataResponse) command;
-            info.Data = CommandMarshallerRegistry.ReadCommand(dataIn);
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += Marshal1NestedObject(wireFormat, info.Data, bs);
 
-        }
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-            DataResponse info = (DataResponse) command;
-            CommandMarshallerRegistry.WriteCommand((Command) info.Data, dataOut);
+        DataResponse info = (DataResponse)o;
+        Marshal2NestedObject(wireFormat, info.Data, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DestinationInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DestinationInfoMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DestinationInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DestinationInfoMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for DestinationInfo
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,36 +26,84 @@
 
 namespace OpenWire.Client.IO
 {
-    public class DestinationInfoMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for DestinationInfo
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class DestinationInfoMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new DestinationInfo();
+    }
+
+    public override byte GetDataStructureType() 
     {
+        return DestinationInfo.ID_DestinationInfo;
+    }
 
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
-        public override Command CreateCommand() {
-            return new DestinationInfo();
+        DestinationInfo info = (DestinationInfo)o;
+        info.ConnectionId = (ConnectionId) UnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.Destination = (ActiveMQDestination) UnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.OperationType = dataIn.ReadByte();
+        info.Timeout = UnmarshalLong(wireFormat, dataIn, bs);
+
+        if (bs.ReadBoolean()) {
+            short size = dataIn.ReadInt16();
+            BrokerId[] value = new BrokerId[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (BrokerId) UnmarshalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.BrokerPath = value;
+        }
+        else {
+            info.BrokerPath = null;
         }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    }
 
-            DestinationInfo info = (DestinationInfo) command;
-            info.ConnectionId = (ConnectionId) CommandMarshallerRegistry.ConnectionIdMarshaller.ReadCommand(dataIn);
-            info.Destination = ReadDestination(dataIn);
-            info.OperationType = dataIn.ReadByte();
-            info.Timeout = dataIn.ReadInt64();
-            info.BrokerPath = ReadBrokerIds(dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        DestinationInfo info = (DestinationInfo)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += Marshal1CachedObject(wireFormat, info.ConnectionId, bs);
+        rc += Marshal1CachedObject(wireFormat, info.Destination, bs);
+                rc += Marshal1Long(wireFormat, info.Timeout, bs);
+        rc += MarshalObjectArray(wireFormat, info.BrokerPath, bs);
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+        return rc + 1;
+    }
 
-            DestinationInfo info = (DestinationInfo) command;
-            CommandMarshallerRegistry.ConnectionIdMarshaller.WriteCommand(info.ConnectionId, dataOut);
-            WriteDestination(info.Destination, dataOut);
-            dataOut.Write(info.OperationType);
-            dataOut.Write(info.Timeout);
-            WriteBrokerIds(info.BrokerPath, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        DestinationInfo info = (DestinationInfo)o;
+        Marshal2CachedObject(wireFormat, info.ConnectionId, dataOut, bs);
+        Marshal2CachedObject(wireFormat, info.Destination, dataOut, bs);
+        dataOut.Write((byte) info.OperationType);
+        Marshal2Long(wireFormat, info.Timeout, dataOut, bs);
+        MarshalObjectArray(wireFormat, info.BrokerPath, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DiscoveryEventMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DiscoveryEventMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DiscoveryEventMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DiscoveryEventMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for DiscoveryEvent
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,30 +26,65 @@
 
 namespace OpenWire.Client.IO
 {
-    public class DiscoveryEventMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for DiscoveryEvent
+  //
+  //
+  //  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 DiscoveryEventMarshaller : DataStreamMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new DiscoveryEvent();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return DiscoveryEvent.ID_DiscoveryEvent;
+    }
 
-        public override Command CreateCommand() {
-            return new DiscoveryEvent();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+        DiscoveryEvent info = (DiscoveryEvent)o;
+        info.ServiceName = ReadString(dataIn, bs);
+        info.BrokerName = ReadString(dataIn, bs);
 
-            DiscoveryEvent info = (DiscoveryEvent) command;
-            info.ServiceName = dataIn.ReadString();
-            info.BrokerName = dataIn.ReadString();
+    }
 
-        }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        DiscoveryEvent info = (DiscoveryEvent)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += WriteString(info.ServiceName, bs);
+        rc += WriteString(info.BrokerName, bs);
+
+        return rc + 0;
+    }
 
-            DiscoveryEvent info = (DiscoveryEvent) command;
-            dataOut.Write(info.ServiceName);
-            dataOut.Write(info.BrokerName);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
+
+        DiscoveryEvent info = (DiscoveryEvent)o;
+        WriteString(info.ServiceName, dataOut, bs);
+        WriteString(info.BrokerName, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ExceptionResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ExceptionResponseMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ExceptionResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ExceptionResponseMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for ExceptionResponse
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,28 +26,62 @@
 
 namespace OpenWire.Client.IO
 {
-    public class ExceptionResponseMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for ExceptionResponse
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class ExceptionResponseMarshaller : ResponseMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new ExceptionResponse();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return ExceptionResponse.ID_ExceptionResponse;
+    }
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+        ExceptionResponse info = (ExceptionResponse)o;
+        info.Exception = UnmarshalBrokerError(wireFormat, dataIn, bs);
+
+    }
 
-        public override Command CreateCommand() {
-            return new ExceptionResponse();
-        }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        ExceptionResponse info = (ExceptionResponse)o;
 
-            ExceptionResponse info = (ExceptionResponse) command;
-            info.Exception = ReadBrokerError(dataIn);
+        int rc = base.Marshal1(wireFormat, info, bs);
+        rc += MarshalBrokerError(wireFormat, info.Exception, bs);
 
-        }
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-            ExceptionResponse info = (ExceptionResponse) command;
-            WriteBrokerError(info.Exception, dataOut);
+        ExceptionResponse info = (ExceptionResponse)o;
+        MarshalBrokerError(wireFormat, info.Exception, dataOut, bs);
 
-        }
     }
+  }
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/FlushCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/FlushCommandMarshaller.cs?rev=379827&r1=379826&r2=379827&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/FlushCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/FlushCommandMarshaller.cs Wed Feb 22 09:45:12 2006
@@ -1,10 +1,18 @@
 //
-// Marshalling code for Open Wire Format for FlushCommand
 //
+// Copyright 2005-2006 The Apache Software Foundation
 //
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
+// 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;
@@ -18,22 +26,55 @@
 
 namespace OpenWire.Client.IO
 {
-    public class FlushCommandMarshaller : AbstractCommandMarshaller
+  //
+  //  Marshalling code for Open Wire Format for FlushCommand
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class FlushCommandMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
     {
+        return new FlushCommand();
+    }
 
+    public override byte GetDataStructureType() 
+    {
+        return FlushCommand.ID_FlushCommand;
+    }
 
-        public override Command CreateCommand() {
-            return new FlushCommand();
-        }
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void Unmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.Unmarshal(wireFormat, o, dataIn, bs);
+
+    }
 
-        public override void BuildCommand(Command command, BinaryReader dataIn) {
-            base.BuildCommand(command, dataIn);
 
-        }
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int Marshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        FlushCommand info = (FlushCommand)o;
+
+        int rc = base.Marshal1(wireFormat, info, bs);
+
+        return rc + 0;
+    }
 
-        public override void WriteCommand(Command command, BinaryWriter dataOut) {
-            base.WriteCommand(command, dataOut);
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void Marshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.Marshal2(wireFormat, o, dataOut, bs);
 
-        }
     }
+  }
 }



Mime
View raw message