activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r383767 [6/10] - in /incubator/activemq/trunk: activemq-core/src/gram/java/org/apache/activemq/openwire/tool/ activemq-core/src/gram/script/ activemq-core/src/main/java/org/apache/activemq/command/ activemq-core/src/main/java/org/apache/act...
Date Tue, 07 Mar 2006 04:14:38 GMT
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -92,18 +92,18 @@
         ConsumerInfo info = (ConsumerInfo)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
-    bs.WriteBoolean(info.Browser);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
-            bs.WriteBoolean(info.DispatchAsync);
-    rc += TightMarshalString1(info.Selector, bs);
-    rc += TightMarshalString1(info.SubcriptionName, bs);
-    bs.WriteBoolean(info.NoLocal);
-    bs.WriteBoolean(info.Exclusive);
-    bs.WriteBoolean(info.Retroactive);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
+        bs.WriteBoolean(info.Browser);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        bs.WriteBoolean(info.DispatchAsync);
+        rc += TightMarshalString1(info.Selector, bs);
+        rc += TightMarshalString1(info.SubcriptionName, bs);
+        bs.WriteBoolean(info.NoLocal);
+        bs.WriteBoolean(info.Exclusive);
+        bs.WriteBoolean(info.Retroactive);
         rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.AdditionalPredicate, bs);
-    bs.WriteBoolean(info.NetworkSubscription);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.AdditionalPredicate, bs);
+        bs.WriteBoolean(info.NetworkSubscription);
 
         return rc + 9;
     }
@@ -115,21 +115,21 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         ConsumerInfo info = (ConsumerInfo)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
-    bs.ReadBoolean();
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    dataOut.Write(info.PrefetchSize);
-    dataOut.Write(info.MaximumPendingMessageLimit);
-    bs.ReadBoolean();
-    TightMarshalString2(info.Selector, dataOut, bs);
-    TightMarshalString2(info.SubcriptionName, dataOut, bs);
-    bs.ReadBoolean();
-    bs.ReadBoolean();
-    bs.ReadBoolean();
-    dataOut.Write(info.Priority);
-    TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.AdditionalPredicate, dataOut, bs);
-    bs.ReadBoolean();
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
+        bs.ReadBoolean();
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        dataOut.Write(info.PrefetchSize);
+        dataOut.Write(info.MaximumPendingMessageLimit);
+        bs.ReadBoolean();
+        TightMarshalString2(info.Selector, dataOut, bs);
+        TightMarshalString2(info.SubcriptionName, dataOut, bs);
+        bs.ReadBoolean();
+        bs.ReadBoolean();
+        bs.ReadBoolean();
+        dataOut.Write(info.Priority);
+        TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.AdditionalPredicate, dataOut, bs);
+        bs.ReadBoolean();
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -67,7 +67,7 @@
         ControlCommand info = (ControlCommand)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalString1(info.Command, bs);
+        rc += TightMarshalString1(info.Command, bs);
 
         return rc + 0;
     }
@@ -79,7 +79,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         ControlCommand info = (ControlCommand)o;
-    TightMarshalString2(info.Command, dataOut, bs);
+        TightMarshalString2(info.Command, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -78,7 +78,7 @@
         DataArrayResponse info = (DataArrayResponse)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalObjectArray1(wireFormat, info.Data, bs);
+        rc += TightMarshalObjectArray1(wireFormat, info.Data, bs);
 
         return rc + 0;
     }
@@ -90,7 +90,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         DataArrayResponse info = (DataArrayResponse)o;
-    TightMarshalObjectArray2(wireFormat, info.Data, dataOut, bs);
+        TightMarshalObjectArray2(wireFormat, info.Data, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -67,7 +67,7 @@
         DataResponse info = (DataResponse)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Data, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Data, bs);
 
         return rc + 0;
     }
@@ -79,7 +79,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         DataResponse info = (DataResponse)o;
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.Data, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.Data, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -82,10 +82,10 @@
         DestinationInfo info = (DestinationInfo)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
         rc += TightMarshalLong1(wireFormat, info.Timeout, bs);
-    rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
+        rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
 
         return rc + 1;
     }
@@ -97,11 +97,11 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         DestinationInfo info = (DestinationInfo)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    dataOut.Write(info.OperationType);
-    TightMarshalLong2(wireFormat, info.Timeout, dataOut, bs);
-    TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        dataOut.Write(info.OperationType);
+        TightMarshalLong2(wireFormat, info.Timeout, dataOut, bs);
+        TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -68,8 +68,8 @@
         DiscoveryEvent info = (DiscoveryEvent)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalString1(info.ServiceName, bs);
-    rc += TightMarshalString1(info.BrokerName, bs);
+        rc += TightMarshalString1(info.ServiceName, bs);
+        rc += TightMarshalString1(info.BrokerName, bs);
 
         return rc + 0;
     }
