Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Get it to compile after refactor 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383068 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-03-04 08:14:24 +00:00
parent 42ac3f1afc
commit aae59ee589
54 changed files with 461 additions and 513 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQBytesMessage // Marshalling code for Open Wire Format for ActiveMQBytesMessage

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQDestination // Marshalling code for Open Wire Format for ActiveMQDestination

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQMapMessage // Marshalling code for Open Wire Format for ActiveMQMapMessage

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQMessage // Marshalling code for Open Wire Format for ActiveMQMessage

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQObjectMessage // Marshalling code for Open Wire Format for ActiveMQObjectMessage

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQQueue // Marshalling code for Open Wire Format for ActiveMQQueue

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQStreamMessage // Marshalling code for Open Wire Format for ActiveMQStreamMessage

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQTempDestination // Marshalling code for Open Wire Format for ActiveMQTempDestination

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQTempQueue // Marshalling code for Open Wire Format for ActiveMQTempQueue

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQTempTopic // Marshalling code for Open Wire Format for ActiveMQTempTopic

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQTextMessage // Marshalling code for Open Wire Format for ActiveMQTextMessage

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ActiveMQTopic // Marshalling code for Open Wire Format for ActiveMQTopic

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for BaseCommand // Marshalling code for Open Wire Format for BaseCommand

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for BrokerId // Marshalling code for Open Wire Format for BrokerId

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for BrokerInfo // Marshalling code for Open Wire Format for BrokerInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ConnectionError // Marshalling code for Open Wire Format for ConnectionError

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ConnectionId // Marshalling code for Open Wire Format for ConnectionId

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ConnectionInfo // Marshalling code for Open Wire Format for ConnectionInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ConsumerId // Marshalling code for Open Wire Format for ConsumerId

15
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ConsumerInfo // Marshalling code for Open Wire Format for ConsumerInfo
@ -60,6 +59,7 @@ namespace OpenWire.Client.IO
info.Browser = bs.ReadBoolean(); info.Browser = bs.ReadBoolean();
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.PrefetchSize = BaseDataStreamMarshaller.ReadInt(dataIn); info.PrefetchSize = BaseDataStreamMarshaller.ReadInt(dataIn);
info.MaximumPendingMessageLimit = BaseDataStreamMarshaller.ReadInt(dataIn);
info.DispatchAsync = bs.ReadBoolean(); info.DispatchAsync = bs.ReadBoolean();
info.Selector = TightUnmarshalString(dataIn, bs); info.Selector = TightUnmarshalString(dataIn, bs);
info.SubcriptionName = TightUnmarshalString(dataIn, bs); info.SubcriptionName = TightUnmarshalString(dataIn, bs);
@ -94,7 +94,7 @@ namespace OpenWire.Client.IO
rc += TightMarshalCachedObject1(wireFormat, info.ConsumerId, bs); rc += TightMarshalCachedObject1(wireFormat, info.ConsumerId, bs);
bs.WriteBoolean(info.Browser); bs.WriteBoolean(info.Browser);
rc += TightMarshalCachedObject1(wireFormat, info.Destination, bs); rc += TightMarshalCachedObject1(wireFormat, info.Destination, bs);
bs.WriteBoolean(info.DispatchAsync); bs.WriteBoolean(info.DispatchAsync);
rc += TightMarshalString1(info.Selector, bs); rc += TightMarshalString1(info.Selector, bs);
rc += TightMarshalString1(info.SubcriptionName, bs); rc += TightMarshalString1(info.SubcriptionName, bs);
bs.WriteBoolean(info.NoLocal); bs.WriteBoolean(info.NoLocal);
@ -103,7 +103,7 @@ namespace OpenWire.Client.IO
rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs); rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
bs.WriteBoolean(info.NetworkSubscription); bs.WriteBoolean(info.NetworkSubscription);
return rc + 5; return rc + 9;
} }
// //
@ -117,6 +117,7 @@ namespace OpenWire.Client.IO
bs.ReadBoolean(); bs.ReadBoolean();
TightMarshalCachedObject2(wireFormat, info.Destination, dataOut, bs); TightMarshalCachedObject2(wireFormat, info.Destination, dataOut, bs);
BaseDataStreamMarshaller.WriteInt(info.PrefetchSize, dataOut); BaseDataStreamMarshaller.WriteInt(info.PrefetchSize, dataOut);
BaseDataStreamMarshaller.WriteInt(info.MaximumPendingMessageLimit, dataOut);
bs.ReadBoolean(); bs.ReadBoolean();
TightMarshalString2(info.Selector, dataOut, bs); TightMarshalString2(info.Selector, dataOut, bs);
TightMarshalString2(info.SubcriptionName, dataOut, bs); TightMarshalString2(info.SubcriptionName, dataOut, bs);

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ControlCommand // Marshalling code for Open Wire Format for ControlCommand

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for DataArrayResponse // Marshalling code for Open Wire Format for DataArrayResponse

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for DataResponse // Marshalling code for Open Wire Format for DataResponse

