Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 57046 invoked from network); 10 Jan 2006 19:30:49 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 10 Jan 2006 19:30:49 -0000 Received: (qmail 4767 invoked by uid 500); 10 Jan 2006 19:30:48 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 4748 invoked by uid 500); 10 Jan 2006 19:30:48 -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 4739 invoked by uid 99); 10 Jan 2006 19:30:48 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Jan 2006 11:30:48 -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; Tue, 10 Jan 2006 11:30:46 -0800 Received: (qmail 56542 invoked by uid 65534); 10 Jan 2006 19:30:26 -0000 Message-ID: <20060110193026.56535.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r367748 - in /incubator/activemq/trunk/openwire-dotnet: ./ src/OpenWire.Client/ src/OpenWire.Client/Commands/ tests/OpenWire.Client/ tests/OpenWire.Client/IO/ Date: Tue, 10 Jan 2006 19:30:23 -0000 To: activemq-commits@geronimo.apache.org From: jstrachan@apache.org X-Mailer: svnmailer-1.0.5 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Author: jstrachan Date: Tue Jan 10 11:30:13 2006 New Revision: 367748 URL: http://svn.apache.org/viewcvs?rev=367748&view=rev Log: added compiling (but not working) unit test case Added: incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/ClientTest.cs incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/IO/ incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/TestSupport.cs Modified: incubator/activemq/trunk/openwire-dotnet/OpenWire.build incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQBytesMessage.cs incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMapMessage.cs incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMessage.cs incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQObjectMessage.cs incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQStreamMessage.cs incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTextMessage.cs incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ConnectionFactory.cs incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ISession.cs incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Session.cs incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/OpenWire.Client.build Modified: incubator/activemq/trunk/openwire-dotnet/OpenWire.build URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/OpenWire.build?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/OpenWire.build (original) +++ incubator/activemq/trunk/openwire-dotnet/OpenWire.build Tue Jan 10 11:30:13 2006 @@ -163,7 +163,7 @@ - + Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQBytesMessage.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQBytesMessage.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQBytesMessage.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQBytesMessage.cs Tue Jan 10 11:30:13 2006 @@ -1,12 +1,3 @@ -// -// Marshalling code for Open Wire Format for ActiveMQBytesMessage -// -// -// 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; Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMapMessage.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMapMessage.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMapMessage.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMapMessage.cs Tue Jan 10 11:30:13 2006 @@ -1,12 +1,3 @@ -// -// Marshalling code for Open Wire Format for ActiveMQMapMessage -// -// -// 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; Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMessage.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMessage.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMessage.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMessage.cs Tue Jan 10 11:30:13 2006 @@ -1,12 +1,3 @@ -// -// Marshalling code for Open Wire Format for ActiveMQMessage -// -// -// 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; Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQObjectMessage.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQObjectMessage.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQObjectMessage.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQObjectMessage.cs Tue Jan 10 11:30:13 2006 @@ -1,12 +1,3 @@ -// -// Marshalling code for Open Wire Format for ActiveMQObjectMessage -// -// -// 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; Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQStreamMessage.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQStreamMessage.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQStreamMessage.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQStreamMessage.cs Tue Jan 10 11:30:13 2006 @@ -1,12 +1,3 @@ -// -// Marshalling code for Open Wire Format for ActiveMQStreamMessage -// -// -// 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; Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTextMessage.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTextMessage.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTextMessage.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTextMessage.cs Tue Jan 10 11:30:13 2006 @@ -1,12 +1,3 @@ -// -// Marshalling code for Open Wire Format for ActiveMQTextMessage -// -// -// 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; @@ -17,9 +8,14 @@ public class ActiveMQTextMessage : ActiveMQMessage, ITextMessage { public const byte ID_ActiveMQTextMessage = 28; - private String text; + public ActiveMQTextMessage() { + } + + public ActiveMQTextMessage(String text) { + this.text = text; + } // TODO generate Equals method // TODO generate GetHashCode method Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ConnectionFactory.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ConnectionFactory.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ConnectionFactory.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ConnectionFactory.cs Tue Jan 10 11:30:13 2006 @@ -14,6 +14,14 @@ private string password; private string clientId; + public ConnectionFactory() { + } + + public ConnectionFactory(string host, int port) { + this.host = host; + this.port = port; + } + public IConnection CreateConnection() { return CreateConnection(userName, password); } Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ISession.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ISession.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ISession.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ISession.cs Tue Jan 10 11:30:13 2006 @@ -39,6 +39,20 @@ /// ITopic GetTopic(string name); - + + /// + /// Creates a new message with an empty body + /// + IMessage CreateMessage(); + + /// + /// Creates a new text message with an empty body + /// + ITextMessage CreateTextMessage(); + + /// + /// Creates a new text message with the given body + /// + ITextMessage CreateTextMessage(string text); } } Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Session.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Session.cs?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Session.cs (original) +++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Session.cs Tue Jan 10 11:30:13 2006 @@ -50,11 +50,23 @@ } public IQueue GetQueue(string name) { - return new ActiveMQQueue(name); + return new ActiveMQQueue(name); } public ITopic GetTopic(string name) { return new ActiveMQTopic(name); + } + + public IMessage CreateMessage() { + return new ActiveMQMessage(); + } + + public ITextMessage CreateTextMessage() { + return new ActiveMQTextMessage(); + } + + public ITextMessage CreateTextMessage(string text) { + return new ActiveMQTextMessage(text); } // Implementation methods Added: incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/ClientTest.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/ClientTest.cs?rev=367748&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/ClientTest.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/ClientTest.cs Tue Jan 10 11:30:13 2006 @@ -0,0 +1,33 @@ +using System; +using System.IO; + +using NUnit.Framework; + +using OpenWire.Client; + +namespace OpenWire.Client { + + [ TestFixture ] + public class ClientTest : TestSupport { + + [ Test ] + public void SendAndSyncReceive() { + IConnectionFactory factory = new ConnectionFactory("localhost", 61616); + + using (IConnection connection = factory.CreateConnection()) { + ISession session = connection.CreateSession(); + IDestination destination = session.GetQueue("FOO.BAR"); + IMessageConsumer consumer = session.CreateConsumer(destination); + + IMessageProducer producer = session.CreateProducer(destination); + string expected = "Hello World!"; + ITextMessage request = session.CreateTextMessage(expected); + producer.Send(request); + + ITextMessage message = (ITextMessage) consumer.Receive(); + + Assert.AreEqual(expected, message.Text); + } + } + } +} Modified: incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/OpenWire.Client.build URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/OpenWire.Client.build?rev=367748&r1=367747&r2=367748&view=diff ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/OpenWire.Client.build (original) +++ incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/OpenWire.Client.build Tue Jan 10 11:30:13 2006 @@ -1,32 +1,40 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + Added: incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/TestSupport.cs URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/TestSupport.cs?rev=367748&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/TestSupport.cs (added) +++ incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/TestSupport.cs Tue Jan 10 11:30:13 2006 @@ -0,0 +1,13 @@ +using System; +using System.IO; + +using OpenWire.Client; + +namespace OpenWire.Client { + + /// + /// useful base class for test cases + /// + public abstract class TestSupport { + } +}