Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,127 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for RemoveSubscriptionInfo + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for RemoveSubscriptionInfo + /// </summary> + class RemoveSubscriptionInfoMarshaller : BaseCommandMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new RemoveSubscriptionInfo(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return RemoveSubscriptionInfo.ID_REMOVESUBSCRIPTIONINFO; + } + + // + // 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); + + RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o; + info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.SubcriptionName = TightUnmarshalString(dataIn, bs); + info.ClientId = TightUnmarshalString(dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs); + rc += TightMarshalString1(info.SubcriptionName, bs); + rc += TightMarshalString1(info.ClientId, 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); + + RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs); + TightMarshalString2(info.SubcriptionName, dataOut, bs); + TightMarshalString2(info.ClientId, 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); + + RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o; + info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.SubcriptionName = LooseUnmarshalString(dataIn); + info.ClientId = LooseUnmarshalString(dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut); + LooseMarshalString(info.SubcriptionName, dataOut); + LooseMarshalString(info.ClientId, dataOut); + } + } +}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,119 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for ReplayCommand + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for ReplayCommand + /// </summary> + class ReplayCommandMarshaller : BaseCommandMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new ReplayCommand(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return ReplayCommand.ID_REPLAYCOMMAND; + } + + // + // 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); + + ReplayCommand info = (ReplayCommand)o; + info.FirstNakNumber = dataIn.ReadInt32(); + info.LastNakNumber = dataIn.ReadInt32(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + + int rc = base.TightMarshal1(wireFormat, o, bs); + + return rc + 8; + } + + // + // 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); + + ReplayCommand info = (ReplayCommand)o; + dataOut.Write(info.FirstNakNumber); + dataOut.Write(info.LastNakNumber); + } + + // + // 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); + + ReplayCommand info = (ReplayCommand)o; + info.FirstNakNumber = dataIn.ReadInt32(); + info.LastNakNumber = dataIn.ReadInt32(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ReplayCommand info = (ReplayCommand)o; + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.FirstNakNumber); + dataOut.Write(info.LastNakNumber); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for Response + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for Response + /// </summary> + class ResponseMarshaller : BaseCommandMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new Response(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return Response.ID_RESPONSE; + } + + // + // 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); + + Response info = (Response)o; + info.CorrelationId = dataIn.ReadInt32(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + + int rc = base.TightMarshal1(wireFormat, o, bs); + + return rc + 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); + + Response info = (Response)o; + dataOut.Write(info.CorrelationId); + } + + // + // 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); + + Response info = (Response)o; + info.CorrelationId = dataIn.ReadInt32(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + Response info = (Response)o; + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.CorrelationId); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for SessionId + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for SessionId + /// </summary> + class SessionIdMarshaller : BaseDataStreamMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new SessionId(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return SessionId.ID_SESSIONID; + } + + // + // 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); + + SessionId info = (SessionId)o; + info.ConnectionId = TightUnmarshalString(dataIn, bs); + info.Value = TightUnmarshalLong(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + SessionId info = (SessionId)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalString1(info.ConnectionId, bs); + rc += TightMarshalLong1(wireFormat, info.Value, bs); + + return rc + 0; + } + + // + // Write a object instance to data output stream + // + public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) + { + base.TightMarshal2(wireFormat, o, dataOut, bs); + + SessionId info = (SessionId)o; + TightMarshalString2(info.ConnectionId, dataOut, bs); + TightMarshalLong2(wireFormat, info.Value, dataOut, bs); + } + + // + // Un-marshal an object instance from the data input stream + // + public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn) + { + base.LooseUnmarshal(wireFormat, o, dataIn); + + SessionId info = (SessionId)o; + info.ConnectionId = LooseUnmarshalString(dataIn); + info.Value = LooseUnmarshalLong(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + SessionId info = (SessionId)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalString(info.ConnectionId, dataOut); + LooseMarshalLong(wireFormat, info.Value, dataOut); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for SessionInfo + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for SessionInfo + /// </summary> + class SessionInfoMarshaller : BaseCommandMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new SessionInfo(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return SessionInfo.ID_SESSIONINFO; + } + + // + // 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); + + SessionInfo info = (SessionInfo)o; + info.SessionId = (SessionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + SessionInfo info = (SessionInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.SessionId, 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); + + SessionInfo info = (SessionInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.SessionId, 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); + + SessionInfo info = (SessionInfo)o; + info.SessionId = (SessionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + SessionInfo info = (SessionInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.SessionId, dataOut); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,103 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for ShutdownInfo + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for ShutdownInfo + /// </summary> + class ShutdownInfoMarshaller : BaseCommandMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new ShutdownInfo(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return ShutdownInfo.ID_SHUTDOWNINFO; + } + + // + // Un-marshal an object instance from the data input stream + // + public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) + { + base.TightUnmarshal(wireFormat, o, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + + int rc = base.TightMarshal1(wireFormat, o, bs); + + return rc + 0; + } + + // + // Write a object instance to data output stream + // + public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) + { + base.TightMarshal2(wireFormat, o, dataOut, bs); + } + + // + // Un-marshal an object instance from the data input stream + // + public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn) + { + base.LooseUnmarshal(wireFormat, o, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + base.LooseMarshal(wireFormat, o, dataOut); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,137 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for SubscriptionInfo + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for SubscriptionInfo + /// </summary> + class SubscriptionInfoMarshaller : BaseDataStreamMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new SubscriptionInfo(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return SubscriptionInfo.ID_SUBSCRIPTIONINFO; + } + + // + // 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); + + SubscriptionInfo info = (SubscriptionInfo)o; + info.ClientId = TightUnmarshalString(dataIn, bs); + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Selector = TightUnmarshalString(dataIn, bs); + info.SubcriptionName = TightUnmarshalString(dataIn, bs); + info.SubscribedDestination = (ActiveMQDestination) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + SubscriptionInfo info = (SubscriptionInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalString1(info.ClientId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalString1(info.Selector, bs); + rc += TightMarshalString1(info.SubcriptionName, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.SubscribedDestination, 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); + + SubscriptionInfo info = (SubscriptionInfo)o; + TightMarshalString2(info.ClientId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalString2(info.Selector, dataOut, bs); + TightMarshalString2(info.SubcriptionName, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.SubscribedDestination, 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); + + SubscriptionInfo info = (SubscriptionInfo)o; + info.ClientId = LooseUnmarshalString(dataIn); + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Selector = LooseUnmarshalString(dataIn); + info.SubcriptionName = LooseUnmarshalString(dataIn); + info.SubscribedDestination = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + SubscriptionInfo info = (SubscriptionInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalString(info.ClientId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalString(info.Selector, dataOut); + LooseMarshalString(info.SubcriptionName, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.SubscribedDestination, dataOut); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for TransactionId + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for TransactionId + /// </summary> + abstract class TransactionIdMarshaller : BaseDataStreamMarshaller + { + + // + // Un-marshal an object instance from the data input stream + // + public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) + { + base.TightUnmarshal(wireFormat, o, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + + int rc = base.TightMarshal1(wireFormat, o, bs); + + return rc + 0; + } + + // + // Write a object instance to data output stream + // + public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) + { + base.TightMarshal2(wireFormat, o, dataOut, bs); + } + + // + // Un-marshal an object instance from the data input stream + // + public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn) + { + base.LooseUnmarshal(wireFormat, o, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + base.LooseMarshal(wireFormat, o, dataOut); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for TransactionInfo + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for TransactionInfo + /// </summary> + class TransactionInfoMarshaller : BaseCommandMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new TransactionInfo(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return TransactionInfo.ID_TRANSACTIONINFO; + } + + // + // 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); + + TransactionInfo info = (TransactionInfo)o; + info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Type = dataIn.ReadByte(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + TransactionInfo info = (TransactionInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs); + + return rc + 1; + } + + // + // 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); + + TransactionInfo info = (TransactionInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs); + dataOut.Write(info.Type); + } + + // + // 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); + + TransactionInfo info = (TransactionInfo)o; + info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Type = dataIn.ReadByte(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + TransactionInfo info = (TransactionInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut); + dataOut.Write(info.Type); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for WireFormatInfo + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for WireFormatInfo + /// </summary> + class WireFormatInfoMarshaller : BaseDataStreamMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new WireFormatInfo(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return WireFormatInfo.ID_WIREFORMATINFO; + } + + // + // 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); + + WireFormatInfo info = (WireFormatInfo)o; + + info.BeforeUnmarshall(wireFormat); + + info.Magic = ReadBytes(dataIn, 8); + info.Version = dataIn.ReadInt32(); + info.MarshalledProperties = ReadBytes(dataIn, bs.ReadBoolean()); + + info.AfterUnmarshall(wireFormat); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + WireFormatInfo info = (WireFormatInfo)o; + + info.BeforeMarshall(wireFormat); + + int rc = base.TightMarshal1(wireFormat, o, bs); + bs.WriteBoolean(info.MarshalledProperties!=null); + rc += info.MarshalledProperties==null ? 0 : info.MarshalledProperties.Length+4; + + return rc + 12; + } + + // + // 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); + + WireFormatInfo info = (WireFormatInfo)o; + dataOut.Write(info.Magic, 0, 8); + dataOut.Write(info.Version); + if(bs.ReadBoolean()) { + dataOut.Write(info.MarshalledProperties.Length); + dataOut.Write(info.MarshalledProperties); + } + + info.AfterMarshall(wireFormat); + } + + // + // 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); + + WireFormatInfo info = (WireFormatInfo)o; + + info.BeforeUnmarshall(wireFormat); + + info.Magic = ReadBytes(dataIn, 8); + info.Version = dataIn.ReadInt32(); + info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean()); + + info.AfterUnmarshall(wireFormat); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + WireFormatInfo info = (WireFormatInfo)o; + + info.BeforeMarshall(wireFormat); + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.Magic, 0, 8); + dataOut.Write(info.Version); + dataOut.Write(info.MarshalledProperties!=null); + if(info.MarshalledProperties!=null) { + dataOut.Write(info.MarshalledProperties.Length); + dataOut.Write(info.MarshalledProperties); + } + + info.AfterMarshall(wireFormat); + } + } +} Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs?rev=799407&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs Thu Jul 30 19:06:34 2009 @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for XATransactionId + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V5; + +namespace Apache.NMS.ActiveMQ.OpenWire.V5 +{ + /// <summary> + /// Marshalling code for Open Wire Format for XATransactionId + /// </summary> + class XATransactionIdMarshaller : TransactionIdMarshaller + { + /// <summery> + /// Creates an instance of the Object that this marshaller handles. + /// </summery> + public override DataStructure CreateObject() + { + return new XATransactionId(); + } + + /// <summery> + /// Returns the type code for the Object that this Marshaller handles.. + /// </summery> + public override byte GetDataStructureType() + { + return XATransactionId.ID_XATRANSACTIONID; + } + + // + // 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); + + XATransactionId info = (XATransactionId)o; + info.FormatId = dataIn.ReadInt32(); + info.GlobalTransactionId = ReadBytes(dataIn, bs.ReadBoolean()); + info.BranchQualifier = ReadBytes(dataIn, bs.ReadBoolean()); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + XATransactionId info = (XATransactionId)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + bs.WriteBoolean(info.GlobalTransactionId!=null); + rc += info.GlobalTransactionId==null ? 0 : info.GlobalTransactionId.Length+4; + bs.WriteBoolean(info.BranchQualifier!=null); + rc += info.BranchQualifier==null ? 0 : info.BranchQualifier.Length+4; + + 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); + + XATransactionId info = (XATransactionId)o; + dataOut.Write(info.FormatId); + if(bs.ReadBoolean()) { + dataOut.Write(info.GlobalTransactionId.Length); + dataOut.Write(info.GlobalTransactionId); + } + if(bs.ReadBoolean()) { + dataOut.Write(info.BranchQualifier.Length); + dataOut.Write(info.BranchQualifier); + } + } + + // + // 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); + + XATransactionId info = (XATransactionId)o; + info.FormatId = dataIn.ReadInt32(); + info.GlobalTransactionId = ReadBytes(dataIn, dataIn.ReadBoolean()); + info.BranchQualifier = ReadBytes(dataIn, dataIn.ReadBoolean()); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + XATransactionId info = (XATransactionId)o; + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.FormatId); + dataOut.Write(info.GlobalTransactionId!=null); + if(info.GlobalTransactionId!=null) { + dataOut.Write(info.GlobalTransactionId.Length); + dataOut.Write(info.GlobalTransactionId); + } + dataOut.Write(info.BranchQualifier!=null); + if(info.BranchQualifier!=null) { + dataOut.Write(info.BranchQualifier.Length); + dataOut.Write(info.BranchQualifier); + } + } + } +}