137
openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs
View File

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

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for DestinationInfo // Marshalling code for Open Wire Format for DestinationInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for DiscoveryEvent // Marshalling code for Open Wire Format for DiscoveryEvent

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ExceptionResponse // Marshalling code for Open Wire Format for ExceptionResponse

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for FlushCommand // Marshalling code for Open Wire Format for FlushCommand

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for IntegerResponse // Marshalling code for Open Wire Format for IntegerResponse

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for JournalQueueAck // Marshalling code for Open Wire Format for JournalQueueAck

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for JournalTopicAck // Marshalling code for Open Wire Format for JournalTopicAck

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for JournalTrace // Marshalling code for Open Wire Format for JournalTrace

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for JournalTransaction // Marshalling code for Open Wire Format for JournalTransaction

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for KeepAliveInfo // Marshalling code for Open Wire Format for KeepAliveInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for LocalTransactionId // Marshalling code for Open Wire Format for LocalTransactionId

181
openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs
View File

@ -1,91 +1,90 @@
// //
// //
// Copyright 2005-2006 The Apache Software Foundation // Copyright 2005-2006 The Apache Software Foundation
// //
// Licensed under the Apache License, Version 2.0 (the "License"); // Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License. // you may not use this file except in compliance with the License.
// You may obtain a copy of the License at // You may obtain a copy of the License at
// //
// http://www.apache.org/licenses/LICENSE-2.0 // http://www.apache.org/licenses/LICENSE-2.0
// //
// Unless required by applicable law or agreed to in writing, software // Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS, // distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and // See the License for the specific language governing permissions and
// limitations under the License. // limitations under the License.
// //
// Marshalling code for Open Wire Format for ExceptionResponse // Marshalling code for Open Wire Format for ExceptionResponse
// //
// //
// NOTE!: This file is autogenerated - do not modify! // NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the // if you need to make a change, please see the Groovy scripts in the
// activemq-openwire module // activemq-openwire module
// //
using System; using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace ActiveMQ.OpenWire.V1
namespace OpenWire.Client.IO {
{ public class MarshallerFactory
public class MarshallerFactory {
{ public void configure(OpenWireFormat format)
public void configure(OpenWireFormat format) {
{
format.addMarshaller(new MessageIdMarshaller());
format.addMarshaller(new MessageIdMarshaller()); format.addMarshaller(new BrokerInfoMarshaller());
format.addMarshaller(new BrokerInfoMarshaller()); format.addMarshaller(new ActiveMQTempQueueMarshaller());
format.addMarshaller(new ActiveMQTempQueueMarshaller()); format.addMarshaller(new LocalTransactionIdMarshaller());
format.addMarshaller(new LocalTransactionIdMarshaller()); format.addMarshaller(new RemoveSubscriptionInfoMarshaller());
format.addMarshaller(new RemoveSubscriptionInfoMarshaller()); format.addMarshaller(new IntegerResponseMarshaller());
format.addMarshaller(new IntegerResponseMarshaller()); format.addMarshaller(new ActiveMQQueueMarshaller());
format.addMarshaller(new ActiveMQQueueMarshaller()); format.addMarshaller(new DestinationInfoMarshaller());
format.addMarshaller(new DestinationInfoMarshaller()); format.addMarshaller(new ActiveMQBytesMessageMarshaller());
format.addMarshaller(new ActiveMQBytesMessageMarshaller()); format.addMarshaller(new ShutdownInfoMarshaller());
format.addMarshaller(new ShutdownInfoMarshaller()); format.addMarshaller(new DataResponseMarshaller());
format.addMarshaller(new DataResponseMarshaller()); format.addMarshaller(new SessionIdMarshaller());
format.addMarshaller(new SessionIdMarshaller()); format.addMarshaller(new DataArrayResponseMarshaller());
format.addMarshaller(new DataArrayResponseMarshaller()); format.addMarshaller(new JournalQueueAckMarshaller());
format.addMarshaller(new JournalQueueAckMarshaller()); format.addMarshaller(new WireFormatInfoMarshaller());
format.addMarshaller(new WireFormatInfoMarshaller()); format.addMarshaller(new ResponseMarshaller());
format.addMarshaller(new ResponseMarshaller()); format.addMarshaller(new ConnectionErrorMarshaller());
format.addMarshaller(new ConnectionErrorMarshaller()); format.addMarshaller(new ActiveMQObjectMessageMarshaller());
format.addMarshaller(new ActiveMQObjectMessageMarshaller()); format.addMarshaller(new ConsumerInfoMarshaller());
format.addMarshaller(new ConsumerInfoMarshaller()); format.addMarshaller(new ActiveMQTempTopicMarshaller());
format.addMarshaller(new ActiveMQTempTopicMarshaller()); format.addMarshaller(new ConnectionIdMarshaller());
format.addMarshaller(new ConnectionIdMarshaller()); format.addMarshaller(new DiscoveryEventMarshaller());
format.addMarshaller(new DiscoveryEventMarshaller()); format.addMarshaller(new ConnectionInfoMarshaller());
format.addMarshaller(new ConnectionInfoMarshaller()); format.addMarshaller(new KeepAliveInfoMarshaller());
format.addMarshaller(new KeepAliveInfoMarshaller()); format.addMarshaller(new XATransactionIdMarshaller());
format.addMarshaller(new XATransactionIdMarshaller()); format.addMarshaller(new JournalTraceMarshaller());
format.addMarshaller(new JournalTraceMarshaller()); format.addMarshaller(new FlushCommandMarshaller());
format.addMarshaller(new FlushCommandMarshaller()); format.addMarshaller(new ConsumerIdMarshaller());
format.addMarshaller(new ConsumerIdMarshaller()); format.addMarshaller(new JournalTopicAckMarshaller());
format.addMarshaller(new JournalTopicAckMarshaller()); format.addMarshaller(new ActiveMQTextMessageMarshaller());
format.addMarshaller(new ActiveMQTextMessageMarshaller()); format.addMarshaller(new BrokerIdMarshaller());
format.addMarshaller(new BrokerIdMarshaller()); format.addMarshaller(new MessageDispatchMarshaller());
format.addMarshaller(new MessageDispatchMarshaller()); format.addMarshaller(new ProducerInfoMarshaller());
format.addMarshaller(new ProducerInfoMarshaller()); format.addMarshaller(new SubscriptionInfoMarshaller());
format.addMarshaller(new SubscriptionInfoMarshaller()); format.addMarshaller(new ActiveMQMapMessageMarshaller());
format.addMarshaller(new ActiveMQMapMessageMarshaller()); format.addMarshaller(new MessageDispatchNotificationMarshaller());
format.addMarshaller(new MessageDispatchNotificationMarshaller()); format.addMarshaller(new SessionInfoMarshaller());
format.addMarshaller(new SessionInfoMarshaller()); format.addMarshaller(new ActiveMQMessageMarshaller());
format.addMarshaller(new ActiveMQMessageMarshaller()); format.addMarshaller(new TransactionInfoMarshaller());
format.addMarshaller(new TransactionInfoMarshaller()); format.addMarshaller(new ActiveMQStreamMessageMarshaller());
format.addMarshaller(new ActiveMQStreamMessageMarshaller()); format.addMarshaller(new MessageAckMarshaller());
format.addMarshaller(new MessageAckMarshaller()); format.addMarshaller(new ProducerIdMarshaller());
format.addMarshaller(new ProducerIdMarshaller()); format.addMarshaller(new ActiveMQTopicMarshaller());
format.addMarshaller(new ActiveMQTopicMarshaller()); format.addMarshaller(new JournalTransactionMarshaller());
format.addMarshaller(new JournalTransactionMarshaller()); format.addMarshaller(new RemoveInfoMarshaller());
format.addMarshaller(new RemoveInfoMarshaller()); format.addMarshaller(new ControlCommandMarshaller());
format.addMarshaller(new ControlCommandMarshaller()); format.addMarshaller(new ExceptionResponseMarshaller());
format.addMarshaller(new ExceptionResponseMarshaller()); }
} }
} }
}

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for MessageAck // Marshalling code for Open Wire Format for MessageAck

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for MessageDispatch // Marshalling code for Open Wire Format for MessageDispatch

