From commits-return-9371-apmail-activemq-commits-archive=activemq.apache.org@activemq.apache.org Fri Oct 17 17:22:58 2008 Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 16293 invoked from network); 17 Oct 2008 17:22:58 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 17 Oct 2008 17:22:58 -0000 Received: (qmail 97426 invoked by uid 500); 17 Oct 2008 17:22:59 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 97369 invoked by uid 500); 17 Oct 2008 17:22:59 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 97360 invoked by uid 99); 17 Oct 2008 17:22:59 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 17 Oct 2008 10:22:59 -0700 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 17 Oct 2008 17:21:50 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 5816323888A0; Fri, 17 Oct 2008 10:22:28 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r705677 [1/9] - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0: ./ deploy/ deploy/mono-2.0/ deploy/net-1.1/ deploy/net-2.0/ deploy/net-3.5/ lib/ src/main/csharp/ src/main/csharp/Transport/Tcp/ src/test/csharp/ vendor/ Date: Fri, 17 Oct 2008 17:22:25 -0000 To: commits@activemq.apache.org From: jgomes@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20081017172228.5816323888A0@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: jgomes Date: Fri Oct 17 10:22:23 2008 New Revision: 705677 URL: http://svn.apache.org/viewvc?rev=705677&view=rev Log: Refactor to use NMS assemblies instead of direct project compilation. Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.dll (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.xml activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.dll (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.xml activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/LICENSE.txt activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/NOTICE.txt activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/nmsprovider-activemq.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/nmsprovider-stomp.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/nmsprovider-tcp.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/nmsprovider-test.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/Apache.NMS.ActiveMQ.Test.dll (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/Apache.NMS.ActiveMQ.Test.pdb (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/Apache.NMS.ActiveMQ.Test.xml activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/Apache.NMS.ActiveMQ.dll (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/Apache.NMS.ActiveMQ.pdb (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/Apache.NMS.ActiveMQ.xml activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/LICENSE.txt activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/NOTICE.txt activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/nmsprovider-activemq.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/nmsprovider-stomp.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/nmsprovider-tcp.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-1.1/nmsprovider-test.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/Apache.NMS.ActiveMQ.Test.dll (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/Apache.NMS.ActiveMQ.Test.pdb (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/Apache.NMS.ActiveMQ.Test.xml activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/Apache.NMS.ActiveMQ.dll (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/Apache.NMS.ActiveMQ.pdb (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/Apache.NMS.ActiveMQ.xml activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/LICENSE.txt activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/NOTICE.txt activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/nmsprovider-activemq.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/nmsprovider-stomp.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/nmsprovider-tcp.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-2.0/nmsprovider-test.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/Apache.NMS.ActiveMQ.Test.dll (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/Apache.NMS.ActiveMQ.Test.pdb (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/Apache.NMS.ActiveMQ.Test.xml activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/Apache.NMS.ActiveMQ.dll (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/Apache.NMS.ActiveMQ.pdb (with props) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/Apache.NMS.ActiveMQ.xml activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/LICENSE.txt activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/NOTICE.txt activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/nmsprovider-activemq.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/nmsprovider-stomp.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/nmsprovider-tcp.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/net-3.5/nmsprovider-test.config activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/lib/ (props changed) - copied from r705419, activemq/activemq-dotnet/Apache.NMS/tags/1.0.0/lib/ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/nant-common.xml Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/nant.build activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/src/main/csharp/CommonAssemblyInfo.cs activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/src/main/csharp/Transport/Tcp/TcpTransportFactory.cs activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/src/test/csharp/CommonAssemblyInfo.cs activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/vendor/ (props changed) activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/vs2008-activemq-test.csproj activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/vs2008-activemq.csproj activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/vs2008-activemq.sln Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.dll URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.dll?rev=705677&view=auto ============================================================================== Binary file - no diff available. Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.dll ------------------------------------------------------------------------------ svn:mime-type = application/octet-stream Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.xml URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.xml?rev=705677&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.xml (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.Test.xml Fri Oct 17 10:22:23 2008 @@ -0,0 +1,8 @@ + + + + C:\Src\ActiveMQ\activemq-dotnet\Apache.NMS.ActiveMQ\tags\1.0.0\build\mono-2.0\release\Apache.NMS.ActiveMQ.Test + + + + Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.dll URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.dll?rev=705677&view=auto ============================================================================== Binary file - no diff available. Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.dll ------------------------------------------------------------------------------ svn:mime-type = application/octet-stream Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.xml URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.xml?rev=705677&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.xml (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/tags/1.0.0/deploy/mono-2.0/Apache.NMS.ActiveMQ.xml Fri Oct 17 10:22:23 2008 @@ -0,0 +1,1703 @@ + + + + C:\Src\ActiveMQ\activemq-dotnet\Apache.NMS.ActiveMQ\tags\1.0.0\build\mono-2.0\release\Apache.NMS.ActiveMQ + + + + + Summary description for ActiveMQDestination. + + + + * The Default Constructor + + * Construct the Destination with a defined physical name; + * + * @param name + + * Topic Destination object + + * Temporary Topic Destination object + + * Queue Destination object + + * Temporary Queue Destination object + + * prefix for Advisory message destinations + + * prefix for consumer advisory destinations + + * prefix for producer advisory destinations + + * prefix for connection advisory destinations + + * The default target for ordered destinations + + + Dictionary of name/value pairs representing option values specified + in the URI used to create this Destination. A null value is returned + if no options were specified. + + + + * Returns true if this destination represents a collection of + * destinations; allowing a set of destinations to be published to or subscribed + * from in one NMS operation. + *