@@ -81,8 +81,8 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         DiscoveryEvent info = (DiscoveryEvent)o;
-    TightMarshalString2(info.ServiceName, dataOut, bs);
-    TightMarshalString2(info.BrokerName, dataOut, bs);
+        TightMarshalString2(info.ServiceName, dataOut, bs);
+        TightMarshalString2(info.BrokerName, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -67,7 +67,7 @@
         ExceptionResponse info = (ExceptionResponse)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalBrokerError1(wireFormat, info.Exception, bs);
+        rc += TightMarshalBrokerError1(wireFormat, info.Exception, bs);
 
         return rc + 0;
     }
@@ -79,7 +79,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         ExceptionResponse info = (ExceptionResponse)o;
-    TightMarshalBrokerError2(wireFormat, info.Exception, dataOut, bs);
+        TightMarshalBrokerError2(wireFormat, info.Exception, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -67,7 +67,7 @@
         IntegerResponse info = (IntegerResponse)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    
+
         return rc + 4;
     }
 
@@ -78,7 +78,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         IntegerResponse info = (IntegerResponse)o;
-    dataOut.Write(info.Result);
+        dataOut.Write(info.Result);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -68,8 +68,8 @@
         JournalQueueAck info = (JournalQueueAck)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Destination, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageAck, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageAck, bs);
 
         return rc + 0;
     }
@@ -81,8 +81,8 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         JournalQueueAck info = (JournalQueueAck)o;
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageAck, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageAck, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -72,12 +72,12 @@
         JournalTopicAck info = (JournalTopicAck)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Destination, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
-    rc += TightMarshalLong1(wireFormat, info.MessageSequenceId, bs);
-    rc += TightMarshalString1(info.SubscritionName, bs);
-    rc += TightMarshalString1(info.ClientId, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
+        rc += TightMarshalLong1(wireFormat, info.MessageSequenceId, bs);
+        rc += TightMarshalString1(info.SubscritionName, bs);
+        rc += TightMarshalString1(info.ClientId, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
 
         return rc + 0;
     }
@@ -89,12 +89,12 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         JournalTopicAck info = (JournalTopicAck)o;
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
-    TightMarshalLong2(wireFormat, info.MessageSequenceId, dataOut, bs);
-    TightMarshalString2(info.SubscritionName, dataOut, bs);
-    TightMarshalString2(info.ClientId, dataOut, bs);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.MessageSequenceId, dataOut, bs);
+        TightMarshalString2(info.SubscritionName, dataOut, bs);
+        TightMarshalString2(info.ClientId, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -67,7 +67,7 @@
         JournalTrace info = (JournalTrace)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalString1(info.Message, bs);
+        rc += TightMarshalString1(info.Message, bs);
 
         return rc + 0;
     }
@@ -79,7 +79,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         JournalTrace info = (JournalTrace)o;
-    TightMarshalString2(info.Message, dataOut, bs);
+        TightMarshalString2(info.Message, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -69,7 +69,7 @@
         JournalTransaction info = (JournalTransaction)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
         bs.WriteBoolean(info.WasPrepared);
 
         return rc + 1;
@@ -82,9 +82,9 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         JournalTransaction info = (JournalTransaction)o;
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
-    dataOut.Write(info.Type);
-    bs.ReadBoolean();
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
+        dataOut.Write(info.Type);
+        bs.ReadBoolean();
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -68,8 +68,8 @@
         LocalTransactionId info = (LocalTransactionId)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalLong1(wireFormat, info.Value, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
+        rc += TightMarshalLong1(wireFormat, info.Value, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
 
         return rc + 0;
     }
@@ -81,8 +81,8 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         LocalTransactionId info = (LocalTransactionId)o;
-    TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -73,12 +73,12 @@
         MessageAck info = (MessageAck)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
         rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.FirstMessageId, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.LastMessageId, bs);
-    
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.LastMessageId, bs);
+
         return rc + 5;
     }
 
@@ -89,13 +89,13 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         MessageAck info = (MessageAck)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
-    dataOut.Write(info.AckType);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.FirstMessageId, dataOut, bs);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.LastMessageId, dataOut, bs);
-    dataOut.Write(info.MessageCount);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
+        dataOut.Write(info.AckType);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.FirstMessageId, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.LastMessageId, dataOut, bs);
+        dataOut.Write(info.MessageCount);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -70,10 +70,10 @@
         MessageDispatch info = (MessageDispatch)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Message, bs);
-    
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Message, bs);
+
         return rc + 4;
     }
 
@@ -84,10 +84,10 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         MessageDispatch info = (MessageDispatch)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.Message, dataOut, bs);
-    dataOut.Write(info.RedeliveryCounter);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.Message, dataOut, bs);
+        dataOut.Write(info.RedeliveryCounter);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs?rev=383767&r1=383766&r2=383767&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 Mon Mar  6 20:14:27 2006
@@ -1 +1,95 @@
-//
//
// Copyright 2005-2006 The Apache Software Foundation
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//

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

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

