activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r387665 [6/9] - in /incubator/activemq/trunk: activecluster/src/java/org/apache/activecluster/impl/ activemq-core/src/main/java/org/apache/activemq/advisory/ activemq-core/src/main/java/org/apache/activemq/broker/jmx/ activemq-core/src/main...
Date Tue, 21 Mar 2006 23:21:29 GMT
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/XATransactionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/XATransactionId.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/XATransactionId.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/XATransactionId.cs Tue Mar 21 15:20:55 2006
@@ -1 +1,106 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* 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.
*/

//
//  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
//

using System;
using System.Collections;

using ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ XATransactionId Comman
 d
	/// </summary>
    public class XATransactionId : TransactionId, Xid
    {
        public const byte ID_XATransactionId = 112;
    			
        int formatId;
        byte[] globalTransactionId;
        byte[] branchQualifier;

		public override int GetHashCode() {
            int answer = 0;
            answer = (answer * 37) + HashCode(FormatId);
            answer = (answer * 37) + HashCode(GlobalTransactionId);
            answer = (answer * 37) + HashCode(BranchQualifier);
            return answer;

		}
	

		public override bool Equals(object that) {
	    	if (that is XATransactionId) {
	    	    return Equals((XATransactionId) that);
			}
			return false;
    	}
    
		public virtual bool Equals(XATransactionId that) {
            if (! Equals(this.FormatId, that.FormatId)) return false;
            if (! Equals(this.GlobalTransactionId, that.GlobalTransactionId)) return false;
            if (! Equals(this.BranchQualifier, that.BranchQualifier)) return false;
      
       return true;

		}
	

		public override string ToString() {
            return GetType().Name + "["
                + " FormatId=" + FormatId
                + " GlobalTransactionId=" + GlobalTransactionId
                + " BranchQualifier=" + BranchQualifier
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_XATransactionId;
        }


        // Properties

        public int FormatId
        {
            get { return formatId; }
            set { this.formatId = value; }            
        }

        public byte[] GlobalTransactionId
        {
            get { return globalTransactionId; }
            set { this.globalTransactionId = value; }            
        }

        public byte[] BranchQualifier
        {
            get { return branchQualifier; }
            set { this.branchQualifier = value; }            
        }

    }
}
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* 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.
+*/
+
+//
+//  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
+//
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+	/// <summary>
+    ///  The ActiveMQ XATransactionId Command
+	/// </summary>
+    public class XATransactionId : TransactionId, Xid
+    {
+        public const byte ID_XATransactionId = 112;
+    			
+        int formatId;
+        byte[] globalTransactionId;
+        byte[] branchQualifier;
+
+		public override int GetHashCode() {
+            int answer = 0;
+            answer = (answer * 37) + HashCode(FormatId);
+            answer = (answer * 37) + HashCode(GlobalTransactionId);
+            answer = (answer * 37) + HashCode(BranchQualifier);
+            return answer;
+
+		}
+	
+
+		public override bool Equals(object that) {
+	    	if (that is XATransactionId) {
+	    	    return Equals((XATransactionId) that);
+			}
+			return false;
+    	}
+    
+		public virtual bool Equals(XATransactionId that) {
+            if (! Equals(this.FormatId, that.FormatId)) return false;
+            if (! Equals(this.GlobalTransactionId, that.GlobalTransactionId)) return false;
+            if (! Equals(this.BranchQualifier, that.BranchQualifier)) return false;
+            return true;
+
+		}
+	
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " FormatId=" + FormatId
+                + " GlobalTransactionId=" + GlobalTransactionId
+                + " BranchQualifier=" + BranchQualifier
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_XATransactionId;
+        }
+
+
+        // Properties
+
+        public int FormatId
+        {
+            get { return formatId; }
+            set { this.formatId = value; }            
+        }
+
+        public byte[] GlobalTransactionId
+        {
+            get { return globalTransactionId; }
+            set { this.globalTransactionId = value; }            
+        }
+
+        public byte[] BranchQualifier
+        {
+            get { return branchQualifier; }
+            set { this.branchQualifier = value; }            
+        }
+
+    }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/XATransactionId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Xid.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Dispatcher.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/ISynchronization.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/ISynchronization.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/ISynchronization.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/ISynchronization.cs Tue Mar 21 15:20:55 2006
@@ -1,38 +1,38 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.
- */
-
-namespace ActiveMQ
-{
-	public interface ISynchronization
-    {
-        /// <summary>
-        /// Called before a commit
-        /// </summary>
-        void BeforeCommit();
-        
-        /// <summary>
-        /// Called after a commit
-        /// </summary>
-        void AfterCommit();
-        
-        /// <summary>
-        /// Called after a transaction rollback
-        /// </summary>
-        void AfterRollback();
-    }
-}
-
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+ */
+
+namespace ActiveMQ
+{
+	public interface ISynchronization
+    {
+        /// <summary>
+        /// Called before a commit
+        /// </summary>
+        void BeforeCommit();
+        
+        /// <summary>
+        /// Called after a commit
+        /// </summary>
+        void AfterCommit();
+        
+        /// <summary>
+        /// Called after a transaction rollback
+        /// </summary>
+        void AfterRollback();
+    }
+}
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/ISynchronization.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/BooleanStream.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/BooleanStream.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/BooleanStream.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/BooleanStream.cs Tue Mar 21 15:20:55 2006
@@ -1,122 +1,122 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.IO;
-
-using ActiveMQ.OpenWire;
-
-namespace ActiveMQ.OpenWire
-
-{
-    /// <summary>
-    /// Represents a stream of boolean flags
-    /// </summary>
-    public class BooleanStream
-    {
-        byte[] data = new byte[48];
-        short arrayLimit;
-        short arrayPos;
-        byte bytePos;
-        
-        public bool ReadBoolean()
-        {
-            byte b = data[arrayPos];
-            bool rc = ((b >> bytePos) & 0x01) != 0;
-            bytePos++;
-            if (bytePos >= 8)
-            {
-                bytePos = 0;
-                arrayPos++;
-            }
-            return rc;
-        }
-        
-        public void WriteBoolean(bool value)
-        {
-            if (bytePos == 0)
-            {
-                arrayLimit++;
-                if (arrayLimit >= data.Length)
-                {
-                    // re-grow the array.
-                    byte[] d = new byte[data.Length * 2];
-					Array.Copy(data, d, data.Length);
-                    data = d;
-                }
-            }
-            if (value)
-            {
-                data[arrayPos] |= (byte) (0x01 << bytePos);
-            }
-            bytePos++;
-            if (bytePos >= 8)
-            {
-                bytePos = 0;
-                arrayPos++;
-            }
-        }
-        
-        public void Marshal(BinaryWriter dataOut)
-        {
-			if( arrayLimit < 64 ) {
-				dataOut.Write((byte)arrayLimit);
-			} else if( arrayLimit < 256 ) { // max value of unsigned byte
-				dataOut.Write((byte)0xC0);
-				dataOut.Write((byte)arrayLimit);
-			} else {
-				dataOut.Write((byte)0x80);
-				dataOut.Write(arrayLimit);
-			}
-            dataOut.Write(data, 0, arrayLimit);
-            Clear();
-        }
-        
-        public void Unmarshal(BinaryReader dataIn)
-        {
-            arrayLimit = (short)(dataIn.ReadByte() & 0xFF);
-			if ( arrayLimit == 0xC0 ) {
-				arrayLimit = (short)(dataIn.ReadByte() & 0xFF);
-			} else if( arrayLimit == 0x80 ) {
-				arrayLimit = dataIn.ReadInt16();
-			}
-			if( data.Length < arrayLimit ) {
-				data = new byte[arrayLimit];
-			}
-			
-            dataIn.Read(data, 0, arrayLimit);
-            Clear();
-        }
-        
-        public void Clear()
-        {
-            arrayPos = 0;
-            bytePos = 0;
-        }
-        
-        public int MarshalledSize()
-        {
-			if( arrayLimit < 64 ) {
-				return 1+arrayLimit;
-			} else if (arrayLimit < 256) {
-				return 2+arrayLimit;
-			} else {
-				return 3+arrayLimit;
-			}
-			
-        }
-    }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.IO;
+
+using ActiveMQ.OpenWire;
+
+namespace ActiveMQ.OpenWire
+
+{
+    /// <summary>
+    /// Represents a stream of boolean flags
+    /// </summary>
+    public class BooleanStream
+    {
+        byte[] data = new byte[48];
+        short arrayLimit;
+        short arrayPos;
+        byte bytePos;
+        
+        public bool ReadBoolean()
+        {
+            byte b = data[arrayPos];
+            bool rc = ((b >> bytePos) & 0x01) != 0;
+            bytePos++;
+            if (bytePos >= 8)
+            {
+                bytePos = 0;
+                arrayPos++;
+            }
+            return rc;
+        }
+        
+        public void WriteBoolean(bool value)
+        {
+            if (bytePos == 0)
+            {
+                arrayLimit++;
+                if (arrayLimit >= data.Length)
+                {
+                    // re-grow the array.
+                    byte[] d = new byte[data.Length * 2];
+					Array.Copy(data, d, data.Length);
+                    data = d;
+                }
+            }
+            if (value)
+            {
+                data[arrayPos] |= (byte) (0x01 << bytePos);
+            }
+            bytePos++;
+            if (bytePos >= 8)
+            {
+                bytePos = 0;
+                arrayPos++;
+            }
+        }
+        
+        public void Marshal(BinaryWriter dataOut)
+        {
+			if( arrayLimit < 64 ) {
+				dataOut.Write((byte)arrayLimit);
+			} else if( arrayLimit < 256 ) { // max value of unsigned byte
+				dataOut.Write((byte)0xC0);
+				dataOut.Write((byte)arrayLimit);
+			} else {
+				dataOut.Write((byte)0x80);
+				dataOut.Write(arrayLimit);
+			}
+            dataOut.Write(data, 0, arrayLimit);
+            Clear();
+        }
+        
+        public void Unmarshal(BinaryReader dataIn)
+        {
+            arrayLimit = (short)(dataIn.ReadByte() & 0xFF);
+			if ( arrayLimit == 0xC0 ) {
+				arrayLimit = (short)(dataIn.ReadByte() & 0xFF);
+			} else if( arrayLimit == 0x80 ) {
+				arrayLimit = dataIn.ReadInt16();
+			}
+			if( data.Length < arrayLimit ) {
+				data = new byte[arrayLimit];
+			}
+			
+            dataIn.Read(data, 0, arrayLimit);
+            Clear();
+        }
+        
+        public void Clear()
+        {
+            arrayPos = 0;
+            bytePos = 0;
+        }
+        
+        public int MarshalledSize()
+        {
+			if( arrayLimit < 64 ) {
+				return 1+arrayLimit;
+			} else if (arrayLimit < 256) {
+				return 2+arrayLimit;
+			} else {
+				return 3+arrayLimit;
+			}
+			
+        }
+    }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/BooleanStream.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/EndianSupport.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/MessagePropertyHelper.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/MessagePropertyHelper.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/MessagePropertyHelper.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/MessagePropertyHelper.cs Tue Mar 21 15:20:55 2006
@@ -1,53 +1,53 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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 ActiveMQ.Commands;
-using System.Collections;
-
-namespace ActiveMQ.OpenWire
-{
-    public delegate object PropertyGetter(ActiveMQMessage message);
-    public delegate void PropertySetter(ActiveMQMessage message, object value);
-    
-    public class MessagePropertyHelper
-    {
-        private IDictionary setters = new Hashtable();
-        private IDictionary getters = new Hashtable();
-        
-        public MessagePropertyHelper()
-        {
-            // TODO find all of the JMS properties via introspection
-        }
-        
-        
-        public object GetObjectProperty(ActiveMQMessage message, string name) {
-            object getter = getters[name];
-            if (getter != null) {
-            }
-            return message.Properties[name];
-        }
-        
-        public void SetObjectProperty(ActiveMQMessage message, string name, object value) {
-            PropertySetter setter = (PropertySetter) setters[name];
-            if (setter != null) {
-                setter(message, value);
-            }
-            else {
-                message.Properties[name] = value;
-            }
-        }
-    }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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 ActiveMQ.Commands;
+using System.Collections;
+
+namespace ActiveMQ.OpenWire
+{
+    public delegate object PropertyGetter(ActiveMQMessage message);
+    public delegate void PropertySetter(ActiveMQMessage message, object value);
+    
+    public class MessagePropertyHelper
+    {
+        private IDictionary setters = new Hashtable();
+        private IDictionary getters = new Hashtable();
+        
+        public MessagePropertyHelper()
+        {
+            // TODO find all of the JMS properties via introspection
+        }
+        
+        
+        public object GetObjectProperty(ActiveMQMessage message, string name) {
+            object getter = getters[name];
+            if (getter != null) {
+            }
+            return message.Properties[name];
+        }
+        
+        public void SetObjectProperty(ActiveMQMessage message, string name, object value) {
+            PropertySetter setter = (PropertySetter) setters[name];
+            if (setter != null) {
+                setter(message, value);
+            }
+            else {
+                message.Properties[name] = value;
+            }
+        }
+    }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/MessagePropertyHelper.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/OpenWireBinaryReader.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/OpenWireBinaryWriter.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/OpenWireFormat.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/OpenWireFormat.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/OpenWireFormat.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/OpenWireFormat.cs Tue Mar 21 15:20:55 2006
@@ -1,279 +1,279 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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 ActiveMQ.Commands;
-using ActiveMQ.OpenWire.V1;
-using System;
-using System.IO;
-
-namespace ActiveMQ.OpenWire
-{
-    /// <summary>
-    /// Represents the wire format
-    /// </summary>
-    public class OpenWireFormat
-    {
-        
-        private BaseDataStreamMarshaller[] dataMarshallers;
-        private const byte NULL_TYPE = 0;
-		
-		private int version=1;
-		private bool stackTraceEnabled=false;
-		private bool tightEncodingEnabled=false;
-		private bool sizePrefixDisabled=false;
-		
-        public OpenWireFormat()
-        {
-            dataMarshallers = new BaseDataStreamMarshaller[256];
-            MarshallerFactory factory = new MarshallerFactory();
-            factory.configure(this);
-        }
-                
-        public bool StackTraceEnabled {
-            get { return stackTraceEnabled; }
-			set { stackTraceEnabled = value; }
-        }
-        public int Version {
-            get { return version; }
-			set { version = value; }
-        }
-        public bool SizePrefixDisabled {
-            get { return sizePrefixDisabled; }
-			set { sizePrefixDisabled = value; }
-        }
-        public bool TightEncodingEnabled {
-            get { return tightEncodingEnabled; }
-			set { tightEncodingEnabled = value; }
-        }
-        
-        public void addMarshaller(BaseDataStreamMarshaller marshaller)
-        {
-            byte type = marshaller.GetDataStructureType();
-            dataMarshallers[type & 0xFF] = marshaller;
-        }
-        
-        public void Marshal(Object o, BinaryWriter ds)
-        {
-            int size = 1;
-            if (o != null)
-            {
-                DataStructure c = (DataStructure) o;
-                byte type = c.GetDataStructureType();
-                BaseDataStreamMarshaller dsm = dataMarshallers[type & 0xFF];
-                if (dsm == null)
-                    throw new IOException("Unknown data type: " + type);
-
-                if(tightEncodingEnabled) {
-					
-					BooleanStream bs = new BooleanStream();
-					size += dsm.TightMarshal1(this, c, bs);
-					size += bs.MarshalledSize();
-					
-                    if( !sizePrefixDisabled ) {
-						ds.Write(size);
-					}
-					
-					ds.Write(type);
-					bs.Marshal(ds);
-					dsm.TightMarshal2(this, c, ds, bs);
-					
-				} else {
-					
-					BinaryWriter looseOut = ds;
-					MemoryStream ms = null;
-					// If we are prefixing then we need to first write it to memory,
-					// otherwise we can write direct to the stream.
-					if( !sizePrefixDisabled ) {
-						ms= new MemoryStream();
-						looseOut = new OpenWireBinaryWriter(ms);
-						looseOut.Write(size);
-					}
-					
-					looseOut.Write(type);
-					dsm.LooseMarshal(this, c, looseOut);
-					
-					if( !sizePrefixDisabled ) {
-						ms.Position=0;
-						looseOut.Write( (int)ms.Length-4 );
-						ds.Write(ms.GetBuffer(), 0, (int)ms.Length);
-					}
-				}
-            }
-            else
-            {
-                ds.Write(size);
-                ds.Write(NULL_TYPE);
-            }
-        }
-        
-        public Object Unmarshal(BinaryReader dis)
-        {
-            // lets ignore the size of the packet
-			if( !sizePrefixDisabled ) {
-				dis.ReadInt32();
-			}
-            
-            // first byte is the type of the packet
-            byte dataType = dis.ReadByte();
-            if (dataType != NULL_TYPE)
-            {
-                BaseDataStreamMarshaller dsm = dataMarshallers[dataType & 0xFF];
-                if (dsm == null)
-                    throw new IOException("Unknown data type: " + dataType);
-                //Console.WriteLine("Parsing type: " + dataType + " with: " + dsm);
-                Object data = dsm.CreateObject();
-				
-				if(tightEncodingEnabled) {
-					BooleanStream bs = new BooleanStream();
-					bs.Unmarshal(dis);
-					dsm.TightUnmarshal(this, data, dis, bs);
-					return data;
-				} else {
-					dsm.LooseUnmarshal(this, data, dis);
-					return data;
-				}
-            }
-            else
-            {
-                return null;
-            }
-        }
-        
-        public int TightMarshalNestedObject1(DataStructure o, BooleanStream bs)
-        {
-            bs.WriteBoolean(o != null);
-            if (o == null)
-                return 0;
-            
-            if (o.IsMarshallAware())
-            {
-                MarshallAware ma = (MarshallAware) o;
-                byte[] sequence = ma.GetMarshalledForm(this);
-                bs.WriteBoolean(sequence != null);
-                if (sequence != null)
-                {
-                    return 1 + sequence.Length;
-                }
-            }
-            
-            byte type = o.GetDataStructureType();
-            if (type == 0) {
-                throw new IOException("No valid data structure type for: " + o + " of type: " + o.GetType());
-            }
-            BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[type & 0xFF];
-            if (dsm == null)
-                throw new IOException("Unknown data type: " + type);
-            //Console.WriteLine("Marshalling type: " + type + " with structure: " + o);
-            return 1 + dsm.TightMarshal1(this, o, bs);
-        }
-        
-        public void TightMarshalNestedObject2(DataStructure o, BinaryWriter ds, BooleanStream bs)
-        {
-            if (!bs.ReadBoolean())
-                return ;
-            
-            byte type = o.GetDataStructureType();
-            ds.Write(type);
-            
-            if (o.IsMarshallAware() && bs.ReadBoolean())
-            {
-                MarshallAware ma = (MarshallAware) o;
-                byte[] sequence = ma.GetMarshalledForm(this);
-                ds.Write(sequence, 0, sequence.Length);
-            }
-            else
-            {
-                
-                BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[type & 0xFF];
-                if (dsm == null)
-                    throw new IOException("Unknown data type: " + type);
-                dsm.TightMarshal2(this, o, ds, bs);
-            }
-        }
-        
-        public DataStructure TightUnmarshalNestedObject(BinaryReader dis, BooleanStream bs)
-        {
-            if (bs.ReadBoolean())
-            {
-                
-                byte dataType = dis.ReadByte();
-                BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[dataType & 0xFF];
-                if (dsm == null)
-                    throw new IOException("Unknown data type: " + dataType);
-                DataStructure data = dsm.CreateObject();
-                
-                if (data.IsMarshallAware() && bs.ReadBoolean())
-                {
-                    dis.ReadInt32();
-                    dis.ReadByte();
-                    
-                    BooleanStream bs2 = new BooleanStream();
-                    bs2.Unmarshal(dis);
-                    dsm.TightUnmarshal(this, data, dis, bs2);
-                    
-                    // TODO: extract the sequence from the dis and associate it.
-                    //                MarshallAware ma = (MarshallAware)data
-                    //                ma.setCachedMarshalledForm(this, sequence);
-                }
-                else
-                {
-                    dsm.TightUnmarshal(this, data, dis, bs);
-                }
-                
-                return data;
-            }
-            else
-            {
-                return null;
-            }
-        }
-
-
-        
-        public void LooseMarshalNestedObject(DataStructure o, BinaryWriter dataOut)
-        {
-			dataOut.Write(o!=null);
-			if( o!=null ) {
-				byte type = o.GetDataStructureType();
-				dataOut.Write(type);
-                BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[type & 0xFF];
-				if( dsm == null )
-					throw new IOException("Unknown data type: "+type);
-				dsm.LooseMarshal(this, o, dataOut);
-			}
-        }
-        
-        public DataStructure LooseUnmarshalNestedObject(BinaryReader dis)
-        {
-            if (dis.ReadBoolean())
-            {
-                
-                byte dataType = dis.ReadByte();
-                BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[dataType & 0xFF];
-                if (dsm == null)
-                    throw new IOException("Unknown data type: " + dataType);
-                DataStructure data = dsm.CreateObject();
-				dsm.LooseUnmarshal(this, data, dis);
-                return data;
-            }
-            else
-            {
-                return null;
-            }
-        }
-        
-    }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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 ActiveMQ.Commands;
+using ActiveMQ.OpenWire.V1;
+using System;
+using System.IO;
+
+namespace ActiveMQ.OpenWire
+{
+    /// <summary>
+    /// Represents the wire format
+    /// </summary>
+    public class OpenWireFormat
+    {
+        
+        private BaseDataStreamMarshaller[] dataMarshallers;
+        private const byte NULL_TYPE = 0;
+		
+		private int version=1;
+		private bool stackTraceEnabled=false;
+		private bool tightEncodingEnabled=false;
+		private bool sizePrefixDisabled=false;
+		
+        public OpenWireFormat()
+        {
+            dataMarshallers = new BaseDataStreamMarshaller[256];
+            MarshallerFactory factory = new MarshallerFactory();
+            factory.configure(this);
+        }
+                
+        public bool StackTraceEnabled {
+            get { return stackTraceEnabled; }
+			set { stackTraceEnabled = value; }
+        }
+        public int Version {
+            get { return version; }
+			set { version = value; }
+        }
+        public bool SizePrefixDisabled {
+            get { return sizePrefixDisabled; }
+			set { sizePrefixDisabled = value; }
+        }
+        public bool TightEncodingEnabled {
+            get { return tightEncodingEnabled; }
+			set { tightEncodingEnabled = value; }
+        }
+        
+        public void addMarshaller(BaseDataStreamMarshaller marshaller)
+        {
+            byte type = marshaller.GetDataStructureType();
+            dataMarshallers[type & 0xFF] = marshaller;
+        }
+        
+        public void Marshal(Object o, BinaryWriter ds)
+        {
+            int size = 1;
+            if (o != null)
+            {
+                DataStructure c = (DataStructure) o;
+                byte type = c.GetDataStructureType();
+                BaseDataStreamMarshaller dsm = dataMarshallers[type & 0xFF];
+                if (dsm == null)
+                    throw new IOException("Unknown data type: " + type);
+
+                if(tightEncodingEnabled) {
+					
+					BooleanStream bs = new BooleanStream();
+					size += dsm.TightMarshal1(this, c, bs);
+					size += bs.MarshalledSize();
+					
+                    if( !sizePrefixDisabled ) {
+						ds.Write(size);
+					}
+					
+					ds.Write(type);
+					bs.Marshal(ds);
+					dsm.TightMarshal2(this, c, ds, bs);
+					
+				} else {
+					
+					BinaryWriter looseOut = ds;
+					MemoryStream ms = null;
+					// If we are prefixing then we need to first write it to memory,
+					// otherwise we can write direct to the stream.
+					if( !sizePrefixDisabled ) {
+						ms= new MemoryStream();
+						looseOut = new OpenWireBinaryWriter(ms);
+						looseOut.Write(size);
+					}
+					
+					looseOut.Write(type);
+					dsm.LooseMarshal(this, c, looseOut);
+					
+					if( !sizePrefixDisabled ) {
+						ms.Position=0;
+						looseOut.Write( (int)ms.Length-4 );
+						ds.Write(ms.GetBuffer(), 0, (int)ms.Length);
+					}
+				}
+            }
+            else
+            {
+                ds.Write(size);
+                ds.Write(NULL_TYPE);
+            }
+        }
+        
+        public Object Unmarshal(BinaryReader dis)
+        {
+            // lets ignore the size of the packet
+			if( !sizePrefixDisabled ) {
+				dis.ReadInt32();
+			}
+            
+            // first byte is the type of the packet
+            byte dataType = dis.ReadByte();
+            if (dataType != NULL_TYPE)
+            {
+                BaseDataStreamMarshaller dsm = dataMarshallers[dataType & 0xFF];
+                if (dsm == null)
+                    throw new IOException("Unknown data type: " + dataType);
+                //Console.WriteLine("Parsing type: " + dataType + " with: " + dsm);
+                Object data = dsm.CreateObject();
+				
+				if(tightEncodingEnabled) {
+					BooleanStream bs = new BooleanStream();
+					bs.Unmarshal(dis);
+					dsm.TightUnmarshal(this, data, dis, bs);
+					return data;
+				} else {
+					dsm.LooseUnmarshal(this, data, dis);
+					return data;
+				}
+            }
+            else
+            {
+                return null;
+            }
+        }
+        
+        public int TightMarshalNestedObject1(DataStructure o, BooleanStream bs)
+        {
+            bs.WriteBoolean(o != null);
+            if (o == null)
+                return 0;
+            
+            if (o.IsMarshallAware())
+            {
+                MarshallAware ma = (MarshallAware) o;
+                byte[] sequence = ma.GetMarshalledForm(this);
+                bs.WriteBoolean(sequence != null);
+                if (sequence != null)
+                {
+                    return 1 + sequence.Length;
+                }
+            }
+            
+            byte type = o.GetDataStructureType();
+            if (type == 0) {
+                throw new IOException("No valid data structure type for: " + o + " of type: " + o.GetType());
+            }
+            BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[type & 0xFF];
+            if (dsm == null)
+                throw new IOException("Unknown data type: " + type);
+            //Console.WriteLine("Marshalling type: " + type + " with structure: " + o);
+            return 1 + dsm.TightMarshal1(this, o, bs);
+        }
+        
+        public void TightMarshalNestedObject2(DataStructure o, BinaryWriter ds, BooleanStream bs)
+        {
+            if (!bs.ReadBoolean())
+                return ;
+            
+            byte type = o.GetDataStructureType();
+            ds.Write(type);
+            
+            if (o.IsMarshallAware() && bs.ReadBoolean())
+            {
+                MarshallAware ma = (MarshallAware) o;
+                byte[] sequence = ma.GetMarshalledForm(this);
+                ds.Write(sequence, 0, sequence.Length);
+            }
+            else
+            {
+                
+                BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[type & 0xFF];
+                if (dsm == null)
+                    throw new IOException("Unknown data type: " + type);
+                dsm.TightMarshal2(this, o, ds, bs);
+            }
+        }
+        
+        public DataStructure TightUnmarshalNestedObject(BinaryReader dis, BooleanStream bs)
+        {
+            if (bs.ReadBoolean())
+            {
+                
+                byte dataType = dis.ReadByte();
+                BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[dataType & 0xFF];
+                if (dsm == null)
+                    throw new IOException("Unknown data type: " + dataType);
+                DataStructure data = dsm.CreateObject();
+                
+                if (data.IsMarshallAware() && bs.ReadBoolean())
+                {
+                    dis.ReadInt32();
+                    dis.ReadByte();
+                    
+                    BooleanStream bs2 = new BooleanStream();
+                    bs2.Unmarshal(dis);
+                    dsm.TightUnmarshal(this, data, dis, bs2);
+                    
+                    // TODO: extract the sequence from the dis and associate it.
+                    //                MarshallAware ma = (MarshallAware)data
+                    //                ma.setCachedMarshalledForm(this, sequence);
+                }
+                else
+                {
+                    dsm.TightUnmarshal(this, data, dis, bs);
+                }
+                
+                return data;
+            }
+            else
+            {
+                return null;
+            }
+        }
+
+
+        
+        public void LooseMarshalNestedObject(DataStructure o, BinaryWriter dataOut)
+        {
+			dataOut.Write(o!=null);
+			if( o!=null ) {
+				byte type = o.GetDataStructureType();
+				dataOut.Write(type);
+                BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[type & 0xFF];
+				if( dsm == null )
+					throw new IOException("Unknown data type: "+type);
+				dsm.LooseMarshal(this, o, dataOut);
+			}
+        }
+        
+        public DataStructure LooseUnmarshalNestedObject(BinaryReader dis)
+        {
+            if (dis.ReadBoolean())
+            {
+                
+                byte dataType = dis.ReadByte();
+                BaseDataStreamMarshaller dsm = (BaseDataStreamMarshaller) dataMarshallers[dataType & 0xFF];
+                if (dsm == null)
+                    throw new IOException("Unknown data type: " + dataType);
+                DataStructure data = dsm.CreateObject();
+				dsm.LooseUnmarshal(this, data, dis);
+                return data;
+            }
+            else
+            {
+                return null;
+            }
+        }
+        
+    }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/OpenWireFormat.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/PrimitiveMap.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs Tue Mar 21 15:20:55 2006
@@ -1,64 +1,64 @@
-//
-//
-// 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 ActiveMQ.Commands;
-using System;
-using System.IO;
-
-namespace ActiveMQ.OpenWire.V1
-{
-  //
-  //  Marshalling code for Open Wire Format for DataStructureSupport
-  //
-  //
-  //  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 DataStructureSupportMarshaller : BaseDataStreamMarshaller
-  {
-
-    //
-    // 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) {
-        DataStructureSupport info = (DataStructureSupport)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);
-
-    }
-  }
-}
+//
+//
+// 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 ActiveMQ.Commands;
+using System;
+using System.IO;
+
+namespace ActiveMQ.OpenWire.V1
+{
+  //
+  //  Marshalling code for Open Wire Format for DataStructureSupport
+  //
+  //
+  //  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 DataStructureSupportMarshaller : BaseDataStreamMarshaller
+  {
+
+    //
+    // 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) {
+        DataStructureSupport info = (DataStructureSupport)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);
+
+    }
+  }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs Tue Mar 21 15:20:55 2006
@@ -1 +1,98 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* 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.
*/

//
// 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
//

using System;
using System.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;

namespace ActiveMQ.OpenWire.V1
{
  /// <summary
 >
  ///  Marshalling code for Open Wire Format for LastPartialCommand
  /// </summary>
  class LastPartialCommandMarshaller : BaseCommandMarshaller
  {


    public override DataStructure CreateObject() 
    {
        return new LastPartialCommand();
    }

    public override byte GetDataStructureType() 
    {
        return LastPartialCommand.ID_LastPartialCommand;
    }

    // 
    // 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) {
        LastPartialCommand info = (LastPartialCommand)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);

    }
    
  }
}
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* 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.
+*/
+
+//
+// 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
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for LastPartialCommand
+  /// </summary>
+  class LastPartialCommandMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new LastPartialCommand();
+    }
+
+    public override byte GetDataStructureType() 
+    {
+        return LastPartialCommand.ID_LastPartialCommand;
+    }
+
+    // 
+    // 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) {
+        LastPartialCommand info = (LastPartialCommand)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);
+
+    }
+    
+  }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MarshallerFactory.cs
------------------------------------------------------------------------------
    svn:eol-style = native

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=387665&r1=387664&r2=387665&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 Tue Mar 21 15:20:55 2006
@@ -1 +1,126 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* 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.
*/

