From activemq-commits-return-918-apmail-geronimo-activemq-commits-archive=geronimo.apache.org@geronimo.apache.org Sat Mar 04 08:15:03 2006 Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 94842 invoked from network); 4 Mar 2006 08:15:03 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 4 Mar 2006 08:15:03 -0000 Received: (qmail 29784 invoked by uid 500); 4 Mar 2006 08:15:49 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 29769 invoked by uid 500); 4 Mar 2006 08:15:49 -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 29760 invoked by uid 99); 4 Mar 2006 08:15:49 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 04 Mar 2006 00:15:49 -0800 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [209.237.227.194] (HELO minotaur.apache.org) (209.237.227.194) by apache.org (qpsmtpd/0.29) with SMTP; Sat, 04 Mar 2006 00:15:46 -0800 Received: (qmail 94781 invoked by uid 65534); 4 Mar 2006 08:14:38 -0000 Message-ID: <20060304081438.94780.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r383068 - /incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ Date: Sat, 04 Mar 2006 08:14:29 -0000 To: activemq-commits@geronimo.apache.org From: chirino@apache.org X-Mailer: svnmailer-1.0.7 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Author: chirino Date: Sat Mar 4 00:14:24 2006 New Revision: 383068 URL: http://svn.apache.org/viewcvs?rev=383068&view=rev Log: Get it to compile after refactor Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQBytesMessage Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQDestination Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQMapMessage Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQMessage Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQObjectMessage Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQQueue Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQStreamMessage Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQTempDestination Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQTempQueue Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQTempTopic Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQTextMessage Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ActiveMQTopic Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for BaseCommand Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for BrokerId Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for BrokerInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ConnectionError Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ConnectionId Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ConnectionInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ConsumerId Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ConsumerInfo @@ -60,6 +59,7 @@ info.Browser = bs.ReadBoolean(); info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); info.PrefetchSize = BaseDataStreamMarshaller.ReadInt(dataIn); + info.MaximumPendingMessageLimit = BaseDataStreamMarshaller.ReadInt(dataIn); info.DispatchAsync = bs.ReadBoolean(); info.Selector = TightUnmarshalString(dataIn, bs); info.SubcriptionName = TightUnmarshalString(dataIn, bs); @@ -94,7 +94,7 @@ rc += TightMarshalCachedObject1(wireFormat, info.ConsumerId, bs); bs.WriteBoolean(info.Browser); rc += TightMarshalCachedObject1(wireFormat, info.Destination, bs); - bs.WriteBoolean(info.DispatchAsync); + bs.WriteBoolean(info.DispatchAsync); rc += TightMarshalString1(info.Selector, bs); rc += TightMarshalString1(info.SubcriptionName, bs); bs.WriteBoolean(info.NoLocal); @@ -103,7 +103,7 @@ rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs); bs.WriteBoolean(info.NetworkSubscription); - return rc + 5; + return rc + 9; } // @@ -117,6 +117,7 @@ bs.ReadBoolean(); TightMarshalCachedObject2(wireFormat, info.Destination, dataOut, bs); BaseDataStreamMarshaller.WriteInt(info.PrefetchSize, dataOut); + BaseDataStreamMarshaller.WriteInt(info.MaximumPendingMessageLimit, dataOut); bs.ReadBoolean(); TightMarshalString2(info.Selector, dataOut, bs); TightMarshalString2(info.SubcriptionName, dataOut, bs); Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ControlCommand Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for DataArrayResponse Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for DataResponse Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -1,69 +1,68 @@ -// -// -// Copyright 2005-2006 The Apache Software Foundation -// -// Licensed 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. -// - -using System; -using System.Collections; -using System.IO; - -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; - -namespace OpenWire.Client.IO -{ - // - // Marshalling code for Open Wire Format for DataStructureSupport - // - // - // 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 - // - public abstract class DataStructureSupportMarshaller : 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) { - DataStructureSupport info = (DataStructureSupport)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); - - } - } -} +// +// +// Copyright 2005-2006 The Apache Software Foundation +// +// Licensed 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. +// + +using System; +using System.Collections; +using System.IO; + +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; + +namespace ActiveMQ.OpenWire.V1 +{ + // + // Marshalling code for Open Wire Format for DataStructureSupport + // + // + // 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 + // + public abstract class DataStructureSupportMarshaller : 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) { + DataStructureSupport info = (DataStructureSupport)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); + + } + } +} Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for DestinationInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for DiscoveryEvent Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ExceptionResponse Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for FlushCommand Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for IntegerResponse Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for JournalQueueAck Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for JournalTopicAck Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for JournalTrace Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for JournalTransaction Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for KeepAliveInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for LocalTransactionId Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs Sat Mar 4 00:14:24 2006 @@ -1,91 +1,90 @@ -// -// -// Copyright 2005-2006 The Apache Software Foundation -// -// Licensed 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. -// - -// Marshalling code for Open Wire Format for ExceptionResponse -// -// -// NOTE!: This file is autogenerated - do not modify! -// if you need to make a change, please see the Groovy scripts in the -// activemq-openwire module -// - -using System; -using System.Collections; -using System.IO; - -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; - -namespace OpenWire.Client.IO -{ - public class MarshallerFactory - { - public void configure(OpenWireFormat format) - { - - format.addMarshaller(new MessageIdMarshaller()); - format.addMarshaller(new BrokerInfoMarshaller()); - format.addMarshaller(new ActiveMQTempQueueMarshaller()); - format.addMarshaller(new LocalTransactionIdMarshaller()); - format.addMarshaller(new RemoveSubscriptionInfoMarshaller()); - format.addMarshaller(new IntegerResponseMarshaller()); - format.addMarshaller(new ActiveMQQueueMarshaller()); - format.addMarshaller(new DestinationInfoMarshaller()); - format.addMarshaller(new ActiveMQBytesMessageMarshaller()); - format.addMarshaller(new ShutdownInfoMarshaller()); - format.addMarshaller(new DataResponseMarshaller()); - format.addMarshaller(new SessionIdMarshaller()); - format.addMarshaller(new DataArrayResponseMarshaller()); - format.addMarshaller(new JournalQueueAckMarshaller()); - format.addMarshaller(new WireFormatInfoMarshaller()); - format.addMarshaller(new ResponseMarshaller()); - format.addMarshaller(new ConnectionErrorMarshaller()); - format.addMarshaller(new ActiveMQObjectMessageMarshaller()); - format.addMarshaller(new ConsumerInfoMarshaller()); - format.addMarshaller(new ActiveMQTempTopicMarshaller()); - format.addMarshaller(new ConnectionIdMarshaller()); - format.addMarshaller(new DiscoveryEventMarshaller()); - format.addMarshaller(new ConnectionInfoMarshaller()); - format.addMarshaller(new KeepAliveInfoMarshaller()); - format.addMarshaller(new XATransactionIdMarshaller()); - format.addMarshaller(new JournalTraceMarshaller()); - format.addMarshaller(new FlushCommandMarshaller()); - format.addMarshaller(new ConsumerIdMarshaller()); - format.addMarshaller(new JournalTopicAckMarshaller()); - format.addMarshaller(new ActiveMQTextMessageMarshaller()); - format.addMarshaller(new BrokerIdMarshaller()); - format.addMarshaller(new MessageDispatchMarshaller()); - format.addMarshaller(new ProducerInfoMarshaller()); - format.addMarshaller(new SubscriptionInfoMarshaller()); - format.addMarshaller(new ActiveMQMapMessageMarshaller()); - format.addMarshaller(new MessageDispatchNotificationMarshaller()); - format.addMarshaller(new SessionInfoMarshaller()); - format.addMarshaller(new ActiveMQMessageMarshaller()); - format.addMarshaller(new TransactionInfoMarshaller()); - format.addMarshaller(new ActiveMQStreamMessageMarshaller()); - format.addMarshaller(new MessageAckMarshaller()); - format.addMarshaller(new ProducerIdMarshaller()); - format.addMarshaller(new ActiveMQTopicMarshaller()); - format.addMarshaller(new JournalTransactionMarshaller()); - format.addMarshaller(new RemoveInfoMarshaller()); - format.addMarshaller(new ControlCommandMarshaller()); - format.addMarshaller(new ExceptionResponseMarshaller()); - } - } -} +// +// +// Copyright 2005-2006 The Apache Software Foundation +// +// Licensed 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. +// + +// Marshalling code for Open Wire Format for ExceptionResponse +// +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Groovy scripts in the +// activemq-openwire module +// + +using System; +using System.Collections; +using System.IO; + +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; + +namespace ActiveMQ.OpenWire.V1 +{ + public class MarshallerFactory + { + public void configure(OpenWireFormat format) + { + + format.addMarshaller(new MessageIdMarshaller()); + format.addMarshaller(new BrokerInfoMarshaller()); + format.addMarshaller(new ActiveMQTempQueueMarshaller()); + format.addMarshaller(new LocalTransactionIdMarshaller()); + format.addMarshaller(new RemoveSubscriptionInfoMarshaller()); + format.addMarshaller(new IntegerResponseMarshaller()); + format.addMarshaller(new ActiveMQQueueMarshaller()); + format.addMarshaller(new DestinationInfoMarshaller()); + format.addMarshaller(new ActiveMQBytesMessageMarshaller()); + format.addMarshaller(new ShutdownInfoMarshaller()); + format.addMarshaller(new DataResponseMarshaller()); + format.addMarshaller(new SessionIdMarshaller()); + format.addMarshaller(new DataArrayResponseMarshaller()); + format.addMarshaller(new JournalQueueAckMarshaller()); + format.addMarshaller(new WireFormatInfoMarshaller()); + format.addMarshaller(new ResponseMarshaller()); + format.addMarshaller(new ConnectionErrorMarshaller()); + format.addMarshaller(new ActiveMQObjectMessageMarshaller()); + format.addMarshaller(new ConsumerInfoMarshaller()); + format.addMarshaller(new ActiveMQTempTopicMarshaller()); + format.addMarshaller(new ConnectionIdMarshaller()); + format.addMarshaller(new DiscoveryEventMarshaller()); + format.addMarshaller(new ConnectionInfoMarshaller()); + format.addMarshaller(new KeepAliveInfoMarshaller()); + format.addMarshaller(new XATransactionIdMarshaller()); + format.addMarshaller(new JournalTraceMarshaller()); + format.addMarshaller(new FlushCommandMarshaller()); + format.addMarshaller(new ConsumerIdMarshaller()); + format.addMarshaller(new JournalTopicAckMarshaller()); + format.addMarshaller(new ActiveMQTextMessageMarshaller()); + format.addMarshaller(new BrokerIdMarshaller()); + format.addMarshaller(new MessageDispatchMarshaller()); + format.addMarshaller(new ProducerInfoMarshaller()); + format.addMarshaller(new SubscriptionInfoMarshaller()); + format.addMarshaller(new ActiveMQMapMessageMarshaller()); + format.addMarshaller(new MessageDispatchNotificationMarshaller()); + format.addMarshaller(new SessionInfoMarshaller()); + format.addMarshaller(new ActiveMQMessageMarshaller()); + format.addMarshaller(new TransactionInfoMarshaller()); + format.addMarshaller(new ActiveMQStreamMessageMarshaller()); + format.addMarshaller(new MessageAckMarshaller()); + format.addMarshaller(new ProducerIdMarshaller()); + format.addMarshaller(new ActiveMQTopicMarshaller()); + format.addMarshaller(new JournalTransactionMarshaller()); + format.addMarshaller(new RemoveInfoMarshaller()); + format.addMarshaller(new ControlCommandMarshaller()); + format.addMarshaller(new ExceptionResponseMarshaller()); + } + } +} Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for MessageAck Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for MessageDispatch Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -1,96 +1,95 @@ -// -// -// Copyright 2005-2006 The Apache Software Foundation -// -// Licensed 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. -// - -using System; -using System.Collections; -using System.IO; - -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; - -namespace OpenWire.Client.IO -{ - // - // Marshalling code for Open Wire Format for MessageDispatchNotification - // - // - // 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 - // - public 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, info.ConsumerId, bs); - rc += TightMarshalCachedObject1(wireFormat, info.Destination, bs); - rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs); - rc += TightMarshalNestedObject1(wireFormat, 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, info.ConsumerId, dataOut, bs); - TightMarshalCachedObject2(wireFormat, info.Destination, dataOut, bs); - TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs); - TightMarshalNestedObject2(wireFormat, info.MessageId, dataOut, bs); - - } - } -} +// +// +// Copyright 2005-2006 The Apache Software Foundation +// +// Licensed 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. +// + +using System; +using System.Collections; +using System.IO; + +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; + +namespace ActiveMQ.OpenWire.V1 +{ + // + // Marshalling code for Open Wire Format for MessageDispatchNotification + // + // + // 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 + // + public 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, info.ConsumerId, bs); + rc += TightMarshalCachedObject1(wireFormat, info.Destination, bs); + rc += TightMarshalLong1(wireFormat, info.DeliverySequenceId, bs); + rc += TightMarshalNestedObject1(wireFormat, 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, info.ConsumerId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, info.Destination, dataOut, bs); + TightMarshalLong2(wireFormat, info.DeliverySequenceId, dataOut, bs); + TightMarshalNestedObject2(wireFormat, info.MessageId, dataOut, bs); + + } + } +} Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for MessageId Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for Message Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ProducerId Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ProducerInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for RemoveInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for RemoveSubscriptionInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for Response Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for SessionId Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for SessionInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for ShutdownInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for SubscriptionInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for TransactionId Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for TransactionInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for WireFormatInfo Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs?rev=383068&r1=383067&r2=383068&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs Sat Mar 4 00:14:24 2006 @@ -19,12 +19,11 @@ using System.Collections; using System.IO; -using OpenWire.Client; -using OpenWire.Client.Commands; -using OpenWire.Client.Core; -using OpenWire.Client.IO; +using ActiveMQ.OpenWire; +using ActiveMQ.OpenWire.Commands; +using ActiveMQ.OpenWire.V1; -namespace OpenWire.Client.IO +namespace ActiveMQ.OpenWire.V1 { // // Marshalling code for Open Wire Format for XATransactionId