namespace ActiveMQ.OpenWire.V1
{
  //
  //  Marshalling code for Open Wire Format for MessageDispatchNotification
  //
  //
  //  NOTE!: This file is autogenerated - do not modify!
  //        if you need to make a change, please see 
 the Groovy scripts in the
  //        activemq-core module
  //
  public class MessageDispatchNotificationMarshaller : BaseCommandMarshaller
  {


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

    public override byte GetDataStructureType() 
    {
        return MessageDispatchNotification.ID_MessageDispatchNotification;
    }

    // 
    // Un-marshal an object instance from the data input stream
    // 
    public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
    {
        base.TightUnmarshal(wireFormat, o, dataIn, bs);

        MessageDispatchNotification info = (MessageDispatchNotification)o;
        info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
        info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
        info.DeliverySequenceId = TightUnmarshalLong(wireFormat, 
 dataIn, bs);
        info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);

    }


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

        int rc = base.TightMarshal1(wireFormat, info, bs);
    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
    rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs);
    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);

        return rc + 0;
    }

    // 
    // Write a object instance to data output stream
    //
    public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
        base.TightMarshal
 2(wireFormat, o, dataOut, bs);

        MessageDispatchNotification info = (MessageDispatchNotification)o;
    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
    TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
    TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs);
    TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);

    }
  }
}
\ No newline at end of file
+//
+//
+// Copyright 2005-2006 The Apache Software Foundation
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+  //
+  //  Marshalling code for Open Wire Format for MessageDispatchNotification
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class MessageDispatchNotificationMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new MessageDispatchNotification();
+    }
+
+    public override byte GetDataStructureType() 
+    {
+        return MessageDispatchNotification.ID_MessageDispatchNotification;
+    }
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+        MessageDispatchNotification info = (MessageDispatchNotification)o;
+        info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.DeliverySequenceId = TightUnmarshalLong(wireFormat, dataIn, bs);
+        info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
+
+    }
+
+
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        MessageDispatchNotification info = (MessageDispatchNotification)o;
+
+        int rc = base.TightMarshal1(wireFormat, info, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
+
+        return rc + 0;
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+        MessageDispatchNotification info = (MessageDispatchNotification)o;
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
+
+    }
+  }
+}

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -69,9 +69,9 @@
         MessageId info = (MessageId)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
-    rc += TightMarshalLong1(wireFormat, info.ProducerSequenceId, bs);
-    rc += TightMarshalLong1(wireFormat, info.BrokerSequenceId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
+        rc += TightMarshalLong1(wireFormat, info.ProducerSequenceId, bs);
+        rc += TightMarshalLong1(wireFormat, info.BrokerSequenceId, bs);
 
         return rc + 0;
     }
@@ -83,9 +83,9 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         MessageId info = (MessageId)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
-    TightMarshalLong2(wireFormat, info.ProducerSequenceId, dataOut, bs);
-    TightMarshalLong2(wireFormat, info.BrokerSequenceId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.ProducerSequenceId, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.BrokerSequenceId, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MessageMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -91,30 +91,30 @@
         Message info = (Message)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalDestination, bs);
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalTransactionId, bs);
-    rc += TightMarshalString1(info.GroupID, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalDestination, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalTransactionId, bs);
+        rc += TightMarshalString1(info.GroupID, bs);
         rc += TightMarshalString1(info.CorrelationId, bs);
-    bs.WriteBoolean(info.Persistent);
-    rc += TightMarshalLong1(wireFormat, info.Expiration, bs);
+        bs.WriteBoolean(info.Persistent);
+        rc += TightMarshalLong1(wireFormat, info.Expiration, bs);
         rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.ReplyTo, bs);
-    rc += TightMarshalLong1(wireFormat, info.Timestamp, bs);
-    rc += TightMarshalString1(info.Type, bs);
-    bs.WriteBoolean(info.Content!=null);
+        rc += TightMarshalLong1(wireFormat, info.Timestamp, bs);
+        rc += TightMarshalString1(info.Type, bs);
+        bs.WriteBoolean(info.Content!=null);
         rc += info.Content==null ? 0 : info.Content.Length+4;
-    bs.WriteBoolean(info.MarshalledProperties!=null);
+        bs.WriteBoolean(info.MarshalledProperties!=null);
         rc += info.MarshalledProperties==null ? 0 : info.MarshalledProperties.Length+4;
-    rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.DataStructure, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TargetConsumerId, bs);
-    bs.WriteBoolean(info.Compressed);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.DataStructure, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TargetConsumerId, bs);
+        bs.WriteBoolean(info.Compressed);
         rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
-    rc += TightMarshalLong1(wireFormat, info.Arrival, bs);
-    rc += TightMarshalString1(info.UserID, bs);
-    bs.WriteBoolean(info.RecievedByDFBridge);
+        rc += TightMarshalLong1(wireFormat, info.Arrival, bs);
+        rc += TightMarshalString1(info.UserID, bs);
+        bs.WriteBoolean(info.RecievedByDFBridge);
 
         return rc + 9;
     }
