You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/04/18 23:02:38 UTC
svn commit: r1469573 [1/5] - in
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp:
Commands/ OpenWire/ OpenWire/V9/
Author: tabish
Date: Thu Apr 18 21:02:36 2013
New Revision: 1469573
URL: http://svn.apache.org/r1469573
Log:
fix for: https://issues.apache.org/jira/browse/AMQNET-427
Added:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBlobMessageMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBytesMessageMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQDestinationMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMapMessageMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMessageMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQObjectMessageMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQQueueMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQStreamMessageMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempDestinationMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempQueueMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempTopicMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTextMessageMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTopicMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BaseCommandMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerIdMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ConnectionControlMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ConnectionErrorMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ConnectionIdMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ConnectionInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ConsumerControlMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ConsumerIdMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ConsumerInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ControlCommandMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/DataArrayResponseMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/DataResponseMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/DestinationInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/DiscoveryEventMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ExceptionResponseMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/FlushCommandMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/IntegerResponseMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/JournalQueueAckMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/JournalTopicAckMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/JournalTraceMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/JournalTransactionMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/KeepAliveInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/LastPartialCommandMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/LocalTransactionIdMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/MarshallerFactory.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/MessageAckMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/MessageDispatchMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/MessageDispatchNotificationMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/MessageIdMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/MessageMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/MessagePullMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/NetworkBridgeFilterMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/PartialCommandMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ProducerAckMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ProducerIdMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ProducerInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/RemoveInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/RemoveSubscriptionInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ReplayCommandMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ResponseMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/SessionIdMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/SessionInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ShutdownInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/SubscriptionInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/TransactionIdMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/TransactionInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/WireFormatInfoMarshaller.cs (with props)
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/XATransactionIdMarshaller.cs (with props)
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/OpenWireFormat.cs
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs?rev=1469573&r1=1469572&r2=1469573&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs Thu Apr 18 21:02:36 2013
@@ -42,6 +42,27 @@ namespace Apache.NMS.ActiveMQ.Commands
int messageCount;
BrokerError poisonCause;
+ public MessageAck() : base()
+ {
+ }
+
+ public MessageAck(MessageDispatch dispatch, byte ackType, int messageCount) : base()
+ {
+ this.ackType = ackType;
+ this.consumerId = dispatch.ConsumerId;
+ this.destination = dispatch.Destination;
+ this.lastMessageId = dispatch.Message.MessageId;
+ this.messageCount = messageCount;
+ }
+
+ public MessageAck(Message message, byte ackType, int messageCount) : base()
+ {
+ this.ackType = ackType;
+ this.destination = message.Destination;
+ this.lastMessageId = message.MessageId;
+ this.messageCount = messageCount;
+ }
+
///
/// <summery>
/// Get the unique identifier that this object and its own
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs?rev=1469573&r1=1469572&r2=1469573&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs Thu Apr 18 21:02:36 2013
@@ -55,7 +55,7 @@ namespace Apache.NMS.ActiveMQ.Commands
{
return GetType().Name + "[ " +
"CommandId = " + CommandId + ", " +
- "Data = " + System.Text.ASCIIEncoding.ASCII.GetString(Data) + " ]";
+ "Data = " + Data ?? System.Text.ASCIIEncoding.ASCII.GetString(Data) + " ]";
}
public int CommandId
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs?rev=1469573&r1=1469572&r2=1469573&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs Thu Apr 18 21:02:36 2013
@@ -56,8 +56,8 @@ namespace Apache.NMS.ActiveMQ.Commands
{
return GetType().Name + "[ " +
"FormatId = " + FormatId + ", " +
- "GlobalTransactionId = " + System.Text.ASCIIEncoding.ASCII.GetString(GlobalTransactionId) + ", " +
- "BranchQualifier = " + System.Text.ASCIIEncoding.ASCII.GetString(BranchQualifier) + " ]";
+ "GlobalTransactionId = " + GlobalTransactionId ?? System.Text.ASCIIEncoding.ASCII.GetString(GlobalTransactionId) + ", " +
+ "BranchQualifier = " + BranchQualifier ?? System.Text.ASCIIEncoding.ASCII.GetString(BranchQualifier) + " ]";
}
public int FormatId
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/OpenWireFormat.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/OpenWireFormat.cs?rev=1469573&r1=1469572&r2=1469573&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/OpenWireFormat.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/OpenWireFormat.cs Thu Apr 18 21:02:36 2013
@@ -59,7 +59,7 @@ namespace Apache.NMS.ActiveMQ.OpenWire
PreferredWireFormatInfo.MaxInactivityDuration = 30000;
PreferredWireFormatInfo.MaxInactivityDurationInitialDelay = 10000;
PreferredWireFormatInfo.CacheSize = 0;
- PreferredWireFormatInfo.Version = 6;
+ PreferredWireFormatInfo.Version = 9;
dataMarshallers = new BaseDataStreamMarshaller[256];
Version = 1;
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBlobMessageMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBlobMessageMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBlobMessageMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBlobMessageMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQBlobMessage
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQBlobMessage
+ /// </summary>
+ class ActiveMQBlobMessageMarshaller : ActiveMQMessageMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQBlobMessage();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQBlobMessage.ID_ACTIVEMQBLOBMESSAGE;
+ }
+
+ //
+ // 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);
+
+ ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;
+ info.RemoteBlobUrl = TightUnmarshalString(dataIn, bs);
+ info.MimeType = TightUnmarshalString(dataIn, bs);
+ info.DeletedByBroker = bs.ReadBoolean();
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+ ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+ rc += TightMarshalString1(info.RemoteBlobUrl, bs);
+ rc += TightMarshalString1(info.MimeType, bs);
+ bs.WriteBoolean(info.DeletedByBroker);
+
+ 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);
+
+ ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;
+ TightMarshalString2(info.RemoteBlobUrl, dataOut, bs);
+ TightMarshalString2(info.MimeType, dataOut, bs);
+ bs.ReadBoolean();
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;
+ info.RemoteBlobUrl = LooseUnmarshalString(dataIn);
+ info.MimeType = LooseUnmarshalString(dataIn);
+ info.DeletedByBroker = dataIn.ReadBoolean();
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.RemoteBlobUrl, dataOut);
+ LooseMarshalString(info.MimeType, dataOut);
+ dataOut.Write(info.DeletedByBroker);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBlobMessageMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBytesMessageMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBytesMessageMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBytesMessageMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBytesMessageMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQBytesMessage
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQBytesMessage
+ /// </summary>
+ class ActiveMQBytesMessageMarshaller : ActiveMQMessageMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQBytesMessage();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQBytesMessage.ID_ACTIVEMQBYTESMESSAGE;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQBytesMessageMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQDestinationMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQDestinationMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQDestinationMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQDestinationMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQDestination
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQDestination
+ /// </summary>
+ abstract class ActiveMQDestinationMarshaller : BaseDataStreamMarshaller
+ {
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+ ActiveMQDestination info = (ActiveMQDestination)o;
+ info.PhysicalName = TightUnmarshalString(dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+ ActiveMQDestination info = (ActiveMQDestination)o;
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+ rc += TightMarshalString1(info.PhysicalName, 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);
+
+ ActiveMQDestination info = (ActiveMQDestination)o;
+ TightMarshalString2(info.PhysicalName, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ActiveMQDestination info = (ActiveMQDestination)o;
+ info.PhysicalName = LooseUnmarshalString(dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ ActiveMQDestination info = (ActiveMQDestination)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.PhysicalName, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQDestinationMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMapMessageMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMapMessageMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMapMessageMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMapMessageMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQMapMessage
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQMapMessage
+ /// </summary>
+ class ActiveMQMapMessageMarshaller : ActiveMQMessageMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQMapMessage();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQMapMessage.ID_ACTIVEMQMAPMESSAGE;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMapMessageMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMessageMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMessageMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMessageMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMessageMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQMessage
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQMessage
+ /// </summary>
+ class ActiveMQMessageMarshaller : MessageMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQMessage();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQMessage.ID_ACTIVEMQMESSAGE;
+ }
+
+ //
+ // 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);
+
+ ActiveMQMessage info = (ActiveMQMessage)o;
+
+ info.BeforeUnmarshall(wireFormat);
+
+
+ info.AfterUnmarshall(wireFormat);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+ ActiveMQMessage info = (ActiveMQMessage)o;
+
+ info.BeforeMarshall(wireFormat);
+
+ int rc = base.TightMarshal1(wireFormat, o, 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);
+
+ ActiveMQMessage info = (ActiveMQMessage)o;
+
+ info.AfterMarshall(wireFormat);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ ActiveMQMessage info = (ActiveMQMessage)o;
+
+ info.BeforeUnmarshall(wireFormat);
+
+
+ info.AfterUnmarshall(wireFormat);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ ActiveMQMessage info = (ActiveMQMessage)o;
+
+ info.BeforeMarshall(wireFormat);
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+
+ info.AfterMarshall(wireFormat);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQMessageMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQObjectMessageMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQObjectMessageMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQObjectMessageMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQObjectMessageMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQObjectMessage
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQObjectMessage
+ /// </summary>
+ class ActiveMQObjectMessageMarshaller : ActiveMQMessageMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQObjectMessage();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQObjectMessage.ID_ACTIVEMQOBJECTMESSAGE;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQObjectMessageMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQQueueMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQQueueMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQQueueMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQQueueMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQQueue
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQQueue
+ /// </summary>
+ class ActiveMQQueueMarshaller : ActiveMQDestinationMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQQueue();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQQueue.ID_ACTIVEMQQUEUE;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQQueueMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQStreamMessageMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQStreamMessageMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQStreamMessageMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQStreamMessageMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQStreamMessage
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQStreamMessage
+ /// </summary>
+ class ActiveMQStreamMessageMarshaller : ActiveMQMessageMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQStreamMessage();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQStreamMessage.ID_ACTIVEMQSTREAMMESSAGE;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQStreamMessageMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempDestinationMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempDestinationMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempDestinationMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempDestinationMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQTempDestination
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQTempDestination
+ /// </summary>
+ abstract class ActiveMQTempDestinationMarshaller : ActiveMQDestinationMarshaller
+ {
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempDestinationMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempQueueMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempQueueMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempQueueMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempQueueMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQTempQueue
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQTempQueue
+ /// </summary>
+ class ActiveMQTempQueueMarshaller : ActiveMQTempDestinationMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQTempQueue();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQTempQueue.ID_ACTIVEMQTEMPQUEUE;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempQueueMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempTopicMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempTopicMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempTopicMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempTopicMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQTempTopic
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQTempTopic
+ /// </summary>
+ class ActiveMQTempTopicMarshaller : ActiveMQTempDestinationMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQTempTopic();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQTempTopic.ID_ACTIVEMQTEMPTOPIC;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTempTopicMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTextMessageMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTextMessageMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTextMessageMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTextMessageMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQTextMessage
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQTextMessage
+ /// </summary>
+ class ActiveMQTextMessageMarshaller : ActiveMQMessageMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQTextMessage();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQTextMessage.ID_ACTIVEMQTEXTMESSAGE;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTextMessageMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTopicMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTopicMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTopicMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTopicMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for ActiveMQTopic
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ActiveMQTopic
+ /// </summary>
+ class ActiveMQTopicMarshaller : ActiveMQDestinationMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ActiveMQTopic();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ActiveMQTopic.ID_ACTIVEMQTOPIC;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs)
+ {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/ActiveMQTopicMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BaseCommandMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BaseCommandMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BaseCommandMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BaseCommandMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,103 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for BaseCommand
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for BaseCommand
+ /// </summary>
+ abstract class BaseCommandMarshaller : BaseDataStreamMarshaller
+ {
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+ BaseCommand info = (BaseCommand)o;
+ info.CommandId = dataIn.ReadInt32();
+ info.ResponseRequired = bs.ReadBoolean();
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+ BaseCommand info = (BaseCommand)o;
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+ bs.WriteBoolean(info.ResponseRequired);
+
+ 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);
+
+ BaseCommand info = (BaseCommand)o;
+ dataOut.Write(info.CommandId);
+ bs.ReadBoolean();
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ BaseCommand info = (BaseCommand)o;
+ info.CommandId = dataIn.ReadInt32();
+ info.ResponseRequired = dataIn.ReadBoolean();
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ BaseCommand info = (BaseCommand)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.CommandId);
+ dataOut.Write(info.ResponseRequired);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BaseCommandMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerIdMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerIdMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerIdMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerIdMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for BrokerId
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for BrokerId
+ /// </summary>
+ class BrokerIdMarshaller : BaseDataStreamMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new BrokerId();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return BrokerId.ID_BROKERID;
+ }
+
+ //
+ // 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);
+
+ BrokerId info = (BrokerId)o;
+ info.Value = TightUnmarshalString(dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+ BrokerId info = (BrokerId)o;
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+ rc += TightMarshalString1(info.Value, 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);
+
+ BrokerId info = (BrokerId)o;
+ TightMarshalString2(info.Value, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ BrokerId info = (BrokerId)o;
+ info.Value = LooseUnmarshalString(dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ BrokerId info = (BrokerId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.Value, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerIdMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerInfoMarshaller.cs?rev=1469573&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerInfoMarshaller.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerInfoMarshaller.cs Thu Apr 18 21:02:36 2013
@@ -0,0 +1,191 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for BrokerInfo
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V9
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for BrokerInfo
+ /// </summary>
+ class BrokerInfoMarshaller : BaseCommandMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new BrokerInfo();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return BrokerInfo.ID_BROKERINFO;
+ }
+
+ //
+ // 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);
+
+ BrokerInfo info = (BrokerInfo)o;
+ info.BrokerId = (BrokerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+ info.BrokerURL = TightUnmarshalString(dataIn, bs);
+
+ if (bs.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ BrokerInfo[] value = new BrokerInfo[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (BrokerInfo) TightUnmarshalNestedObject(wireFormat,dataIn, bs);
+ }
+ info.PeerBrokerInfos = value;
+ }
+ else {
+ info.PeerBrokerInfos = null;
+ }
+ info.BrokerName = TightUnmarshalString(dataIn, bs);
+ info.SlaveBroker = bs.ReadBoolean();
+ info.MasterBroker = bs.ReadBoolean();
+ info.FaultTolerantConfiguration = bs.ReadBoolean();
+ info.DuplexConnection = bs.ReadBoolean();
+ info.NetworkConnection = bs.ReadBoolean();
+ info.ConnectionId = TightUnmarshalLong(wireFormat, dataIn, bs);
+ info.BrokerUploadUrl = TightUnmarshalString(dataIn, bs);
+ info.NetworkProperties = TightUnmarshalString(dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs)
+ {
+ BrokerInfo info = (BrokerInfo)o;
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.BrokerId, bs);
+ rc += TightMarshalString1(info.BrokerURL, bs);
+ rc += TightMarshalObjectArray1(wireFormat, info.PeerBrokerInfos, bs);
+ rc += TightMarshalString1(info.BrokerName, bs);
+ bs.WriteBoolean(info.SlaveBroker);
+ bs.WriteBoolean(info.MasterBroker);
+ bs.WriteBoolean(info.FaultTolerantConfiguration);
+ bs.WriteBoolean(info.DuplexConnection);
+ bs.WriteBoolean(info.NetworkConnection);
+ rc += TightMarshalLong1(wireFormat, info.ConnectionId, bs);
+ rc += TightMarshalString1(info.BrokerUploadUrl, bs);
+ rc += TightMarshalString1(info.NetworkProperties, 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);
+
+ BrokerInfo info = (BrokerInfo)o;
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.BrokerId, dataOut, bs);
+ TightMarshalString2(info.BrokerURL, dataOut, bs);
+ TightMarshalObjectArray2(wireFormat, info.PeerBrokerInfos, dataOut, bs);
+ TightMarshalString2(info.BrokerName, dataOut, bs);
+ bs.ReadBoolean();
+ bs.ReadBoolean();
+ bs.ReadBoolean();
+ bs.ReadBoolean();
+ bs.ReadBoolean();
+ TightMarshalLong2(wireFormat, info.ConnectionId, dataOut, bs);
+ TightMarshalString2(info.BrokerUploadUrl, dataOut, bs);
+ TightMarshalString2(info.NetworkProperties, dataOut, bs);
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ BrokerInfo info = (BrokerInfo)o;
+ info.BrokerId = (BrokerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.BrokerURL = LooseUnmarshalString(dataIn);
+
+ if (dataIn.ReadBoolean()) {
+ short size = dataIn.ReadInt16();
+ BrokerInfo[] value = new BrokerInfo[size];
+ for( int i=0; i < size; i++ ) {
+ value[i] = (BrokerInfo) LooseUnmarshalNestedObject(wireFormat,dataIn);
+ }
+ info.PeerBrokerInfos = value;
+ }
+ else {
+ info.PeerBrokerInfos = null;
+ }
+ info.BrokerName = LooseUnmarshalString(dataIn);
+ info.SlaveBroker = dataIn.ReadBoolean();
+ info.MasterBroker = dataIn.ReadBoolean();
+ info.FaultTolerantConfiguration = dataIn.ReadBoolean();
+ info.DuplexConnection = dataIn.ReadBoolean();
+ info.NetworkConnection = dataIn.ReadBoolean();
+ info.ConnectionId = LooseUnmarshalLong(wireFormat, dataIn);
+ info.BrokerUploadUrl = LooseUnmarshalString(dataIn);
+ info.NetworkProperties = LooseUnmarshalString(dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut)
+ {
+
+ BrokerInfo info = (BrokerInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.BrokerId, dataOut);
+ LooseMarshalString(info.BrokerURL, dataOut);
+ LooseMarshalObjectArray(wireFormat, info.PeerBrokerInfos, dataOut);
+ LooseMarshalString(info.BrokerName, dataOut);
+ dataOut.Write(info.SlaveBroker);
+ dataOut.Write(info.MasterBroker);
+ dataOut.Write(info.FaultTolerantConfiguration);
+ dataOut.Write(info.DuplexConnection);
+ dataOut.Write(info.NetworkConnection);
+ LooseMarshalLong(wireFormat, info.ConnectionId, dataOut);
+ LooseMarshalString(info.BrokerUploadUrl, dataOut);
+ LooseMarshalString(info.NetworkProperties, dataOut);
+ }
+ }
+}
Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V9/BrokerInfoMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native