You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/09/27 04:49:23 UTC
svn commit: r450291 [6/8] - in /incubator/activemq/activemq-dotnet/trunk: ./
src/main/csharp/ActiveMQ/Commands/ src/main/csharp/ActiveMQ/OpenWire/V2/
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/LocalTransactionIdMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/LocalTransactionIdMarshaller.cs?view=diff&rev=450291&r1=450290&r2=450291
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/LocalTransactionIdMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/LocalTransactionIdMarshaller.cs Tue Sep 26 19:49:19 2006
@@ -1 +1 @@
-/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using System.Colle
ctions;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for LocalTransactionId
/// </summary>
class LocalTransactionIdMarshaller : TransactionIdMarshaller
{
public override DataStructure CreateObject()
{
return new LocalTransactionId();
}
public override byte GetDataStructureType()
{
return LocalTransactionId.ID_LocalTransactionId;
}
//
// 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);
LocalTransactionId info = (LocalTransactionId)o;
info.Value = TightUnmarshalLong(wireFormat, dataIn, bs);
info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFo
rmat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
LocalTransactionId info = (LocalTransactionId)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalLong1(wireFormat, info.Value, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, 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);
LocalTransactionId info = (LocalTransactionId)o;
TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
}
//
// Un-ma
rshal an object instance from the data input stream
//
public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
{
base.LooseUnmarshal(wireFormat, o, dataIn);
LocalTransactionId info = (LocalTransactionId)o;
info.Value = LooseUnmarshalLong(wireFormat, dataIn);
info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
LocalTransactionId info = (LocalTransactionId)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalLong(wireFormat, info.Value, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
}
}
}
\ No newline at end of file
+/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using S
ystem.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for LocalTransactionId
/// </summary>
class LocalTransactionIdMarshaller : TransactionIdMarshaller
{
public override DataStructure CreateObject()
{
return new LocalTransactionId();
}
public override byte GetDataStructureType()
{
return LocalTransactionId.ID_LocalTransactionId;
}
//
// 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);
LocalTransactionId info = (LocalTransactionId)o;
info.Value = TightUnmarshalLong(wireFormat, dataIn, bs);
info.ConnectionId = (ConnectionId) TightUnmarshalCachedOb
ject(wireFormat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
LocalTransactionId info = (LocalTransactionId)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalLong1(wireFormat, info.Value, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, 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);
LocalTransactionId info = (LocalTransactionId)o;
TightMarshalLong2(wireFormat, info.Value, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, 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);
LocalTransactionId info = (LocalTransactionId)o;
info.Value = LooseUnmarshalLong(wireFormat, dataIn);
info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
LocalTransactionId info = (LocalTransactionId)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalLong(wireFormat, info.Value, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
}
}
}
\ No newline at end of file
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MarshallerFactory.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MarshallerFactory.cs?view=diff&rev=450291&r1=450290&r2=450291
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MarshallerFactory.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MarshallerFactory.cs Tue Sep 26 19:49:19 2006
@@ -1,19 +1,19 @@
/*
-* 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.
-*/
+ * 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.
+ */
//
// NOTE!: This file is autogenerated - do not modify!
@@ -38,61 +38,61 @@
{
public void configure(OpenWireFormat format)
{
-
- format.addMarshaller(new LocalTransactionIdMarshaller());
- format.addMarshaller(new PartialCommandMarshaller());
- format.addMarshaller(new IntegerResponseMarshaller());
- format.addMarshaller(new ActiveMQQueueMarshaller());
+ format.addMarshaller(new ActiveMQBytesMessageMarshaller());
+ format.addMarshaller(new ActiveMQMapMessageMarshaller());
+ format.addMarshaller(new ActiveMQMessageMarshaller());
format.addMarshaller(new ActiveMQObjectMessageMarshaller());
- format.addMarshaller(new ConnectionIdMarshaller());
- format.addMarshaller(new ConnectionInfoMarshaller());
- format.addMarshaller(new ProducerInfoMarshaller());
- format.addMarshaller(new MessageDispatchNotificationMarshaller());
- format.addMarshaller(new SessionInfoMarshaller());
- format.addMarshaller(new TransactionInfoMarshaller());
+ format.addMarshaller(new ActiveMQQueueMarshaller());
format.addMarshaller(new ActiveMQStreamMessageMarshaller());
- format.addMarshaller(new MessageAckMarshaller());
- format.addMarshaller(new ProducerIdMarshaller());
- format.addMarshaller(new MessageIdMarshaller());
format.addMarshaller(new ActiveMQTempQueueMarshaller());
- format.addMarshaller(new RemoveSubscriptionInfoMarshaller());
- format.addMarshaller(new SessionIdMarshaller());
- format.addMarshaller(new DataArrayResponseMarshaller());
- format.addMarshaller(new JournalQueueAckMarshaller());
- format.addMarshaller(new ResponseMarshaller());
- format.addMarshaller(new ConnectionErrorMarshaller());
- format.addMarshaller(new ConsumerInfoMarshaller());
- format.addMarshaller(new XATransactionIdMarshaller());
- format.addMarshaller(new JournalTraceMarshaller());
- format.addMarshaller(new ConsumerIdMarshaller());
- format.addMarshaller(new ActiveMQTextMessageMarshaller());
- format.addMarshaller(new SubscriptionInfoMarshaller());
- format.addMarshaller(new JournalTransactionMarshaller());
- format.addMarshaller(new ControlCommandMarshaller());
- format.addMarshaller(new LastPartialCommandMarshaller());
- format.addMarshaller(new NetworkBridgeFilterMarshaller());
- format.addMarshaller(new MessagePullMarshaller());
- format.addMarshaller(new ActiveMQBytesMessageMarshaller());
- format.addMarshaller(new WireFormatInfoMarshaller());
format.addMarshaller(new ActiveMQTempTopicMarshaller());
- format.addMarshaller(new DiscoveryEventMarshaller());
- format.addMarshaller(new ReplayCommandMarshaller());
+ format.addMarshaller(new ActiveMQTextMessageMarshaller());
format.addMarshaller(new ActiveMQTopicMarshaller());
+ format.addMarshaller(new BrokerIdMarshaller());
format.addMarshaller(new BrokerInfoMarshaller());
- format.addMarshaller(new DestinationInfoMarshaller());
- format.addMarshaller(new ShutdownInfoMarshaller());
- format.addMarshaller(new DataResponseMarshaller());
format.addMarshaller(new ConnectionControlMarshaller());
- format.addMarshaller(new KeepAliveInfoMarshaller());
- format.addMarshaller(new FlushCommandMarshaller());
+ format.addMarshaller(new ConnectionErrorMarshaller());
+ format.addMarshaller(new ConnectionIdMarshaller());
+ format.addMarshaller(new ConnectionInfoMarshaller());
format.addMarshaller(new ConsumerControlMarshaller());
+ format.addMarshaller(new ConsumerIdMarshaller());
+ format.addMarshaller(new ConsumerInfoMarshaller());
+ format.addMarshaller(new ControlCommandMarshaller());
+ format.addMarshaller(new DataArrayResponseMarshaller());
+ format.addMarshaller(new DataResponseMarshaller());
+ format.addMarshaller(new DestinationInfoMarshaller());
+ format.addMarshaller(new DiscoveryEventMarshaller());
+ format.addMarshaller(new ExceptionResponseMarshaller());
+ format.addMarshaller(new FlushCommandMarshaller());
+ format.addMarshaller(new IntegerResponseMarshaller());
+ format.addMarshaller(new JournalQueueAckMarshaller());
format.addMarshaller(new JournalTopicAckMarshaller());
- format.addMarshaller(new BrokerIdMarshaller());
+ format.addMarshaller(new JournalTraceMarshaller());
+ format.addMarshaller(new JournalTransactionMarshaller());
+ format.addMarshaller(new KeepAliveInfoMarshaller());
+ format.addMarshaller(new LastPartialCommandMarshaller());
+ format.addMarshaller(new LocalTransactionIdMarshaller());
+ format.addMarshaller(new MessageAckMarshaller());
format.addMarshaller(new MessageDispatchMarshaller());
- format.addMarshaller(new ActiveMQMapMessageMarshaller());
- format.addMarshaller(new ActiveMQMessageMarshaller());
+ format.addMarshaller(new MessageDispatchNotificationMarshaller());
+ format.addMarshaller(new MessageIdMarshaller());
+ format.addMarshaller(new MessagePullMarshaller());
+ format.addMarshaller(new NetworkBridgeFilterMarshaller());
+ format.addMarshaller(new PartialCommandMarshaller());
+ format.addMarshaller(new ProducerIdMarshaller());
+ format.addMarshaller(new ProducerInfoMarshaller());
format.addMarshaller(new RemoveInfoMarshaller());
- format.addMarshaller(new ExceptionResponseMarshaller());
+ format.addMarshaller(new RemoveSubscriptionInfoMarshaller());
+ format.addMarshaller(new ReplayCommandMarshaller());
+ format.addMarshaller(new ResponseMarshaller());
+ format.addMarshaller(new SessionIdMarshaller());
+ format.addMarshaller(new SessionInfoMarshaller());
+ format.addMarshaller(new ShutdownInfoMarshaller());
+ format.addMarshaller(new SubscriptionInfoMarshaller());
+ format.addMarshaller(new TransactionInfoMarshaller());
+ format.addMarshaller(new WireFormatInfoMarshaller());
+ format.addMarshaller(new XATransactionIdMarshaller());
+
}
}
}
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageAckMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageAckMarshaller.cs?view=diff&rev=450291&r1=450290&r2=450291
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageAckMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageAckMarshaller.cs Tue Sep 26 19:49:19 2006
@@ -1 +1 @@
-/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using System.Colle
ctions;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for MessageAck
/// </summary>
class MessageAckMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new MessageAck();
}
public override byte GetDataStructureType()
{
return MessageAck.ID_MessageAck;
}
//
// 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);
MessageAck info = (MessageAck)o;
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.AckType = dataIn.ReadByte();
info.FirstMessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.LastMessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.MessageCount = dataIn.ReadInt32();
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageAck info = (MessageAck)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure
)info.FirstMessageId, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.LastMessageId, bs);
return rc + 5;
}
//
// 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);
MessageAck info = (MessageAck)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
dataOut.Write(info.AckType);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.FirstMessageId, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.LastMessageId, dataOut, bs);
dataOut.Write(info.MessageCount);
}
//
// 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);
MessageAck info = (MessageAck)o;
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.AckType = dataIn.ReadByte();
info.FirstMessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.LastMessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.MessageCount = dataIn.ReadInt32();
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWrit
er dataOut) {
MessageAck info = (MessageAck)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
dataOut.Write(info.AckType);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.FirstMessageId, dataOut);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.LastMessageId, dataOut);
dataOut.Write(info.MessageCount);
}
}
}
\ No newline at end of file
+/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using S
ystem.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for MessageAck
/// </summary>
class MessageAckMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new MessageAck();
}
public override byte GetDataStructureType()
{
return MessageAck.ID_MessageAck;
}
//
// 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);
MessageAck info = (MessageAck)o;
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dat
aIn, bs);
info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.AckType = dataIn.ReadByte();
info.FirstMessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.LastMessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.MessageCount = dataIn.ReadInt32();
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageAck info = (MessageAck)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
rc += TightMarshalNestedObject1(wireFormat, (Da
taStructure)info.FirstMessageId, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.LastMessageId, bs);
return rc + 5;
}
//
// 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);
MessageAck info = (MessageAck)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
dataOut.Write(info.AckType);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.FirstMessageId, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.LastMessageId, dataOut, bs);
dataOut.Write(info.MessageCo
unt);
}
//
// 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);
MessageAck info = (MessageAck)o;
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.AckType = dataIn.ReadByte();
info.FirstMessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.LastMessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.MessageCount = dataIn.ReadInt32();
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o,
BinaryWriter dataOut) {
MessageAck info = (MessageAck)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
dataOut.Write(info.AckType);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.FirstMessageId, dataOut);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.LastMessageId, dataOut);
dataOut.Write(info.MessageCount);
}
}
}
\ No newline at end of file
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchMarshaller.cs?view=diff&rev=450291&r1=450290&r2=450291
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchMarshaller.cs Tue Sep 26 19:49:19 2006
@@ -1 +1 @@
-/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using System.Colle
ctions;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for MessageDispatch
/// </summary>
class MessageDispatchMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new MessageDispatch();
}
public override byte GetDataStructureType()
{
return MessageDispatch.ID_MessageDispatch;
}
//
// 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);
MessageDispatch info = (MessageDispatch)o;
info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObje
ct(wireFormat, dataIn, bs);
info.Message = (Message) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.RedeliveryCounter = dataIn.ReadInt32();
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageDispatch info = (MessageDispatch)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Message, bs);
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, data
Out, bs);
MessageDispatch info = (MessageDispatch)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.Message, dataOut, bs);
dataOut.Write(info.RedeliveryCounter);
}
//
// 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);
MessageDispatch info = (MessageDispatch)o;
info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Message = (Message) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.RedeliveryCounter = dataIn.Read
Int32();
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
MessageDispatch info = (MessageDispatch)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.Message, dataOut);
dataOut.Write(info.RedeliveryCounter);
}
}
}
\ No newline at end of file
+/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using S
ystem.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for MessageDispatch
/// </summary>
class MessageDispatchMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new MessageDispatch();
}
public override byte GetDataStructureType()
{
return MessageDispatch.ID_MessageDispatch;
}
//
// 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);
MessageDispatch info = (MessageDispatch)o;
info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.Destination = (ActiveMQDestination) TightUnmarsha
lCachedObject(wireFormat, dataIn, bs);
info.Message = (Message) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.RedeliveryCounter = dataIn.ReadInt32();
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageDispatch info = (MessageDispatch)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Message, bs);
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(wireForm
at, o, dataOut, bs);
MessageDispatch info = (MessageDispatch)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.Message, dataOut, bs);
dataOut.Write(info.RedeliveryCounter);
}
//
// 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);
MessageDispatch info = (MessageDispatch)o;
info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Message = (Message) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.RedeliveryCounter =
dataIn.ReadInt32();
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
MessageDispatch info = (MessageDispatch)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.Message, dataOut);
dataOut.Write(info.RedeliveryCounter);
}
}
}
\ No newline at end of file
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchNotificationMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchNotificationMarshaller.cs?view=diff&rev=450291&r1=450290&r2=450291
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchNotificationMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchNotificationMarshaller.cs Tue Sep 26 19:49:19 2006
@@ -1 +1 @@
-/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using System.Colle
ctions;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for MessageDispatchNotification
/// </summary>
class MessageDispatchNotificationMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new MessageDispatchNotification();
}
public override byte GetDataStructureType()
{
return MessageDispatchNotification.ID_MessageDispatchNotification;
}
//
// Un-marshal an object instance from the data input stream
//
public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
{
base.TightUnmarshal(wireFormat, o, dataIn, bs);
MessageDispatchNotification info = (MessageDispatchNotification)o;
info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, da
taIn, bs);
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.DeliverySequenceId = TightUnmarshalLong(wireFormat, dataIn, bs);
info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageDispatchNotification info = (MessageDispatchNotification)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
return rc + 0;
}
//
// Writ
e a object instance to data output stream
//
public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
base.TightMarshal2(wireFormat, o, dataOut, bs);
MessageDispatchNotification info = (MessageDispatchNotification)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
}
//
// Un-marshal an object instance from the data input stream
//
public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
{
base.LooseUnmarshal(wireFormat, o, dataIn);
MessageDispatchNotification info = (MessageDispatchNotification)o;
info.Con
sumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.DeliverySequenceId = LooseUnmarshalLong(wireFormat, dataIn);
info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
MessageDispatchNotification info = (MessageDispatchNotification)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalLong(wireFormat, info.DeliverySequenceId, dataOut);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut);
}
}
}
\ No newline at end of file
+/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using S
ystem.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for MessageDispatchNotification
/// </summary>
class MessageDispatchNotificationMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new MessageDispatchNotification();
}
public override byte GetDataStructureType()
{
return MessageDispatchNotification.ID_MessageDispatchNotification;
}
//
// Un-marshal an object instance from the data input stream
//
public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
{
base.TightUnmarshal(wireFormat, o, dataIn, bs);
MessageDispatchNotification info = (MessageDispatchNotification)o;
info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wir
eFormat, dataIn, bs);
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.DeliverySequenceId = TightUnmarshalLong(wireFormat, dataIn, bs);
info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageDispatchNotification info = (MessageDispatchNotification)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
return rc + 0;
}
//
// Write a object instance to data output stream
//
public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
base.TightMarshal2(wireFormat, o, dataOut, bs);
MessageDispatchNotification info = (MessageDispatchNotification)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
}
//
// Un-marshal an object instance from the data input stream
//
public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
{
base.LooseUnmarshal(wireFormat, o, dataIn);
MessageDispatchNotification info = (MessageDispatchNotification)o;
info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.DeliverySequenceId = LooseUnmarshalLong(wireFormat, dataIn);
info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
MessageDispatchNotification info = (MessageDispatchNotification)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalLong(wireFormat, info.DeliverySequenceId, dataOut);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut);
}
}
}
\ No newline at end of file
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageIdMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageIdMarshaller.cs?view=diff&rev=450291&r1=450290&r2=450291
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageIdMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageIdMarshaller.cs Tue Sep 26 19:49:19 2006
@@ -1 +1 @@
-/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using System.Colle
ctions;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for MessageId
/// </summary>
class MessageIdMarshaller : BaseDataStreamMarshaller
{
public override DataStructure CreateObject()
{
return new MessageId();
}
public override byte GetDataStructureType()
{
return MessageId.ID_MessageId;
}
//
// 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);
MessageId info = (MessageId)o;
info.ProducerId = (ProducerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.ProducerSequenceId = TightUnmarshalLong(wireFormat, dataIn, bs);
info.BrokerSequenceId = Ti
ghtUnmarshalLong(wireFormat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageId info = (MessageId)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
rc += TightMarshalLong1(wireFormat, info.ProducerSequenceId, bs);
rc += TightMarshalLong1(wireFormat, info.BrokerSequenceId, bs);
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);
MessageId info = (MessageId)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
TightMarshalLong
2(wireFormat, info.ProducerSequenceId, dataOut, bs);
TightMarshalLong2(wireFormat, info.BrokerSequenceId, 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);
MessageId info = (MessageId)o;
info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.ProducerSequenceId = LooseUnmarshalLong(wireFormat, dataIn);
info.BrokerSequenceId = LooseUnmarshalLong(wireFormat, dataIn);
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
MessageId info = (MessageId)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId,
dataOut);
LooseMarshalLong(wireFormat, info.ProducerSequenceId, dataOut);
LooseMarshalLong(wireFormat, info.BrokerSequenceId, dataOut);
}
}
}
\ No newline at end of file
+/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using S
ystem.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for MessageId
/// </summary>
class MessageIdMarshaller : BaseDataStreamMarshaller
{
public override DataStructure CreateObject()
{
return new MessageId();
}
public override byte GetDataStructureType()
{
return MessageId.ID_MessageId;
}
//
// 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);
MessageId info = (MessageId)o;
info.ProducerId = (ProducerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.ProducerSequenceId = TightUnmarshalLong(wireFormat, dataIn, bs);
info.BrokerSequ
enceId = TightUnmarshalLong(wireFormat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessageId info = (MessageId)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
rc += TightMarshalLong1(wireFormat, info.ProducerSequenceId, bs);
rc += TightMarshalLong1(wireFormat, info.BrokerSequenceId, bs);
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);
MessageId info = (MessageId)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
Tight
MarshalLong2(wireFormat, info.ProducerSequenceId, dataOut, bs);
TightMarshalLong2(wireFormat, info.BrokerSequenceId, 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);
MessageId info = (MessageId)o;
info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.ProducerSequenceId = LooseUnmarshalLong(wireFormat, dataIn);
info.BrokerSequenceId = LooseUnmarshalLong(wireFormat, dataIn);
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
MessageId info = (MessageId)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.
ProducerId, dataOut);
LooseMarshalLong(wireFormat, info.ProducerSequenceId, dataOut);
LooseMarshalLong(wireFormat, info.BrokerSequenceId, dataOut);
}
}
}
\ No newline at end of file
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageMarshaller.cs?view=diff&rev=450291&r1=450290&r2=450291
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageMarshaller.cs Tue Sep 26 19:49:19 2006
@@ -1 +1 @@
-/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using System.Colle
ctions;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for Message
/// </summary>
abstract class MessageMarshaller : BaseCommandMarshaller
{
//
// 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);
Message info = (Message)o;
info.ProducerId = (ProducerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.OriginalDestination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.OriginalTransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.GroupID = TightUnmarshalString(dataIn, bs);
info.GroupSequence = dataIn.ReadInt32();
info.CorrelationId = TightUnmarshalString(dataIn, bs);
info.Persistent = bs.ReadBoolean();
info.Expiration = TightUnmarshalLong(wireFormat, dataIn, bs);
info.Priority = dataIn.ReadByte();
info.ReplyTo = (ActiveMQDestination) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.Timestamp = TightUnmarshalLong(wireFormat, dataIn, bs);
info.Type = TightUnmarshalString(dataIn, bs);
info.Content = ReadBytes(dataIn, bs.ReadBoolean());
info.MarshalledProperties = ReadBytes(dataIn, bs.ReadBoolean());
info.DataStructure = (DataStructure) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.TargetCons
umerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.Compressed = bs.ReadBoolean();
info.RedeliveryCounter = dataIn.ReadInt32();
if (bs.ReadBoolean()) {
short size = dataIn.ReadInt16();
BrokerId[] value = new BrokerId[size];
for( int i=0; i < size; i++ ) {
value[i] = (BrokerId) TightUnmarshalNestedObject(wireFormat,dataIn, bs);
}
info.BrokerPath = value;
}
else {
info.BrokerPath = null;
}
info.Arrival = TightUnmarshalLong(wireFormat, dataIn, bs);
info.UserID = TightUnmarshalString(dataIn, bs);
info.RecievedByDFBridge = bs.ReadBoolean();
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
Message info = (Message)o;
int rc = base.TightMarshal1(wir
eFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalDestination, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalTransactionId, bs);
rc += TightMarshalString1(info.GroupID, bs);
rc += TightMarshalString1(info.CorrelationId, bs);
bs.WriteBoolean(info.Persistent);
rc += TightMarshalLong1(wireFormat, info.Expiration, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.ReplyTo, bs);
rc += TightMarshalLong1(wireFormat, info.Timestamp, bs);
rc += TightMarshalString1(info.Ty
pe, bs);
bs.WriteBoolean(info.Content!=null);
rc += info.Content==null ? 0 : info.Content.Length+4;
bs.WriteBoolean(info.MarshalledProperties!=null);
rc += info.MarshalledProperties==null ? 0 : info.MarshalledProperties.Length+4;
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.DataStructure, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TargetConsumerId, bs);
bs.WriteBoolean(info.Compressed);
rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
rc += TightMarshalLong1(wireFormat, info.Arrival, bs);
rc += TightMarshalString1(info.UserID, bs);
bs.WriteBoolean(info.RecievedByDFBridge);
return rc + 9;
}
//
// Write a object instance to data output stream
//
public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
base.TightMarshal2(wireFormat, o, d
ataOut, bs);
Message info = (Message)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalDestination, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut, bs);
TightMarshalString2(info.GroupID, dataOut, bs);
dataOut.Write(info.GroupSequence);
TightMarshalString2(info.CorrelationId, dataOut, bs);
bs.ReadBoolean();
TightMarshalLong2(wireFormat, info.Expiration, dataOut, bs);
dataOut.Write(info.Priority);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.Reply
To, dataOut, bs);
TightMarshalLong2(wireFormat, info.Timestamp, dataOut, bs);
TightMarshalString2(info.Type, dataOut, bs);
if(bs.ReadBoolean()) {
dataOut.Write(info.Content.Length);
dataOut.Write(info.Content);
}
if(bs.ReadBoolean()) {
dataOut.Write(info.MarshalledProperties.Length);
dataOut.Write(info.MarshalledProperties);
}
TightMarshalNestedObject2(wireFormat, (DataStructure)info.DataStructure, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.TargetConsumerId, dataOut, bs);
bs.ReadBoolean();
dataOut.Write(info.RedeliveryCounter);
TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
TightMarshalLong2(wireFormat, info.Arrival, dataOut, bs);
TightMarshalString2(info.UserID, dataOut, bs);
bs.ReadBoolean();
}
//
// 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);
Message info = (Message)o;
info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.OriginalDestination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.OriginalTransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.GroupID = LooseUnmarshalString(dataIn);
info.GroupSequence = dataIn.ReadInt32();
info.CorrelationId = LooseUnmarshalString(dataIn);
info.Persistent = dataIn.ReadBoolean();
in
fo.Expiration = LooseUnmarshalLong(wireFormat, dataIn);
info.Priority = dataIn.ReadByte();
info.ReplyTo = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.Timestamp = LooseUnmarshalLong(wireFormat, dataIn);
info.Type = LooseUnmarshalString(dataIn);
info.Content = ReadBytes(dataIn, dataIn.ReadBoolean());
info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean());
info.DataStructure = (DataStructure) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.TargetConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Compressed = dataIn.ReadBoolean();
info.RedeliveryCounter = dataIn.ReadInt32();
if (dataIn.ReadBoolean()) {
short size = dataIn.ReadInt16();
BrokerId[] value = new BrokerId[size];
for( int i=0; i < size; i++ ) {
value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,d
ataIn);
}
info.BrokerPath = value;
}
else {
info.BrokerPath = null;
}
info.Arrival = LooseUnmarshalLong(wireFormat, dataIn);
info.UserID = LooseUnmarshalString(dataIn);
info.RecievedByDFBridge = dataIn.ReadBoolean();
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
Message info = (Message)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.OriginalDestination, dataOut);
LooseMarshalNestedObject(wireFormat, (DataStructure)info
.MessageId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut);
LooseMarshalString(info.GroupID, dataOut);
dataOut.Write(info.GroupSequence);
LooseMarshalString(info.CorrelationId, dataOut);
dataOut.Write(info.Persistent);
LooseMarshalLong(wireFormat, info.Expiration, dataOut);
dataOut.Write(info.Priority);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.ReplyTo, dataOut);
LooseMarshalLong(wireFormat, info.Timestamp, dataOut);
LooseMarshalString(info.Type, dataOut);
dataOut.Write(info.Content!=null);
if(info.Content!=null) {
dataOut.Write(info.Content.Length);
dataOut.Write(info.Content);
}
dataOut.Write(info.MarshalledProperties!=null);
if(info.MarshalledProperties!=null) {
dataOut.Write(info.MarshalledProperties.Length);
dataOut.Write(info.MarshalledProper
ties);
}
LooseMarshalNestedObject(wireFormat, (DataStructure)info.DataStructure, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.TargetConsumerId, dataOut);
dataOut.Write(info.Compressed);
dataOut.Write(info.RedeliveryCounter);
LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut);
LooseMarshalLong(wireFormat, info.Arrival, dataOut);
LooseMarshalString(info.UserID, dataOut);
dataOut.Write(info.RecievedByDFBridge);
}
}
}
\ No newline at end of file
+/*
* 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.
*/
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
using System;
using S
ystem.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;
namespace ActiveMQ.OpenWire.V2
{
/// <summary>
/// Marshalling code for Open Wire Format for Message
/// </summary>
abstract class MessageMarshaller : BaseCommandMarshaller
{
//
// 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);
Message info = (Message)o;
info.ProducerId = (ProducerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.OriginalDestination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn
, bs);
info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.OriginalTransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.GroupID = TightUnmarshalString(dataIn, bs);
info.GroupSequence = dataIn.ReadInt32();
info.CorrelationId = TightUnmarshalString(dataIn, bs);
info.Persistent = bs.ReadBoolean();
info.Expiration = TightUnmarshalLong(wireFormat, dataIn, bs);
info.Priority = dataIn.ReadByte();
info.ReplyTo = (ActiveMQDestination) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info.Timestamp = TightUnmarshalLong(wireFormat, dataIn, bs);
info.Type = TightUnmarshalString(dataIn, bs);
info.Content = ReadBytes(dataIn, bs.ReadBoolean());
info.MarshalledProperties = ReadBytes(dataIn, bs.ReadBoolean());
info.DataStructure = (DataStructure) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
info
.TargetConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.Compressed = bs.ReadBoolean();
info.RedeliveryCounter = dataIn.ReadInt32();
if (bs.ReadBoolean()) {
short size = dataIn.ReadInt16();
BrokerId[] value = new BrokerId[size];
for( int i=0; i < size; i++ ) {
value[i] = (BrokerId) TightUnmarshalNestedObject(wireFormat,dataIn, bs);
}
info.BrokerPath = value;
}
else {
info.BrokerPath = null;
}
info.Arrival = TightUnmarshalLong(wireFormat, dataIn, bs);
info.UserID = TightUnmarshalString(dataIn, bs);
info.RecievedByDFBridge = bs.ReadBoolean();
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
Message info = (Message)o;
int rc = base.TightM
arshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalDestination, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalTransactionId, bs);
rc += TightMarshalString1(info.GroupID, bs);
rc += TightMarshalString1(info.CorrelationId, bs);
bs.WriteBoolean(info.Persistent);
rc += TightMarshalLong1(wireFormat, info.Expiration, bs);
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.ReplyTo, bs);
rc += TightMarshalLong1(wireFormat, info.Timestamp, bs);
rc += TightMarshalStri
ng1(info.Type, bs);
bs.WriteBoolean(info.Content!=null);
rc += info.Content==null ? 0 : info.Content.Length+4;
bs.WriteBoolean(info.MarshalledProperties!=null);
rc += info.MarshalledProperties==null ? 0 : info.MarshalledProperties.Length+4;
rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.DataStructure, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TargetConsumerId, bs);
bs.WriteBoolean(info.Compressed);
rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs);
rc += TightMarshalLong1(wireFormat, info.Arrival, bs);
rc += TightMarshalString1(info.UserID, bs);
bs.WriteBoolean(info.RecievedByDFBridge);
return rc + 9;
}
//
// Write a object instance to data output stream
//
public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
base.TightMarshal2(wireF
ormat, o, dataOut, bs);
Message info = (Message)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalDestination, dataOut, bs);
TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut, bs);
TightMarshalString2(info.GroupID, dataOut, bs);
dataOut.Write(info.GroupSequence);
TightMarshalString2(info.CorrelationId, dataOut, bs);
bs.ReadBoolean();
TightMarshalLong2(wireFormat, info.Expiration, dataOut, bs);
dataOut.Write(info.Priority);
TightMarshalNestedObject2(wireFormat, (DataStructure
)info.ReplyTo, dataOut, bs);
TightMarshalLong2(wireFormat, info.Timestamp, dataOut, bs);
TightMarshalString2(info.Type, dataOut, bs);
if(bs.ReadBoolean()) {
dataOut.Write(info.Content.Length);
dataOut.Write(info.Content);
}
if(bs.ReadBoolean()) {
dataOut.Write(info.MarshalledProperties.Length);
dataOut.Write(info.MarshalledProperties);
}
TightMarshalNestedObject2(wireFormat, (DataStructure)info.DataStructure, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.TargetConsumerId, dataOut, bs);
bs.ReadBoolean();
dataOut.Write(info.RedeliveryCounter);
TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs);
TightMarshalLong2(wireFormat, info.Arrival, dataOut, bs);
TightMarshalString2(info.UserID, dataOut, bs);
bs.ReadBoolean();
}
//
// Un-marshal an object instance from the data i
nput stream
//
public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
{
base.LooseUnmarshal(wireFormat, o, dataIn);
Message info = (Message)o;
info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.OriginalDestination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.OriginalTransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.GroupID = LooseUnmarshalString(dataIn);
info.GroupSequence = dataIn.ReadInt32();
info.CorrelationId = LooseUnmarshalString(dataIn);
info.Persistent = dataIn.ReadBoolean();
info.Expiration = LooseUnmarshalLong(wireFormat, dataIn);
info.Priority = dataIn.ReadByte();
info.ReplyTo = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.Timestamp = LooseUnmarshalLong(wireFormat, dataIn);
info.Type = LooseUnmarshalString(dataIn);
info.Content = ReadBytes(dataIn, dataIn.ReadBoolean());
info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean());
info.DataStructure = (DataStructure) LooseUnmarshalNestedObject(wireFormat, dataIn);
info.TargetConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Compressed = dataIn.ReadBoolean();
info.RedeliveryCounter = dataIn.ReadInt32();
if (dataIn.ReadBoolean()) {
short size = dataIn.ReadInt16();
BrokerId[] value = new BrokerId[size];
for( int i=0; i < size; i++ ) {
value[i] = (BrokerId) LooseUnmarshalNestedObject(w
ireFormat,dataIn);
}
info.BrokerPath = value;
}
else {
info.BrokerPath = null;
}
info.Arrival = LooseUnmarshalLong(wireFormat, dataIn);
info.UserID = LooseUnmarshalString(dataIn);
info.RecievedByDFBridge = dataIn.ReadBoolean();
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
Message info = (Message)o;
base.LooseMarshal(wireFormat, o, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.OriginalDestination, dataOut);
LooseMarshalNestedObject(wireFormat, (DataStr
ucture)info.MessageId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut);
LooseMarshalString(info.GroupID, dataOut);
dataOut.Write(info.GroupSequence);
LooseMarshalString(info.CorrelationId, dataOut);
dataOut.Write(info.Persistent);
LooseMarshalLong(wireFormat, info.Expiration, dataOut);
dataOut.Write(info.Priority);
LooseMarshalNestedObject(wireFormat, (DataStructure)info.ReplyTo, dataOut);
LooseMarshalLong(wireFormat, info.Timestamp, dataOut);
LooseMarshalString(info.Type, dataOut);
dataOut.Write(info.Content!=null);
if(info.Content!=null) {
dataOut.Write(info.Content.Length);
dataOut.Write(info.Content);
}
dataOut.Write(info.MarshalledProperties!=null);
if(info.MarshalledProperties!=null) {
dataOut.Write(info.MarshalledProperties.Length);
dataOut.Write(info.Marsh
alledProperties);
}
LooseMarshalNestedObject(wireFormat, (DataStructure)info.DataStructure, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.TargetConsumerId, dataOut);
dataOut.Write(info.Compressed);
dataOut.Write(info.RedeliveryCounter);
LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut);
LooseMarshalLong(wireFormat, info.Arrival, dataOut);
LooseMarshalString(info.UserID, dataOut);
dataOut.Write(info.RecievedByDFBridge);
}
}
}
\ No newline at end of file