@@ -126,37 +126,37 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         Message info = (Message)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalDestination, dataOut, bs);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut, bs);
-    TightMarshalString2(info.GroupID, dataOut, bs);
-    dataOut.Write(info.GroupSequence);
-    TightMarshalString2(info.CorrelationId, dataOut, bs);
-    bs.ReadBoolean();
-    TightMarshalLong2(wireFormat, info.Expiration, dataOut, bs);
-    dataOut.Write(info.Priority);
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.ReplyTo, dataOut, bs);
-    TightMarshalLong2(wireFormat, info.Timestamp, dataOut, bs);
-    TightMarshalString2(info.Type, dataOut, bs);
-    if(bs.ReadBoolean()) {
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalDestination, dataOut, bs);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut, bs);
+        TightMarshalString2(info.GroupID, dataOut, bs);
+        dataOut.Write(info.GroupSequence);
+        TightMarshalString2(info.CorrelationId, dataOut, bs);
+        bs.ReadBoolean();
+        TightMarshalLong2(wireFormat, info.Expiration, dataOut, bs);
+        dataOut.Write(info.Priority);
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.ReplyTo, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.Timestamp, dataOut, bs);
+        TightMarshalString2(info.Type, dataOut, bs);
+        if(bs.ReadBoolean()) {
            dataOut.Write(info.Content.Length);
            dataOut.Write(info.Content);
         }
-    if(bs.ReadBoolean()) {
+        if(bs.ReadBoolean()) {
            dataOut.Write(info.MarshalledProperties.Length);
            dataOut.Write(info.MarshalledProperties);
         }
-    TightMarshalNestedObject2(wireFormat, (DataStructure)info.DataStructure, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.TargetConsumerId, dataOut, bs);
-    bs.ReadBoolean();
-    dataOut.Write(info.RedeliveryCounter);
-    TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
-    TightMarshalLong2(wireFormat, info.Arrival, dataOut, bs);
-    TightMarshalString2(info.UserID, dataOut, bs);
-    bs.ReadBoolean();
+        TightMarshalNestedObject2(wireFormat, (DataStructure)info.DataStructure, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.TargetConsumerId, dataOut, bs);
+        bs.ReadBoolean();
+        dataOut.Write(info.RedeliveryCounter);
+        TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.Arrival, dataOut, bs);
+        TightMarshalString2(info.UserID, dataOut, bs);
+        bs.ReadBoolean();
 
     }
   }

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=383767&r1=383766&r2=383767&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 Mon Mar  6 20:14:27 2006
@@ -1 +1,88 @@
-//
//
// Copyright 2005-2006 The Apache Software Foundation
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//

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

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

namespace ActiveMQ.OpenWire.V1
{
  //
  //  Marshalling code for Open Wire Format for NetworkBridgeFilter
  //
  //
  //  NOTE!: This file is autogenerated - do not modify!
  //        if you need to make a change, please see the Groo
 vy scripts in the
  //        activemq-core module
  //
  public class NetworkBridgeFilterMarshaller : BaseDataStreamMarshaller
  {


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

    public override byte GetDataStructureType() 
    {
        return NetworkBridgeFilter.ID_NetworkBridgeFilter;
    }

    // 
    // Un-marshal an object instance from the data input stream
    // 
    public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
    {
        base.TightUnmarshal(wireFormat, o, dataIn, bs);

        NetworkBridgeFilter info = (NetworkBridgeFilter)o;
        info.NetworkTTL = dataIn.ReadInt32();
        info.NetworkBrokerId = (BrokerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);

    }


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

        int rc = base.TightMarshal1(wireFormat, info, bs);
        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.NetworkBrokerId, bs);

        return rc + 4;
    }

    // 
    // Write a object instance to data output stream
    //
    public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
        base.TightMarshal2(wireFormat, o, dataOut, bs);

        NetworkBridgeFilter info = (NetworkBridgeFilter)o;
    dataOut.Write(info.NetworkTTL);
    TightMarshalCachedObject2(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut, bs);

    }
  }
}
\ No newline at end of file
+//
+//
+// Copyright 2005-2006 The Apache Software Foundation
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+  //
+  //  Marshalling code for Open Wire Format for NetworkBridgeFilter
+  //
+  //
+  //  NOTE!: This file is autogenerated - do not modify!
+  //        if you need to make a change, please see the Groovy scripts in the
+  //        activemq-core module
+  //
+  public class NetworkBridgeFilterMarshaller : BaseDataStreamMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new NetworkBridgeFilter();
+    }
+
+    public override byte GetDataStructureType() 
+    {
+        return NetworkBridgeFilter.ID_NetworkBridgeFilter;
+    }
+
+    // 
+    // Un-marshal an object instance from the data input stream
+    // 
+    public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
+    {
+        base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+        NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+        info.NetworkTTL = dataIn.ReadInt32();
+        info.NetworkBrokerId = (BrokerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+
+    }
+
+
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+
+        int rc = base.TightMarshal1(wireFormat, info, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.NetworkBrokerId, bs);
+
+        return rc + 4;
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+        base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+        NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+        dataOut.Write(info.NetworkTTL);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut, bs);
+
+    }
+  }
+}

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -69,9 +69,9 @@
         ProducerId info = (ProducerId)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalString1(info.ConnectionId, bs);
