From activemq-commits-return-928-apmail-geronimo-activemq-commits-archive=geronimo.apache.org@geronimo.apache.org Sun Mar 05 08:30:27 2006 Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 86761 invoked from network); 5 Mar 2006 08:30:25 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 5 Mar 2006 08:30:25 -0000 Received: (qmail 97676 invoked by uid 500); 5 Mar 2006 08:31:11 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 97578 invoked by uid 500); 5 Mar 2006 08:31:10 -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 97496 invoked by uid 99); 5 Mar 2006 08:31:09 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 05 Mar 2006 00:31:09 -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; Sun, 05 Mar 2006 00:31:04 -0800 Received: (qmail 86612 invoked by uid 65534); 5 Mar 2006 08:29:56 -0000 Message-ID: <20060305082956.86611.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r383295 [3/4] - in /incubator/activemq/trunk/openwire-dotnet: src/ src/ActiveMQ/ src/ActiveMQ/Commands/ src/ActiveMQ/OpenWire/ src/ActiveMQ/OpenWire/Commands/ src/ActiveMQ/OpenWire/V1/ src/ActiveMQ/Transport/ src/JMS/ tests/ tests/ActiveMQ/... Date: Sun, 05 Mar 2006 08:29:09 -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 Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs?rev=383295&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs Sun Mar 5 00:28:53 2006 @@ -0,0 +1,79 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* 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 ActiveMQ.OpenWire; +using ActiveMQ.Commands; + +namespace ActiveMQ.Commands +{ + // + // Marshalling code for Open Wire Format for TransactionInfo + // + // + // 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 TransactionInfo : BaseCommand + { + public const byte ID_TransactionInfo = 7; + + ConnectionId connectionId; + TransactionId transactionId; + byte type; + + public override string ToString() { + return GetType().Name + "[" + + " ConnectionId=" + ConnectionId + + " TransactionId=" + TransactionId + + " Type=" + Type + + " ]"; + + } + + + + public override byte GetDataStructureType() { + return ID_TransactionInfo; + } + + + // Properties + + public ConnectionId ConnectionId + { + get { return connectionId; } + set { this.connectionId = value; } + } + + public TransactionId TransactionId + { + get { return transactionId; } + set { this.transactionId = value; } + } + + public byte Type + { + get { return type; } + set { this.type = value; } + } + + } +} Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs?rev=383295&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs Sun Mar 5 00:28:53 2006 @@ -0,0 +1,111 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* 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 ActiveMQ.OpenWire; +using ActiveMQ.Commands; + +namespace ActiveMQ.Commands +{ + // + // Marshalling code for Open Wire Format for WireFormatInfo + // + // + // 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 WireFormatInfo : AbstractCommand + { + public const byte ID_WireFormatInfo = 1; + + byte[] magic; + int version; + bool cacheEnabled; + bool stackTraceEnabled; + bool tcpNoDelayEnabled; + bool prefixPacketSize; + bool tightEncodingEnabled; + + public override string ToString() { + return GetType().Name + "[" + + " Magic=" + Magic + + " Version=" + Version + + " CacheEnabled=" + CacheEnabled + + " StackTraceEnabled=" + StackTraceEnabled + + " TcpNoDelayEnabled=" + TcpNoDelayEnabled + + " PrefixPacketSize=" + PrefixPacketSize + + " TightEncodingEnabled=" + TightEncodingEnabled + + " ]"; + + } + + + + public override byte GetDataStructureType() { + return ID_WireFormatInfo; + } + + + // Properties + + public byte[] Magic + { + get { return magic; } + set { this.magic = value; } + } + + public int Version + { + get { return version; } + set { this.version = value; } + } + + public bool CacheEnabled + { + get { return cacheEnabled; } + set { this.cacheEnabled = value; } + } + + public bool StackTraceEnabled + { + get { return stackTraceEnabled; } + set { this.stackTraceEnabled = value; } + } + + public bool TcpNoDelayEnabled + { + get { return tcpNoDelayEnabled; } + set { this.tcpNoDelayEnabled = value; } + } + + public bool PrefixPacketSize + { + get { return prefixPacketSize; } + set { this.prefixPacketSize = value; } + } + + public bool TightEncodingEnabled + { + get { return tightEncodingEnabled; } + set { this.tightEncodingEnabled = value; } + } + + } +} Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs?rev=383295&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs Sun Mar 5 00:28:53 2006 @@ -0,0 +1,105 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* 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 ActiveMQ.OpenWire; +using ActiveMQ.Commands; + +namespace ActiveMQ.Commands +{ + // + // Marshalling code for Open Wire Format for XATransactionId + // + // + // 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 XATransactionId : TransactionId + { + public const byte ID_XATransactionId = 112; + + int formatId; + byte[] globalTransactionId; + byte[] branchQualifier; + + public override int GetHashCode() { + int answer = 0; + answer = (answer * 37) + HashCode(FormatId); + answer = (answer * 37) + HashCode(GlobalTransactionId); + answer = (answer * 37) + HashCode(BranchQualifier); + return answer; + + } + + + public override bool Equals(object that) { + if (that is XATransactionId) { + return Equals((XATransactionId) that); + } + return false; + } + + public virtual bool Equals(XATransactionId that) { + if (! Equals(this.FormatId, that.FormatId)) return false; + if (! Equals(this.GlobalTransactionId, that.GlobalTransactionId)) return false; + if (! Equals(this.BranchQualifier, that.BranchQualifier)) return false; + return true; + + } + + + public override string ToString() { + return GetType().Name + "[" + + " FormatId=" + FormatId + + " GlobalTransactionId=" + GlobalTransactionId + + " BranchQualifier=" + BranchQualifier + + " ]"; + + } + + + + public override byte GetDataStructureType() { + return ID_XATransactionId; + } + + + // Properties + + public int FormatId + { + get { return formatId; } + set { this.formatId = value; } + } + + public byte[] GlobalTransactionId + { + get { return globalTransactionId; } + set { this.globalTransactionId = value; } + } + + public byte[] BranchQualifier + { + get { return branchQualifier; } + set { this.branchQualifier = value; } + } + + } +} Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs Sun Mar 5 00:28:53 2006 @@ -1,9 +1,9 @@ +using ActiveMQ.Commands; +using ActiveMQ.OpenWire; +using ActiveMQ.Transport; +using JMS; using System; using System.Collections; -using System.Threading; - -using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs Sun Mar 5 00:28:53 2006 @@ -18,7 +18,6 @@ using System.Collections; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs Sun Mar 5 00:28:53 2006 @@ -14,11 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; +using ActiveMQ.Transport; +using JMS; using System; -using System.Collections; - -using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs Sun Mar 5 00:28:53 2006 @@ -18,7 +18,6 @@ using System.Collections; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs Sun Mar 5 00:28:53 2006 @@ -14,10 +14,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; using System; - -using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs Sun Mar 5 00:28:53 2006 @@ -14,12 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -using System; -using System.Collections; -using System.Threading; - +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; +using JMS; +using System.Threading; namespace ActiveMQ { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs Sun Mar 5 00:28:53 2006 @@ -14,10 +14,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -using System; - -using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; +using ActiveMQ.Commands; +using JMS; namespace ActiveMQ { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs Sun Mar 5 00:28:53 2006 @@ -14,9 +14,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; using System; -using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ.OpenWire { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs Sun Mar 5 00:28:53 2006 @@ -14,14 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; using System; +using System.Collections; using System.IO; -using System.Net; using System.Text; -using System.Collections; - -using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ.OpenWire Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs Sun Mar 5 00:28:53 2006 @@ -18,7 +18,6 @@ using System.IO; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ.OpenWire Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs Sun Mar 5 00:28:53 2006 @@ -17,7 +17,6 @@ using System; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ.OpenWire { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs Sun Mar 5 00:28:53 2006 @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -using System.Collections; +using ActiveMQ.Commands; +using JMS; using System; +using System.Collections; using System.Threading; - -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ.OpenWire { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs Sun Mar 5 00:28:53 2006 @@ -14,10 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; using System; using System.Threading; - -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ.OpenWire { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs Sun Mar 5 00:28:53 2006 @@ -14,10 +14,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -using System; +using ActiveMQ.Commands; using System.Collections; - -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ.OpenWire { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs Sun Mar 5 00:28:53 2006 @@ -14,11 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; +using ActiveMQ.OpenWire.V1; using System; using System.IO; - -using ActiveMQ.OpenWire.Commands; -using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire { Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs Sun Mar 5 00:28:53 2006 @@ -14,6 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using JMS; using System; using System.Collections; 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -20,7 +20,6 @@ using System.IO; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -1,90 +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 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()); - } - } -} +// +// +// 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.Commands; +using ActiveMQ.OpenWire; +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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 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=383295&r1=383294&r2=383295&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 Sun Mar 5 00:28:53 2006 @@ -19,8 +19,8 @@ using System.Collections; using System.IO; +using ActiveMQ.Commands; using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; using ActiveMQ.OpenWire.V1; namespace ActiveMQ.OpenWire.V1 Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs?rev=383295&r1=383294&r2=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs Sun Mar 5 00:28:53 2006 @@ -14,11 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; +using JMS; using System; using System.Collections; - -using ActiveMQ.OpenWire; -using ActiveMQ.OpenWire.Commands; namespace ActiveMQ { Copied: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs (from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/TransactionContext.cs) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs&p1=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/TransactionContext.cs&r1=383283&r2=383295&rev=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/TransactionContext.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs Sun Mar 5 00:28:53 2006 @@ -14,25 +14,29 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; +using ActiveMQ.OpenWire; using System.Collections; -using System; -using ActiveMQ.OpenWire.Commands; -namespace ActiveMQ.OpenWire +namespace ActiveMQ { - public enum TransactionType + public enum TransactionType { Begin = 0, Prepare = 1, CommitOnePhase = 2, CommitTwoPhase = 3, Rollback = 4, Recover=5, Forget = 6, End = 7 } - - public class TransactionContext +} + +namespace ActiveMQ +{ + public class TransactionContext { private TransactionId transactionId; private Session session; private ArrayList synchronizations = new ArrayList(); - public TransactionContext(Session session) { + public TransactionContext(Session session) + { this.session = session; } @@ -78,7 +82,8 @@ session.Connection.OneWay(info); } - foreach (ISynchronization synchronization in synchronizations) { + foreach (ISynchronization synchronization in synchronizations) + { synchronization.AfterRollback(); } synchronizations.Clear(); @@ -86,7 +91,8 @@ public void Commit() { - foreach (ISynchronization synchronization in synchronizations) { + foreach (ISynchronization synchronization in synchronizations) + { synchronization.BeforeCommit(); } @@ -101,10 +107,12 @@ session.Connection.OneWay(info); } - foreach (ISynchronization synchronization in synchronizations) { + foreach (ISynchronization synchronization in synchronizations) + { synchronization.AfterCommit(); } synchronizations.Clear(); } } } + Copied: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs (from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/ITransport.cs) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs&p1=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/ITransport.cs&r1=383283&r2=383295&rev=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/ITransport.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs Sun Mar 5 00:28:53 2006 @@ -14,20 +14,28 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; +using ActiveMQ.OpenWire; +using JMS; using System; -using ActiveMQ.OpenWire.Commands; -namespace ActiveMQ.OpenWire + +namespace ActiveMQ.Transport +{ + public delegate void CommandHandler(ITransport sender, Command command); +} +namespace ActiveMQ.Transport { - - public delegate void CommandHandler(ITransport sender, Command command); - public delegate void ExceptionHandler(ITransport sender, Exception command); - - /// - /// Represents the logical networking transport layer. - /// - public interface ITransport : IStartable, IDisposable + public delegate void ExceptionHandler(ITransport sender, Exception command); +} + +/// +/// Represents the logical networking transport layer. +/// +namespace ActiveMQ.Transport +{ + public interface ITransport : IStartable, IDisposable { void Oneway(Command command); @@ -39,3 +47,4 @@ event ExceptionHandler Exception; } } + Copied: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs (from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/SocketTransport.cs) URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs&p1=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/SocketTransport.cs&r1=383283&r2=383295&rev=383295&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/SocketTransport.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs Sun Mar 5 00:28:53 2006 @@ -14,23 +14,23 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +using ActiveMQ.Commands; +using ActiveMQ.OpenWire; using System; using System.Collections; using System.IO; using System.Net; using System.Net.Sockets; -using System.Text; using System.Threading; -using ActiveMQ.OpenWire.Commands; -namespace ActiveMQ.OpenWire + +/// +/// An implementation of ITransport that uses sockets to communicate with the broker +/// +namespace ActiveMQ.Transport { - - /// - /// An implementation of ITransport that uses sockets to communicate with the broker - /// - public class SocketTransport : ITransport + public class SocketTransport : ITransport { private readonly object transmissionLock = new object(); private Socket socket; @@ -222,4 +222,5 @@ } } } + Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs?rev=383295&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs Sun Mar 5 00:28:53 2006 @@ -0,0 +1,35 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * 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 JMS; + + +/// +/// Represents a binary based message +/// +namespace JMS +{ + public interface IBytesMessage : IMessage + { + + byte[] Content + { + get; + set; + } + } +} + Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs?rev=383295&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs Sun Mar 5 00:28:53 2006 @@ -0,0 +1,61 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * 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 JMS; +using System; + +namespace JMS +{ + public enum AcknowledgementMode + { + Unknown, AutoAcknowledge, ClientAcknowledge, Transactional + } + + /// + /// Represents a connection with a message broker + /// + public interface IConnection : IDisposable, IStartable, IStoppable + { + + /// + /// Creates a new session to work on this connection + /// + ISession CreateSession(); + + /// + /// Creates a new session to work on this connection + /// + ISession CreateSession(AcknowledgementMode acknowledgementMode); + + + // Properties + + AcknowledgementMode AcknowledgementMode + { + get; + set; + } + + String ClientId + { + get; + set; + } + + + } +} + Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs?rev=383295&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs Sun Mar 5 00:28:53 2006 @@ -0,0 +1,40 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * 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 JMS; + + + +/// +/// A Factory of IConnection objects +/// +namespace JMS +{ + public interface IConnectionFactory + { + + /// + /// Creates a new connection + /// + IConnection CreateConnection(); + + /// + /// Creates a new connection with the given user name and password + /// + IConnection CreateConnection(string userName, string password); + } +} + Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs?rev=383295&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs Sun Mar 5 00:28:53 2006 @@ -0,0 +1,29 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * 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. + */ + + + +/// +/// Summary description for Destination. +/// +namespace JMS +{ + public interface IDestination + { + } +} + Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs?rev=383295&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs Sun Mar 5 00:28:53 2006 @@ -0,0 +1,35 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * 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 JMS; + + +/// +/// Represents a Map message which contains key and value pairs which are +/// of primitive types +/// +namespace JMS +{ + public interface IMapMessage : IMessage + { + IPrimitiveMap Body + { + get; + } + } +} + +