Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 70013 invoked from network); 10 Aug 2006 19:53:23 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 10 Aug 2006 19:53:23 -0000 Received: (qmail 54355 invoked by uid 500); 10 Aug 2006 19:53:23 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 54338 invoked by uid 500); 10 Aug 2006 19:53:23 -0000 Mailing-List: contact activemq-commits-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 54303 invoked by uid 99); 10 Aug 2006 19:53:23 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 10 Aug 2006 12:53:23 -0700 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: local policy) Received: from [140.211.166.113] (HELO eris.apache.org) (140.211.166.113) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 10 Aug 2006 12:53:15 -0700 Received: by eris.apache.org (Postfix, from userid 65534) id 222BC1A9823; Thu, 10 Aug 2006 12:52:49 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r430504 [4/13] - in /incubator/activemq/trunk: activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ openwire-c/src/libopenwire/ openwire-cpp/src/main/cpp/activemq/command/ openwire-cpp/src... Date: Thu, 10 Aug 2006 19:52:05 -0000 To: activemq-commits@geronimo.apache.org From: jstrachan@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20060810195249.222BC1A9823@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ReplayCommandMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ReplayCommandMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ReplayCommandMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ReplayCommandMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for ReplayCommand /// class ReplayCommandMarshaller : BaseCommandMarshaller { public override DataStructure CreateObject() { return new ReplayCommand(); } 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 BooleanStre am // public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) { ReplayCommand info = (ReplayCommand)o; int rc = base.TightMarshal1(wireFormat, info, 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); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ResponseMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ResponseMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ResponseMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ResponseMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for Response /// class ResponseMarshaller : BaseCommandMarshaller { public override DataStructure CreateObject() { return new Response(); } 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) { Response info = (Response)o; int rc = base.TightMarshal1(wireFormat, info, 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) { Re sponse info = (Response)o; base.LooseMarshal(wireFormat, o, dataOut); dataOut.Write(info.CorrelationId); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SessionIdMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SessionIdMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SessionIdMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SessionIdMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for SessionId /// class SessionIdMarshaller : BaseDataStreamMarshaller { public override DataStructure CreateObject() { return new SessionId(); } 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 BooleanS tream // public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) { SessionId info = (SessionId)o; int rc = base.TightMarshal1(wireFormat, info, 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(wire Format, 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); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SessionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SessionInfoMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SessionInfoMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SessionInfoMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for SessionInfo /// class SessionInfoMarshaller : BaseCommandMarshaller { public override DataStructure CreateObject() { return new SessionInfo(); } 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 ove rride int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) { SessionInfo info = (SessionInfo)o; int rc = base.TightMarshal1(wireFormat, info, 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.Session Id = (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); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ShutdownInfoMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ShutdownInfoMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ShutdownInfoMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ShutdownInfoMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for ShutdownInfo /// class ShutdownInfoMarshaller : BaseCommandMarshaller { public override DataStructure CreateObject() { return new ShutdownInfo(); } 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) { ShutdownInfo info = (ShutdownInfo)o; int rc = base.TightMarshal1(wireFormat, info, 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); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SubscriptionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SubscriptionInfoMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SubscriptionInfoMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/SubscriptionInfoMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for SubscriptionInfo /// class SubscriptionInfoMarshaller : BaseDataStreamMarshaller { public override DataStructure CreateObject() { return new SubscriptionInfo(); } 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); } // // 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, info, bs); rc += TightMarshalString1(info.ClientId, bs); rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); rc += TightMarshalString1(info.Selector, bs); rc += TightMarshalString1(info.SubcriptionName, 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); } // // 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); } // // Write a object instance to data output stream // public override void LooseMarshal(OpenWireFormat wi reFormat, 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); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionIdMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionIdMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionIdMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionIdMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for TransactionId /// 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) { TransactionId info = (TransactionId)o; int rc = base.TightMarshal1(wireFormat, info, bs); return rc + 0; } // // Write a object instance to data output stream // public override void TightMar shal2(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); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionInfoMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionInfoMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionInfoMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for TransactionInfo /// class TransactionInfoMarshaller : BaseCommandMarshaller { public override DataStructure CreateObject() { return new TransactionInfo(); } 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) TightUnmarshalCachedObje ct(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, info, 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); TightMarshalCache dObject2(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); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/WireFormatInfoMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/WireFormatInfoMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/WireFormatInfoMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/WireFormatInfoMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for WireFormatInfo /// class WireFormatInfoMarshaller : BaseDataStreamMarshaller { public override DataStructure CreateObject() { return new WireFormatInfo(); } 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.MarshalledProper ties = 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, info, 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.ReadB oolean()) { 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(wireF ormat); 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); } } } \ No newline at end of file Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/XATransactionIdMarshaller.cs URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/XATransactionIdMarshaller.cs?rev=430504&view=auto ============================================================================== --- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/XATransactionIdMarshaller.cs (added) +++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/XATransactionIdMarshaller.cs Thu Aug 10 12:51:56 2006 @@ -0,0 +1 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Colle ctions; using System.IO; using ActiveMQ.Commands; using ActiveMQ.OpenWire; using ActiveMQ.OpenWire.V2; namespace ActiveMQ.OpenWire.V2 { /// /// Marshalling code for Open Wire Format for XATransactionId /// class XATransactionIdMarshaller : TransactionIdMarshaller { public override DataStructure CreateObject() { return new XATransactionId(); } 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(dataI n, 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, info, 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; bas e.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); } } } } \ No newline at end of file