-    rc += TightMarshalLong1(wireFormat, info.Value, bs);
-    rc += TightMarshalLong1(wireFormat, info.SessionId, bs);
+        rc += TightMarshalString1(info.ConnectionId, bs);
+        rc += TightMarshalLong1(wireFormat, info.Value, bs);
+        rc += TightMarshalLong1(wireFormat, info.SessionId, bs);
 
         return rc + 0;
     }
@@ -83,9 +83,9 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         ProducerId info = (ProducerId)o;
-    TightMarshalString2(info.ConnectionId, dataOut, bs);
-    TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
-    TightMarshalLong2(wireFormat, info.SessionId, dataOut, bs);
+        TightMarshalString2(info.ConnectionId, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.SessionId, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -80,9 +80,9 @@
         ProducerInfo info = (ProducerInfo)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
-    rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
 
         return rc + 0;
     }
@@ -94,9 +94,9 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         ProducerInfo info = (ProducerInfo)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -67,7 +67,7 @@
         RemoveInfo info = (RemoveInfo)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ObjectId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ObjectId, bs);
 
         return rc + 0;
     }
@@ -79,7 +79,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         RemoveInfo info = (RemoveInfo)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ObjectId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ObjectId, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -69,9 +69,9 @@
         RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
-    rc += TightMarshalString1(info.SubcriptionName, bs);
-    rc += TightMarshalString1(info.ClientId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
+        rc += TightMarshalString1(info.SubcriptionName, bs);
+        rc += TightMarshalString1(info.ClientId, bs);
 
         return rc + 0;
     }
@@ -83,9 +83,9 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
-    TightMarshalString2(info.SubcriptionName, dataOut, bs);
-    TightMarshalString2(info.ClientId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
+        TightMarshalString2(info.SubcriptionName, dataOut, bs);
+        TightMarshalString2(info.ClientId, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -67,7 +67,7 @@
         Response info = (Response)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    
+
         return rc + 2;
     }
 
@@ -78,7 +78,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         Response info = (Response)o;
-    dataOut.Write(info.CorrelationId);
+        dataOut.Write(info.CorrelationId);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -68,8 +68,8 @@
         SessionId info = (SessionId)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalString1(info.ConnectionId, bs);
-    rc += TightMarshalLong1(wireFormat, info.Value, bs);
+        rc += TightMarshalString1(info.ConnectionId, bs);
+        rc += TightMarshalLong1(wireFormat, info.Value, bs);
 
         return rc + 0;
     }
@@ -81,8 +81,8 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         SessionId info = (SessionId)o;
-    TightMarshalString2(info.ConnectionId, dataOut, bs);
-    TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
+        TightMarshalString2(info.ConnectionId, dataOut, bs);
+        TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -67,7 +67,7 @@
         SessionInfo info = (SessionInfo)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.SessionId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.SessionId, bs);
 
         return rc + 0;
     }
@@ -79,7 +79,7 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         SessionInfo info = (SessionInfo)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.SessionId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.SessionId, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -70,10 +70,10 @@
         SubscriptionInfo info = (SubscriptionInfo)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalString1(info.ClientId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
-    rc += TightMarshalString1(info.Selector, bs);
-    rc += TightMarshalString1(info.SubcriptionName, bs);
+        rc += TightMarshalString1(info.ClientId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalString1(info.Selector, bs);
+        rc += TightMarshalString1(info.SubcriptionName, bs);
 
         return rc + 0;
     }
@@ -85,10 +85,10 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         SubscriptionInfo info = (SubscriptionInfo)o;
-    TightMarshalString2(info.ClientId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
-    TightMarshalString2(info.Selector, dataOut, bs);
-    TightMarshalString2(info.SubcriptionName, dataOut, bs);
+        TightMarshalString2(info.ClientId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalString2(info.Selector, dataOut, bs);
+        TightMarshalString2(info.SubcriptionName, dataOut, bs);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -69,9 +69,9 @@
         TransactionInfo info = (TransactionInfo)o;
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
-    rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
-    
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
+
         return rc + 1;
     }
 
@@ -82,9 +82,9 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         TransactionInfo info = (TransactionInfo)o;
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
-    TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
-    dataOut.Write(info.Type);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
+        dataOut.Write(info.Type);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -55,10 +55,15 @@
         base.TightUnmarshal(wireFormat, o, dataIn, bs);
 
         WireFormatInfo info = (WireFormatInfo)o;
+
+        info.BeforeUnmarshall(wireFormat);
+        
         info.Magic = ReadBytes(dataIn, 8);
         info.Version = dataIn.ReadInt32();
         info.MarshalledProperties = ReadBytes(dataIn, bs.ReadBoolean());
 
+        info.AfterUnmarshall(wireFormat);
+
     }
 
 
@@ -68,8 +73,10 @@
     public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
         WireFormatInfo info = (WireFormatInfo)o;
 
+        info.BeforeMarshall(wireFormat);
+
         int rc = base.TightMarshal1(wireFormat, info, bs);
-            bs.WriteBoolean(info.MarshalledProperties!=null);
+        bs.WriteBoolean(info.MarshalledProperties!=null);
         rc += info.MarshalledProperties==null ? 0 : info.MarshalledProperties.Length+4;
 
         return rc + 12;
@@ -82,12 +89,14 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         WireFormatInfo info = (WireFormatInfo)o;
-    dataOut.Write(info.Magic, 0, 8);
-    dataOut.Write(info.Version);
-    if(bs.ReadBoolean()) {
+        dataOut.Write(info.Magic, 0, 8);
+        dataOut.Write(info.Version);
+        if(bs.ReadBoolean()) {
            dataOut.Write(info.MarshalledProperties.Length);
            dataOut.Write(info.MarshalledProperties);
         }
+
+        info.AfterMarshall(wireFormat);
 
     }
   }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs Mon Mar  6 20:14:27 2006