//
// 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
//

using System;
using System.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;

namespace ActiveMQ.OpenWire.V1
{
  /// <summary
 >
  ///  Marshalling code for Open Wire Format for MessageDispatchNotification
  /// </summary>
  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 = TightU
 nmarshalLong(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, Boole
 anStream 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(wireF
 ormat, 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);

    }
    
  }
}
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* 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.
+*/
+
+//
+// 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
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for MessageDispatchNotification
+  /// </summary>
+  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);
+
+    }
+    
+  }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

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=387665&r1=387664&r2=387665&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 Tue Mar 21 15:20:55 2006
@@ -1 +1,115 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* 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.
*/

//
// 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
//

using System;
using System.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;

namespace ActiveMQ.OpenWire.V1
{
  /// <summary
 >
  ///  Marshalling code for Open Wire Format for NetworkBridgeFilter
  /// </summary>
  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 wir
 eFormat, 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);

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

    }
    
  }
}
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* 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.
+*/
+
+//
+// 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
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for NetworkBridgeFilter
+  /// </summary>
+  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);
+
+    }
+    
+  }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/NetworkBridgeFilterMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs Tue Mar 21 15:20:55 2006
@@ -1 +1,123 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* 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.
*/

//
// 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
//

using System;
using System.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;

namespace ActiveMQ.OpenWire.V1
{
  /// <summary
 >
  ///  Marshalling code for Open Wire Format for PartialCommand
  /// </summary>
  class PartialCommandMarshaller : BaseDataStreamMarshaller
  {