191
openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs
View File

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

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for MessageId // Marshalling code for Open Wire Format for MessageId

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for Message // Marshalling code for Open Wire Format for Message

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ProducerId // Marshalling code for Open Wire Format for ProducerId

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ProducerInfo // Marshalling code for Open Wire Format for ProducerInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for RemoveInfo // Marshalling code for Open Wire Format for RemoveInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for RemoveSubscriptionInfo // Marshalling code for Open Wire Format for RemoveSubscriptionInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for Response // Marshalling code for Open Wire Format for Response

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for SessionId // Marshalling code for Open Wire Format for SessionId

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for SessionInfo // Marshalling code for Open Wire Format for SessionInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for ShutdownInfo // Marshalling code for Open Wire Format for ShutdownInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for SubscriptionInfo // Marshalling code for Open Wire Format for SubscriptionInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for TransactionId // Marshalling code for Open Wire Format for TransactionId

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for TransactionInfo // Marshalling code for Open Wire Format for TransactionInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for WireFormatInfo // Marshalling code for Open Wire Format for WireFormatInfo

9
openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs
View File

@ -19,12 +19,11 @@ using System;
using System.Collections; using System.Collections;
using System.IO; using System.IO;
using OpenWire.Client; using ActiveMQ.OpenWire;
using OpenWire.Client.Commands; using ActiveMQ.OpenWire.Commands;
using OpenWire.Client.Core; using ActiveMQ.OpenWire.V1;
using OpenWire.Client.IO;
namespace OpenWire.Client.IO namespace ActiveMQ.OpenWire.V1
{ {
// //
// Marshalling code for Open Wire Format for XATransactionId // Marshalling code for Open Wire Format for XATransactionId