@@ -71,7 +71,7 @@
         int rc = base.TightMarshal1(wireFormat, info, bs);
         bs.WriteBoolean(info.GlobalTransactionId!=null);
         rc += info.GlobalTransactionId==null ? 0 : info.GlobalTransactionId.Length+4;
-    bs.WriteBoolean(info.BranchQualifier!=null);
+        bs.WriteBoolean(info.BranchQualifier!=null);
         rc += info.BranchQualifier==null ? 0 : info.BranchQualifier.Length+4;
 
         return rc + 4;
@@ -84,12 +84,12 @@
         base.TightMarshal2(wireFormat, o, dataOut, bs);
 
         XATransactionId info = (XATransactionId)o;
-    dataOut.Write(info.FormatId);
-    if(bs.ReadBoolean()) {
+        dataOut.Write(info.FormatId);
+        if(bs.ReadBoolean()) {
            dataOut.Write(info.GlobalTransactionId.Length);
            dataOut.Write(info.GlobalTransactionId);
         }
-    if(bs.ReadBoolean()) {
+        if(bs.ReadBoolean()) {
            dataOut.Write(info.BranchQualifier.Length);
            dataOut.Write(info.BranchQualifier);
         }

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/CommonAssemblyInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/CommonAssemblyInfo.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/CommonAssemblyInfo.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/CommonAssemblyInfo.cs Mon Mar  6 20:14:27 2006
@@ -1,27 +1,27 @@
-using System;
-using System.Reflection;
-using System.Runtime.InteropServices;
-
-// ------------------------------------------------------------------------------
-//  <autogenerated>
-//      This code was generated by a tool.
-//      Mono Runtime Version: 1.1.4322.2032
-// 
-//      Changes to this file may cause incorrect behavior and will be lost if 
-//      the code is regenerated.
-//  </autogenerated>
-// ------------------------------------------------------------------------------
-
-[assembly: ComVisibleAttribute(false)]
-[assembly: CLSCompliantAttribute(false)]
-[assembly: AssemblyTitleAttribute("ActiveMQ .NET")]
-[assembly: AssemblyDescriptionAttribute("A .NET Library for talking to ActiveMQ")]
-[assembly: AssemblyConfigurationAttribute("SNAPSHOT")]
-[assembly: AssemblyCompanyAttribute("http://activemq.org/")]
-[assembly: AssemblyProductAttribute("ActiveMQ")]
-[assembly: AssemblyCopyrightAttribute("Copyright (C) 2005-2006 Apache Software Foundation")]
-[assembly: AssemblyTrademarkAttribute("")]
-[assembly: AssemblyCultureAttribute("")]
-[assembly: AssemblyVersionAttribute("4.0.2256.0")]
-[assembly: AssemblyInformationalVersionAttribute("4.0")]
-
+using System;
+using System.Reflection;
+using System.Runtime.InteropServices;
+
+//------------------------------------------------------------------------------
+// <autogenerated>
+//     This code was generated by a tool.
+//     Runtime Version: 1.1.4322.2032
+//
+//     Changes to this file may cause incorrect behavior and will be lost if 
+//     the code is regenerated.
+// </autogenerated>
+//------------------------------------------------------------------------------
+
+[assembly: ComVisibleAttribute(false)]
+[assembly: CLSCompliantAttribute(false)]
+[assembly: AssemblyTitleAttribute("ActiveMQ .NET")]
+[assembly: AssemblyDescriptionAttribute("A .NET Library for talking to ActiveMQ")]
+[assembly: AssemblyConfigurationAttribute("SNAPSHOT")]
+[assembly: AssemblyCompanyAttribute("http://activemq.org/")]
+[assembly: AssemblyProductAttribute("ActiveMQ")]
+[assembly: AssemblyCopyrightAttribute("Copyright (C) 2005-2006 Apache Software Foundation")]
+[assembly: AssemblyTrademarkAttribute("")]
+[assembly: AssemblyCultureAttribute("")]
+[assembly: AssemblyVersionAttribute("4.0.2256.0")]
+[assembly: AssemblyInformationalVersionAttribute("4.0")]
+

Modified: incubator/activemq/trunk/activemq-dotnet/src/test/csharp/CommonAssemblyInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/test/csharp/CommonAssemblyInfo.cs?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/test/csharp/CommonAssemblyInfo.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/test/csharp/CommonAssemblyInfo.cs Mon Mar  6 20:14:27 2006
@@ -1,27 +1,27 @@
-using System;
-using System.Reflection;
-using System.Runtime.InteropServices;
-
-// ------------------------------------------------------------------------------
-//  <autogenerated>
-//      This code was generated by a tool.
-//      Mono Runtime Version: 1.1.4322.2032
-// 
-//      Changes to this file may cause incorrect behavior and will be lost if 
-//      the code is regenerated.
-//  </autogenerated>
-// ------------------------------------------------------------------------------
-
-[assembly: ComVisibleAttribute(false)]
-[assembly: CLSCompliantAttribute(false)]
-[assembly: AssemblyTitleAttribute("ActiveMQ .NET Test")]
-[assembly: AssemblyDescriptionAttribute("A .NET Library for testing the ActiveMQ .NET Library")]
-[assembly: AssemblyConfigurationAttribute("SNAPSHOT")]
-[assembly: AssemblyCompanyAttribute("http://activemq.org/")]
-[assembly: AssemblyProductAttribute("ActiveMQ")]
-[assembly: AssemblyCopyrightAttribute("Copyright (C) 2005-2006 Apache Software Foundation")]
-[assembly: AssemblyTrademarkAttribute("")]
-[assembly: AssemblyCultureAttribute("")]
-[assembly: AssemblyVersionAttribute("4.0.2256.0")]
-[assembly: AssemblyInformationalVersionAttribute("4.0")]
-
+using System;
+using System.Reflection;
+using System.Runtime.InteropServices;
+
+//------------------------------------------------------------------------------
+// <autogenerated>
+//     This code was generated by a tool.
+//     Runtime Version: 1.1.4322.2032
+//
+//     Changes to this file may cause incorrect behavior and will be lost if 
+//     the code is regenerated.
+// </autogenerated>
+//------------------------------------------------------------------------------
+
+[assembly: ComVisibleAttribute(false)]
+[assembly: CLSCompliantAttribute(false)]
+[assembly: AssemblyTitleAttribute("ActiveMQ .NET Test")]
+[assembly: AssemblyDescriptionAttribute("A .NET Library for testing the ActiveMQ .NET Library")]
+[assembly: AssemblyConfigurationAttribute("SNAPSHOT")]
+[assembly: AssemblyCompanyAttribute("http://activemq.org/")]
+[assembly: AssemblyProductAttribute("ActiveMQ")]
+[assembly: AssemblyCopyrightAttribute("Copyright (C) 2005-2006 Apache Software Foundation")]
+[assembly: AssemblyTrademarkAttribute("")]
+[assembly: AssemblyCultureAttribute("")]
+[assembly: AssemblyVersionAttribute("4.0.2256.0")]
+[assembly: AssemblyInformationalVersionAttribute("4.0")]
+

Modified: incubator/activemq/trunk/assembly/pom.xml
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/pom.xml?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/assembly/pom.xml (original)
+++ incubator/activemq/trunk/assembly/pom.xml Mon Mar  6 20:14:27 2006
@@ -24,7 +24,7 @@
   </parent>
 
   <artifactId>activemq-assembly</artifactId>
-  <packaging>pom</packaging>
+  <packaging>jar</packaging>
   <name>ActiveMQ :: Assembly</name>
   <description>Puts together the ActiveMQ distribution</description>
   

Modified: incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java (original)
+++ incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java Mon Mar  6 20:14:27 2006
@@ -74,8 +74,7 @@
             tool.receiveTimeOut = Long.parseLong(args[8]);
         }
         
-        
-        tool.run();
+		tool.run();
     }
 
     public void run() {

Modified: incubator/activemq/trunk/assembly/src/test/resources/log4j.properties
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/test/resources/log4j.properties?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/assembly/src/test/resources/log4j.properties (original)
+++ incubator/activemq/trunk/assembly/src/test/resources/log4j.properties Mon Mar  6 20:14:27 2006
@@ -1,10 +1,7 @@
 #
 # The logging properties used during tests..
 #
-log4j.rootLogger=INFO, out
-
-log4j.logger.org.apache.activemq.spring=WARN
-log4j.logger.org.apache.activemq=INFO
+log4j.rootLogger=INFO, stdout
 
 # CONSOLE appender not used by default
 log4j.appender.stdout=org.apache.log4j.ConsoleAppender

Modified: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp Mon Mar  6 20:14:27 2006
@@ -1 +1,81 @@
-/*
* 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.
*/
#ifndef ConnectionError_hpp_
#define ConnectionError_hpp_

#include <string>
#include "command/BaseCommand.hpp"
    
#include "BrokerError.hpp"
#include "command/ConnectionId.hpp"

#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace command
      {
        using na
 mespace ifr;
        using namespace std;
        using namespace apache::activemq::client;

/*
 *
 *  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
 *
 */
class ConnectionError : public BaseCommand
{
private:
    p<BrokerError> exception ;
    p<ConnectionId> connectionId ;

public:
    const static int TYPE = 16;

public:
    ConnectionError() ;
    virtual ~ConnectionError() ;

    virtual int getCommandType() ;

    virtual p<BrokerError> getException() ;
    virtual void setException(p<BrokerError> exception) ;

    virtual p<ConnectionId> getConnectionId() ;
    virtual void setConnectionId(p<ConnectionId> connectionId) ;


} ;

/* namespace */
      }
    }
  }
}