    public override DataStructure CreateObject() 
    {
        return new PartialCommand();
    }

    public override byte GetDataStructureType() 
    {
        return PartialCommand.ID_PartialCommand;
    }

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

        PartialCommand info = (PartialCommand)o;
        info.CommandId = dataIn.ReadInt32();
        info.Data = ReadBytes(dataIn, bs.ReadBoolean());

    }

    //
    // Write the booleans that this object uses to a BooleanStream
    //
    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
        PartialCommand info = (Par
 tialCommand)o;

        int rc = base.TightMarshal1(wireFormat, info, bs);
        bs.WriteBoolean(info.Data!=null);
        rc += info.Data==null ? 0 : info.Data.Length+4;

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

        PartialCommand info = (PartialCommand)o;
        dataOut.Write(info.CommandId);
        if(bs.ReadBoolean()) {
           dataOut.Write(info.Data.Length);
           dataOut.Write(info.Data);
        }

    }

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

        PartialCommand info = (PartialCommand)o;
        info.CommandId = dataIn.ReadI
 nt32();
        info.Data = ReadBytes(dataIn, dataIn.ReadBoolean());

    }

    // 
    // Write a object instance to data output stream
    //
    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {

        PartialCommand info = (PartialCommand)o;

        base.LooseMarshal(wireFormat, o, dataOut);
        dataOut.Write(info.CommandId);
        dataOut.Write(info.Data!=null);
        if(info.Data!=null) {
           dataOut.Write(info.Data.Length);
           dataOut.Write(info.Data);
        }

    }
    
  }
}
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* 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.
+*/
+
+//
+// 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
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for PartialCommand
+  /// </summary>
+  class PartialCommandMarshaller : BaseDataStreamMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new PartialCommand();
+    }
+
+    public override byte GetDataStructureType() 
+    {
+        return PartialCommand.ID_PartialCommand;
+    }
+
+    // 
+    // 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);
+
+        PartialCommand info = (PartialCommand)o;
+        info.CommandId = dataIn.ReadInt32();
+        info.Data = ReadBytes(dataIn, bs.ReadBoolean());
+
+    }
+
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        PartialCommand info = (PartialCommand)o;
+
+        int rc = base.TightMarshal1(wireFormat, info, bs);
+        bs.WriteBoolean(info.Data!=null);
+        rc += info.Data==null ? 0 : info.Data.Length+4;
+
+        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);
+
+        PartialCommand info = (PartialCommand)o;
+        dataOut.Write(info.CommandId);
+        if(bs.ReadBoolean()) {
+           dataOut.Write(info.Data.Length);
+           dataOut.Write(info.Data);
+        }
+
+    }
+
+    // 
+    // 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);
+
+        PartialCommand info = (PartialCommand)o;
+        info.CommandId = dataIn.ReadInt32();
+        info.Data = ReadBytes(dataIn, dataIn.ReadBoolean());
+
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+        PartialCommand info = (PartialCommand)o;
+
+        base.LooseMarshal(wireFormat, o, dataOut);
+        dataOut.Write(info.CommandId);
+        dataOut.Write(info.Data!=null);
+        if(info.Data!=null) {
+           dataOut.Write(info.Data.Length);
+           dataOut.Write(info.Data);
+        }
+
+    }
+    
+  }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

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=387665&r1=387664&r2=387665&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 Tue Mar 21 15:20:55 2006
@@ -1 +1,114 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* 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.
*/

