You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/03/07 05:14:38 UTC
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...
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_*/