#endif /*ConnectionError_hpp_*/
\ 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.
+*/
+#ifndef ConnectionError_hpp_
+#define ConnectionError_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+    
+#include "BrokerError.hpp"
+#include "command/ConnectionId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  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
+ *
+ */
+class ConnectionError : public BaseCommand
+{
+private:
+    p<BrokerError> exception ;
+    p<ConnectionId> connectionId ;
+
+public:
+    const static int TYPE = 16;
+
+public:
+    ConnectionError() ;
+    virtual ~ConnectionError() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<BrokerError> getException() ;
+    virtual void setException(p<BrokerError> exception) ;
+
+    virtual p<ConnectionId> getConnectionId() ;
+    virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ConnectionError_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp Mon Mar  6 20:14:27 2006
@@ -1 +1,75 @@
-/*
* 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.
*/
#ifndef ControlCommand_hpp_
#define ControlCommand_hpp_

#include <string>
#include "command/BaseCommand.hpp"
    

#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace command
      {
        using namespace ifr;
        using namespace std;
        using namespace
  apache::activemq::client;

/*
 *
 *  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
 *
 */
class ControlCommand : public BaseCommand
{
private:
    p<string> command ;

public:
    const static int TYPE = 14;

public:
    ControlCommand() ;
    virtual ~ControlCommand() ;

    virtual int getCommandType() ;

    virtual p<string> getCommand() ;
    virtual void setCommand(p<string> command) ;


} ;

/* namespace */
      }
    }
  }
}