+ * If this destination is a composite then you can call {@link #getChildDestinations()} + * to return the list of child destinations. + * + * @return true if this destination represents a collection of child destinations. + + * @return Returns the advisory. + + * @param advisory The advisory to set. + + * @return true if this is a destination for Consumer advisories + + * @return true if this is a destination for Producer advisories + + * @return true if this is a destination for Connection advisories + + * @return Returns the exclusive. + + * @param exclusive The exclusive to set. + + * @return Returns the ordered. + + * @param ordered The ordered to set. + + * @return Returns the orderedTarget. + + * @param orderedTarget The orderedTarget to set. + + * A helper method to return a descriptive string for the topic or queue + * @param destination + * + * @return a descriptive string for this queue or topic + + * @param destination + + * Create a Destination + * @param type + * @param pyhsicalName + * @return + + * Create a temporary name from the clientId + * + * @param clientId + * @return + + * From a temporary destination find the clientId of the Connection that created it + * + * @param destination + * @return the clientId or null if not a temporary destination + + * @param o object to compare + * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o + + * Lets sort by name first then lets sort topics greater than queues + * + * @param that another destination to compare against + * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o + + * @return Returns the Destination type + + * @return string representation of this instance + + * @return hashCode for this instance + + * if the object passed in is equivalent, return true + * + * @param obj the object to compare + * @return true if this instance and obj are equivalent + + * @return true if the destination matches multiple possible destinations + + * Factory method to create a child destination if this destination is a composite + * @param name + * @return the created Destination + +

+ The correlation ID used to correlate messages with conversations or long running business processes + + + + + The destination of the message + + + + + The time in milliseconds that this message should expire in + + + + + The message ID which is set by the provider + + + + + Whether or not this message is persistent + + + + + The Priority on this message + + + + + Returns true if this message has been redelivered to this or another consumer before being acknowledged successfully. + + + + + The destination that the consumer of this message should send replies to + + + + + The timestamp the broker added to the message + + + + + The type name of this message + + + + + Returns the number of times this message has been redelivered to other consumers without being acknowledged successfully. + + + + + The Message Group ID used to group messages together to the same consumer for the same group ID value + + + + + The Message Group Sequence counter to indicate the position in a group + + + + + Returns the ID of the producers transaction + + + + + Summary description for ActiveMQQueue. + + + + + Method GetDestinationType + + An int + + + + Method CreateDestination + + An ActiveMQDestination + A String + + + + A Temporary Queue + + + + + A Temporary Topic + + + + + Summary description for ActiveMQTopic. + + + + + Base class for all DataStructure implementations + + + + + Represents an exception on the broker + + + + + The ActiveMQ BrokerId Command + + + + + The ActiveMQ BrokerInfo Command + + + + + An OpenWire command + + + + + The ActiveMQ ConnectionControl Command + + + + + The ActiveMQ ConnectionError Command + + + + + The ActiveMQ ConnectionId Command + + + + + The ActiveMQ ConnectionInfo Command + + + + + The ActiveMQ ConsumerControl Command + + + + + The ActiveMQ ConsumerId Command + + + + + The ActiveMQ ConsumerInfo Command + + + + + The ActiveMQ ControlCommand Command + + + + + The ActiveMQ DataArrayResponse Command + + + + + The ActiveMQ DataResponse Command + + + + + An OpenWire command + + + + + Summary description for DataStructureSupport. + + + + + The ActiveMQ DestinationInfo Command + + + + + The ActiveMQ DiscoveryEvent Command + + + + + The ActiveMQ ExceptionResponse Command + + + + + The ActiveMQ FlushCommand Command + + + + + The ActiveMQ IntegerResponse Command + + + + + The ActiveMQ JournalQueueAck Command + + + + + The ActiveMQ JournalTopicAck Command + + + + + The ActiveMQ JournalTrace Command + + + + + The ActiveMQ JournalTransaction Command + + + + + The ActiveMQ KeepAliveInfo Command + + + + + The ActiveMQ LastPartialCommand Command + + + + + The ActiveMQ LocalTransactionId Command + + + + + Represents a marshallable entity + + + + + The ActiveMQ Message Command + + + + + The ActiveMQ MessageAck Command + + + + + The ActiveMQ MessageDispatch Command + + + + + The ActiveMQ MessageDispatchNotification Command + + + + + The ActiveMQ MessageId Command + + + + + The ActiveMQ MessagePull Command + + + + + The ActiveMQ NetworkBridgeFilter Command + + + + + The ActiveMQ PartialCommand Command + + + + + The ActiveMQ ProducerId Command + + + + + The ActiveMQ ProducerInfo Command + + + + + The ActiveMQ RemoveInfo Command + + + + + The ActiveMQ RemoveSubscriptionInfo Command + + + + + The ActiveMQ ReplayCommand Command + + + + + The ActiveMQ Response Command + + + + + The ActiveMQ SessionId Command + + + + + The ActiveMQ SessionInfo Command + + + + + The ActiveMQ ShutdownInfo Command + + + + + The ActiveMQ SubscriptionInfo Command + + + + + The ActiveMQ TransactionId Command + + + + + The ActiveMQ TransactionInfo Command + + + + + The ActiveMQ XATransactionId Command + + + + + Marshalling code for Open Wire Format for ActiveMQBytesMessage + + + + + Marshalling code for Open Wire Format for ActiveMQDestination + + + + + Marshalling code for Open Wire Format for ActiveMQMapMessage + + + + + Marshalling code for Open Wire Format for ActiveMQMessage + + + + + Marshalling code for Open Wire Format for ActiveMQObjectMessage + + + + + Marshalling code for Open Wire Format for ActiveMQQueue + + + + + Marshalling code for Open Wire Format for ActiveMQStreamMessage + + + + + Marshalling code for Open Wire Format for ActiveMQTempDestination + + + + + Marshalling code for Open Wire Format for ActiveMQTempQueue + + + + + Marshalling code for Open Wire Format for ActiveMQTempTopic + + + + + Marshalling code for Open Wire Format for ActiveMQTextMessage + + + + + Marshalling code for Open Wire Format for ActiveMQTopic + + + + + Marshalling code for Open Wire Format for BaseCommand + + + + + Marshalling code for Open Wire Format for BrokerId + + + + + Marshalling code for Open Wire Format for BrokerInfo + + + + + Marshalling code for Open Wire Format for ConnectionControl + + + + + Marshalling code for Open Wire Format for ConnectionError + + + + + Marshalling code for Open Wire Format for ConnectionId + + + + + Marshalling code for Open Wire Format for ConnectionInfo + + + + + Marshalling code for Open Wire Format for ConsumerControl + + + + + Marshalling code for Open Wire Format for ConsumerId + + + + + Marshalling code for Open Wire Format for ConsumerInfo + + + + + Marshalling code for Open Wire Format for ControlCommand + + + + + Marshalling code for Open Wire Format for DataArrayResponse + + + + + Marshalling code for Open Wire Format for DataResponse + + + + + Marshalling code for Open Wire Format for DestinationInfo + + + + + Marshalling code for Open Wire Format for DiscoveryEvent + + + + + Marshalling code for Open Wire Format for ExceptionResponse + + + + + Marshalling code for Open Wire Format for FlushCommand + + + + + Marshalling code for Open Wire Format for IntegerResponse + + + + + Marshalling code for Open Wire Format for JournalQueueAck + + + + + Marshalling code for Open Wire Format for JournalTopicAck + + + + + Marshalling code for Open Wire Format for JournalTrace + + + + + Marshalling code for Open Wire Format for JournalTransaction + + + + + Marshalling code for Open Wire Format for KeepAliveInfo + + + + + Marshalling code for Open Wire Format for LastPartialCommand + + + + + Marshalling code for Open Wire Format for LocalTransactionId + + + + + Used to create marshallers for a specific version of the wire protocol + + + + + Marshalling code for Open Wire Format for MessageAck + + + + + Marshalling code for Open Wire Format for MessageDispatch + + + + + Marshalling code for Open Wire Format for MessageDispatchNotification + + + + + Marshalling code for Open Wire Format for MessageId + + + + + Marshalling code for Open Wire Format for Message + + + + + Marshalling code for Open Wire Format for NetworkBridgeFilter + + + + + Marshalling code for Open Wire Format for PartialCommand + + + + + Marshalling code for Open Wire Format for ProducerId + + + + + Marshalling code for Open Wire Format for ProducerInfo + + + + + Marshalling code for Open Wire Format for RemoveInfo + + + + + Marshalling code for Open Wire Format for RemoveSubscriptionInfo + + + + + Marshalling code for Open Wire Format for ReplayCommand + + + + + Marshalling code for Open Wire Format for Response + + + + + Marshalling code for Open Wire Format for SessionId + + + + + Marshalling code for Open Wire Format for SessionInfo + + + + + Marshalling code for Open Wire Format for ShutdownInfo + + + + + Marshalling code for Open Wire Format for SubscriptionInfo + + + + + Marshalling code for Open Wire Format for TransactionId + + + + + Marshalling code for Open Wire Format for TransactionInfo + + + + + Marshalling code for Open Wire Format for WireFormatInfo + + + + + Marshalling code for Open Wire Format for XATransactionId + + + + + Marshalling code for Open Wire Format for ActiveMQBytesMessage + + + + + Marshalling code for Open Wire Format for ActiveMQDestination + + + + + Marshalling code for Open Wire Format for ActiveMQMapMessage + + + + + Marshalling code for Open Wire Format for ActiveMQMessage + + + + + Marshalling code for Open Wire Format for ActiveMQObjectMessage + + + + + Marshalling code for Open Wire Format for ActiveMQQueue + + + + + Marshalling code for Open Wire Format for ActiveMQStreamMessage + + + + + Marshalling code for Open Wire Format for ActiveMQTempDestination + + + + + Marshalling code for Open Wire Format for ActiveMQTempQueue + + + + + Marshalling code for Open Wire Format for ActiveMQTempTopic + + + + + Marshalling code for Open Wire Format for ActiveMQTextMessage + + + + + Marshalling code for Open Wire Format for ActiveMQTopic + + + + + Marshalling code for Open Wire Format for BaseCommand + + + + + Marshalling code for Open Wire Format for BrokerId + + + + + Marshalling code for Open Wire Format for BrokerInfo + + + + + Marshalling code for Open Wire Format for ConnectionControl + + + + + Marshalling code for Open Wire Format for ConnectionError + + + + + Marshalling code for Open Wire Format for ConnectionId + + + + + Marshalling code for Open Wire Format for ConnectionInfo + + + + + Marshalling code for Open Wire Format for ConsumerControl + + + + + Marshalling code for Open Wire Format for ConsumerId + + + + + Marshalling code for Open Wire Format for ConsumerInfo + + + + + Marshalling code for Open Wire Format for ControlCommand + + + + + Marshalling code for Open Wire Format for DataArrayResponse + + + + + Marshalling code for Open Wire Format for DataResponse + + + + + Marshalling code for Open Wire Format for DestinationInfo + + + + + Marshalling code for Open Wire Format for DiscoveryEvent + + + + + Marshalling code for Open Wire Format for ExceptionResponse + + + + + Marshalling code for Open Wire Format for FlushCommand + + + + + Marshalling code for Open Wire Format for IntegerResponse + + + + + Marshalling code for Open Wire Format for JournalQueueAck + + + + + Marshalling code for Open Wire Format for JournalTopicAck + + + + + Marshalling code for Open Wire Format for JournalTrace + + + + + Marshalling code for Open Wire Format for JournalTransaction + + + + + Marshalling code for Open Wire Format for KeepAliveInfo + + + + + Marshalling code for Open Wire Format for LastPartialCommand + + + + + Marshalling code for Open Wire Format for LocalTransactionId + + + + + Used to create marshallers for a specific version of the wire protocol + + + + + Marshalling code for Open Wire Format for MessageAck + + + + + Marshalling code for Open Wire Format for MessageDispatch + + + + + Marshalling code for Open Wire Format for MessageDispatchNotification + + + + + Marshalling code for Open Wire Format for MessageId + + + + + Marshalling code for Open Wire Format for Message + + + + + Marshalling code for Open Wire Format for MessagePull + + + + + Marshalling code for Open Wire Format for NetworkBridgeFilter + + + + + Marshalling code for Open Wire Format for PartialCommand + + + + + Marshalling code for Open Wire Format for ProducerId + + + + + Marshalling code for Open Wire Format for ProducerInfo + + + + + Marshalling code for Open Wire Format for RemoveInfo + + + + + Marshalling code for Open Wire Format for RemoveSubscriptionInfo + + + + + Marshalling code for Open Wire Format for ReplayCommand + + + + + Marshalling code for Open Wire Format for Response + + + + + Marshalling code for Open Wire Format for SessionId + + + + + Marshalling code for Open Wire Format for SessionInfo + + + + + Marshalling code for Open Wire Format for ShutdownInfo + + + + + Marshalling code for Open Wire Format for SubscriptionInfo + + + + + Marshalling code for Open Wire Format for TransactionId + + + + + Marshalling code for Open Wire Format for TransactionInfo + + + + + Marshalling code for Open Wire Format for WireFormatInfo + + + + + Marshalling code for Open Wire Format for XATransactionId + + + + + A base class with useful implementation inheritence methods + for creating marshallers of the OpenWire protocol + + + + + Converts the object to a String + + + + + Converts the object to a String + + + + + Converts the given transaction ID into a String + + + + + Creates the byte array into hexidecimal + + + + + Represents a stream of boolean flags + + + + + Support class that switches from one endian to the other. + + + + + A BinaryWriter that switches the endian orientation of the read opperations so that they + are compatible with marshalling used by OpenWire. + + + + + Method Read + + An int + A char[] + An int + An int + + + + Method ReadChars + + A char[] + An int + + + + Method ReadInt16 + + A short + + + + Method ReadChar + + A char + + + + Method ReadInt64 + + A long + + + + Method ReadUInt64 + + An ulong + + + + Method ReadUInt32 + + An uint + + + + Method ReadUInt16 + + An ushort + + + + Method ReadInt32 + + An int + + + + Method ReadString + + A string + + + + A BinaryWriter that switches the endian orientation of the write opperations so that they + are compatible with marshalling used by OpenWire. + + + + + Method Write + + A long + + + + Method Write + + An ushort + + + + Method Write + + An int + + + + Method Write + + A char[] + An int + An int + + + + Method Write + + A char[] + + + + Method Write + + An uint + + + + Method Write + + A char + + + + Method Write + + An ulong + + + + Method Write + + A short + + + + Method Write + + A string + + + + Method Write + + A double + + + + Method Write + + A double + + + + Implements the OpenWire protocol. + + + + + A default implementation of IPrimitiveMap + + + + + Method ToString + + A string + + + + Unmarshalls the map from the given data or if the data is null just + return an empty map + + + + + Marshals the primitive type map to a byte array + + + + + Unmarshals the primitive type map from the given byte array + + + + + A Stream for writing a STOMP Frame + + + + + Some STOMP protocol conversion helper methods. + + + + + Implements the STOMP protocol. + + + + + An implementation of ITransport that uses sockets to communicate with the broker + + + + + Property IsStarted + + + + + Property RequestTimeout + + + + + Method Start + + + + + Size in bytes of the receive buffer. + + + + + Size in bytes of send buffer. + + + + + The time-out value, in milliseconds. The default value is 0, which indicates + an infinite time-out period. Specifying -1 also indicates an infinite time-out period. + + + + + The time-out value, in milliseconds. If you set the property with a value between 1 and 499, + the value will be changed to 500. The default value is 0, which indicates an infinite + time-out period. Specifying -1 also indicates an infinite time-out period. + + + + + Handles asynchronous responses + + + + + Represents the logical networking transport layer. + + + + + Represents the marshalling of commands to and from an IO stream + + + + + Marshalls the given command object onto the stream + + + + + Unmarshalls the next command object from the stream + + + + + A Transport filter that is used to log the commands sent and received. + + + + + A Transport which guards access to the next transport using a mutex. + + + + + A Transport that correlates asynchronous send/receive messages into single request/response. + + + + + Used to implement a filter on the transport layer. + + + + + Property RequestTimeout + + + + + Property IsStarted + + + + + Method Oneway + + A Command + + + + Method AsyncRequest + + A FutureResponse + A Command + + + + Method Request + + A Response + A Command + + + + Method Request with time out for Response. + + A Response + A Command + Timeout in milliseconds + + + + Method Start + + + + + Method Dispose + + + + + A Transport which negotiates the wire format + + + + + Exception thrown when the broker returns an error + + + + + Generates a nice textual stack trace + + + + + Represents a connection with a message broker + + + + + This property indicates whether or not async send is enabled. + + + + + This property indicates whether or not async close is enabled. + When the connection is closed, it will either send a synchronous + DisposeOf command to the broker and wait for confirmation (if true), + or it will send the DisposeOf command asynchronously. + + + + + This property sets the acknowledgment mode for the connection. + The URI parameter connection.ackmode can be set to a string value + that maps to the enumeration value. + + + + + This property determines if the asynchronous message delivery of incoming + messages has been started for this connection. + + + + + Starts asynchronous message delivery of incoming messages for this connection. + Synchronous delivery is unaffected. + + + + + Temporarily stop asynchronous delivery of inbound messages for this connection. + The sending of outbound messages is unaffected. + + + + + Creates a new session to work on this connection + + + + + Creates a new session to work on this connection + + + + + Performs a synchronous request-response with the broker + + + + + Creates a new temporary destination name + + + + + Creates a new local transaction ID + + + + + Handle incoming commands + + An ITransport + A Command + + + + Exception thrown when a connection is used that it already closed + + + + + Represents a connection with a message broker + + + + + Exception thrown when a consumer is used that it already closed + + + + + Summary description for DestinationFilter. + + + + + Handles the multi-threaded dispatching between the transport and the consumers + + + + + Whem we start a transaction we must redeliver any rolled back messages + + + + + Redeliver the given message, putting it at the head of the queue + + + + + Method Enqueue + + + + + Method DequeueNoWait + + + + + Method Dequeue + + + + + Method Dequeue + + + + + Called before a commit + + + + + Called after a commit + + + + + Called after a transaction rollback + + + + + An object capable of receiving messages from some destination + + + + + Method Dispatch + + An ActiveMQMessage + + + + Dispatch any pending messages to the asynchronous listener + + + + + An object capable of sending messages to some destination + + + + + Default provider of ISession + + + + + Sets the prefetch size, the maximum number of messages a broker will dispatch to consumers + until acknowledgements are received. + + + + + Sets the maximum number of messages to keep around per consumer + in addition to the prefetch window for non-durable topics until messages + will start to be evicted for slow consumers. + Must be > 0 to enable this feature + + + + + Enables or disables whether asynchronous dispatch should be used by the broker + + + + + Enables or disables exclusive consumers when using queues. An exclusive consumer means + only one instance of a consumer is allowed to process messages on a queue to preserve order + + + + + Enables or disables retroactive mode for consumers; i.e. do they go back in time or not? + + + + + Sets the default consumer priority for consumers + + + + + This property indicates whether or not async send is enabled. + + + + + Ensures that a transaction is started + + + + + Private method called by the dispatcher thread in order to perform + asynchronous delivery of queued (inbound) messages. + + + + + Returns a copy of the current consumers in a thread safe way to avoid concurrency + problems if the consumers are changed in another thread + + + + + Returns a copy of the current consumers in a thread safe way to avoid concurrency + problems if the consumers are changed in another thread + + + + + Configures the message command + + + + + Method AddSynchronization + + + +