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/10/09 22:59:17 UTC
svn commit: r454506 [5/11] - in
/incubator/activemq/activemq-dotnet/trunk/src: main/csharp/ActiveMQ/
main/csharp/ActiveMQ/Commands/ main/csharp/ActiveMQ/OpenWire/
main/csharp/ActiveMQ/OpenWire/V2/ main/csharp/ActiveMQ/Transport/
main/csharp/ActiveMQ/Ut...
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=454506&r1=454505&r2=454506
==============================================================================
--- 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 Mon Oct 9 13:59:14 2006
@@ -1 +1,138 @@
-/*
* 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
+/*
+ * 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.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, 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, 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);
+
+ }
+ }
+}
Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageAckMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
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=454506&r1=454505&r2=454506
==============================================================================
--- 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 Mon Oct 9 13:59:14 2006
@@ -1 +1,124 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
//
// 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
+/*
+ * 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.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) TightUnmarshalCachedObject(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, 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);
+
+ }
+ }
+}
Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
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=454506&r1=454505&r2=454506
==============================================================================
--- 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 Mon Oct 9 13:59:14 2006
@@ -1 +1,125 @@
-/*
* 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
+/*
+ * 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.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(wireFormat, dataIn, bs);
+ info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+ info.DeliverySequenceId = TightUnmarshalLong(wireFormat, dataIn, bs);
+ info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
+
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+ MessageDispatchNotification info = (MessageDispatchNotification)o;
+
+ int rc = base.TightMarshal1(wireFormat, info, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+ rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs);
+ rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+ MessageDispatchNotification info = (MessageDispatchNotification)o;
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+ TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs);
+ TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
+
+ }
+
+ //
+ // 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);
+
+ }
+ }
+}
Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageDispatchNotificationMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
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=454506&r1=454505&r2=454506
==============================================================================
--- 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 Mon Oct 9 13:59:14 2006
@@ -1 +1,120 @@
-/*
* 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
+/*
+ * 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.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.BrokerSequenceId = 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);
+ TightMarshalLong2(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);
+
+ }
+ }
+}
Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageIdMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
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=454506&r1=454505&r2=454506
==============================================================================
--- 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 Mon Oct 9 13:59:14 2006
@@ -1 +1,254 @@
-/*
* 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
+/*
+ * 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.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.TightMarshal1(wireFormat, info, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalDestination, bs);
+ rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalTransactionId, bs);
+ rc += TightMarshalString1(info.GroupID, bs);
+ rc += 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.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(wireFormat, o, dataOut, bs);
+
+ Message info = (Message)o;
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalDestination, dataOut, bs);
+ TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut, bs);
+ TightMarshalString2(info.GroupID, dataOut, bs);
+ dataOut.Write(info.GroupSequence);
+ TightMarshalString2(info.CorrelationId, dataOut, bs);
+ bs.ReadBoolean();
+ TightMarshalLong2(wireFormat, info.Expiration, dataOut, bs);
+ dataOut.Write(info.Priority);
+ TightMarshalNestedObject2(wireFormat, (DataStructure)info.ReplyTo, dataOut, bs);
+ TightMarshalLong2(wireFormat, info.Timestamp, dataOut, bs);
+ TightMarshalString2(info.Type, dataOut, bs);
+ if(bs.ReadBoolean()) {
+ 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();
+ 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(wireFormat,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, (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.MarshalledProperties);
+ }
+ 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);
+
+ }
+ }
+}
Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessageMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessagePullMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessagePullMarshaller.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessagePullMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessagePullMarshaller.cs Mon Oct 9 13:59:14 2006
@@ -1 +1,120 @@
-/*
* 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 MessagePull
/// </summary>
class MessagePullMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new MessagePull();
}
public override byte GetDataStructureType()
{
return MessagePull.ID_MessagePull;
}
//
// 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);
MessagePull info = (MessagePull)o;
info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, da
taIn, bs);
info.Timeout = TightUnmarshalLong(wireFormat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
MessagePull info = (MessagePull)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.Timeout, 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);
MessagePull info = (MessagePull)o;
TightMarshalCachedObject2(wireFormat, (DataStructure)info
.ConsumerId, dataOut, bs);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
TightMarshalLong2(wireFormat, info.Timeout, 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);
MessagePull info = (MessagePull)o;
info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
info.Timeout = LooseUnmarshalLong(wireFormat, dataIn);
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
MessagePull info = (MessagePull)o;
base.LooseMarshal(wireFormat, o, dataOu
t);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
LooseMarshalLong(wireFormat, info.Timeout, 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 System.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 MessagePull
+ /// </summary>
+ class MessagePullMarshaller : BaseCommandMarshaller
+ {
+
+
+ public override DataStructure CreateObject()
+ {
+ return new MessagePull();
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return MessagePull.ID_MessagePull;
+ }
+
+ //
+ // 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);
+
+ MessagePull info = (MessagePull)o;
+ info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+ info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+ info.Timeout = TightUnmarshalLong(wireFormat, dataIn, bs);
+
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+ MessagePull info = (MessagePull)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.Timeout, 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);
+
+ MessagePull info = (MessagePull)o;
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+ TightMarshalLong2(wireFormat, info.Timeout, 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);
+
+ MessagePull info = (MessagePull)o;
+ info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Timeout = LooseUnmarshalLong(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ MessagePull info = (MessagePull)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalLong(wireFormat, info.Timeout, dataOut);
+
+ }
+ }
+}
Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/MessagePullMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/NetworkBridgeFilterMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/NetworkBridgeFilterMarshaller.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/NetworkBridgeFilterMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/NetworkBridgeFilterMarshaller.cs Mon Oct 9 13:59:14 2006
@@ -1 +1,114 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
//
// 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 NetworkBridgeFilter
/// </summary>
class NetworkBridgeFilterMarshaller : BaseDataStreamMarshaller
{
public override DataStructure CreateObject()
{
return new NetworkBridgeFilter();
}
public override byte GetDataStructureType()
{
return NetworkBridgeFilter.ID_NetworkBridgeFilter;
}
//
// Un-marshal an object instance from the data input stream
//
public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
{
base.TightUnmarshal(wireFormat, o, dataIn, bs);
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
info.NetworkTTL = dataIn.ReadInt32();
info.NetworkBrokerId = (BrokerId) TightUnmarshalCachedObject(wireFor
mat, dataIn, bs);
}
//
// Write the booleans that this object uses to a BooleanStream
//
public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.NetworkBrokerId, bs);
return rc + 4;
}
//
// Write a object instance to data output stream
//
public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
base.TightMarshal2(wireFormat, o, dataOut, bs);
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
dataOut.Write(info.NetworkTTL);
TightMarshalCachedObject2(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut, bs);
}
//
// Un-marshal an object instance from the data input stream
//
public overr
ide void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
{
base.LooseUnmarshal(wireFormat, o, dataIn);
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
info.NetworkTTL = dataIn.ReadInt32();
info.NetworkBrokerId = (BrokerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
base.LooseMarshal(wireFormat, o, dataOut);
dataOut.Write(info.NetworkTTL);
LooseMarshalCachedObject(wireFormat, (DataStructure)info.NetworkBrokerId, 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 System.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 NetworkBridgeFilter
+ /// </summary>
+ class NetworkBridgeFilterMarshaller : BaseDataStreamMarshaller
+ {
+
+
+ public override DataStructure CreateObject()
+ {
+ return new NetworkBridgeFilter();
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return NetworkBridgeFilter.ID_NetworkBridgeFilter;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+ info.NetworkTTL = dataIn.ReadInt32();
+ info.NetworkBrokerId = (BrokerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+
+ int rc = base.TightMarshal1(wireFormat, info, bs);
+ rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.NetworkBrokerId, bs);
+
+ return rc + 4;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+ dataOut.Write(info.NetworkTTL);
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut, bs);
+
+ }
+
+ //
+ // 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);
+
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+ info.NetworkTTL = dataIn.ReadInt32();
+ info.NetworkBrokerId = (BrokerId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ NetworkBridgeFilter info = (NetworkBridgeFilter)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.NetworkTTL);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut);
+
+ }
+ }
+}
Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/NetworkBridgeFilterMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native