#endif /*ControlCommand_hpp_*/
\ 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.
+*/
+#ifndef ControlCommand_hpp_
+#define ControlCommand_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+    
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  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
+ *
+ */
+class ControlCommand : public BaseCommand
+{
+private:
+    p<string> command ;
+
+public:
+    const static int TYPE = 14;
+
+public:
+    ControlCommand() ;
+    virtual ~ControlCommand() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<string> getCommand() ;
+    virtual void setCommand(p<string> command) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ControlCommand_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp?rev=383767&r1=383766&r2=383767&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp Mon Mar  6 20:14:27 2006
@@ -1 +1,76 @@
-/*
* 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.
*/
#ifndef DataArrayResponse_hpp_
#define DataArrayResponse_hpp_

#include <string>
#include "command/Response.hpp"
    
#include "command/IDataStructure.hpp"

#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace command
      {
        using namespace ifr;
        usi
 ng namespace std;
        using namespace apache::activemq::client;

/*
 *
 *  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
 *
 */
class DataArrayResponse : public Response
{
private:
    ap<IDataStructure> data ;

public:
    const static int TYPE = 33;

public:
    DataArrayResponse() ;
    virtual ~DataArrayResponse() ;

    virtual int getCommandType() ;

    virtual ap<IDataStructure> getData() ;
    virtual void setData(ap<IDataStructure> data) ;


} ;

/* namespace */
      }
    }
  }
}

#endif /*DataArrayResponse_hpp_*/
\ 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.
+*/
+#ifndef DataArrayResponse_hpp_
+#define DataArrayResponse_hpp_
+
+#include <string>
+#include "command/Response.hpp"
+    
+#include "command/IDataStructure.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  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
+ *
+ */
+class DataArrayResponse : public Response
+{
+private:
+    ap<IDataStructure> data ;
+
+public:
+    const static int TYPE = 33;
+
+public:
+    DataArrayResponse() ;
+    virtual ~DataArrayResponse() ;
+
+    virtual int getCommandType() ;
+
+    virtual ap<IDataStructure> getData() ;
+    virtual void setData(ap<IDataStructure> data) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*DataArrayResponse_hpp_*/



Mime
View raw message