//
// 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
//

using System;
using System.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;

namespace ActiveMQ.OpenWire.V1
{
  /// <summary
 >
  ///  Marshalling code for Open Wire Format for ReplayCommand
  /// </summary>
  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);

        ReplayCommand info = (ReplayCommand)o;
        info.FirstNakNumber = dataIn.ReadInt32();
        info.LastNakNumber = dataIn.ReadInt32();

    }

    //
    // 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 + 8;
    }

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

        ReplayCommand info = (ReplayCommand)o;
        dataOut.Write(info.FirstNakNumber);
        dataOut.Write(info.LastNakNumber);

    }

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

        ReplayCommand info = (ReplayCommand)o;
        info.FirstNakNumber = dataIn.ReadInt32();
        info.LastNakNumber = dataIn.ReadInt32();

    }

    // 
    // Write a object instance to data output stream
    //
    public override void LooseMarshal(OpenWireFormat 
 wireFormat, Object o, BinaryWriter dataOut) {

        ReplayCommand info = (ReplayCommand)o;

        base.LooseMarshal(wireFormat, o, dataOut);
        dataOut.Write(info.FirstNakNumber);
        dataOut.Write(info.LastNakNumber);

    }
    
  }
}
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* 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.
+*/
+
+//
+// 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
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for ReplayCommand
+  /// </summary>
+  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);
+
+        ReplayCommand info = (ReplayCommand)o;
+        info.FirstNakNumber = dataIn.ReadInt32();
+        info.LastNakNumber = dataIn.ReadInt32();
+
+    }
+
+    //
+    // 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 + 8;
+    }
+
+    // 
+    // 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);
+
+        ReplayCommand info = (ReplayCommand)o;
+        dataOut.Write(info.FirstNakNumber);
+        dataOut.Write(info.LastNakNumber);
+
+    }
+
+    // 
+    // 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);
+
+        ReplayCommand info = (ReplayCommand)o;
+        info.FirstNakNumber = dataIn.ReadInt32();
+        info.LastNakNumber = dataIn.ReadInt32();
+
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+        ReplayCommand info = (ReplayCommand)o;
+
+        base.LooseMarshal(wireFormat, o, dataOut);
+        dataOut.Write(info.FirstNakNumber);
+        dataOut.Write(info.LastNakNumber);
+
+    }
+    
+  }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message