Mailing-List: contact users-help@qpid.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@qpid.apache.org
Received-SPF: pass (athena.apache.org: domain of nekresh@gmail.com designates
 209.85.210.42 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:from:date:message-id:subject:to:content-type;
        b=cw5R42rNRKoNsOVCBdLmMfEyYcTEUGvrygDMvjsioPuAAGJeW4aGjNAoSXaGPnHZgY
         /wCA4PQYmGTzsY8Bl/wJCugIJdC3L7q0kRzGht7SWSPS0gTm1VeFJ63ft1UB01AL7Xb5
         bYKeT+HFKHAjK1D0CyS17Dj7uldn2icnn/JlI=
MIME-Version: 1.0
From: nekresh <nekresh@gmail.com>
Date: Wed, 11 Aug 2010 00:24:03 +0200
Message-ID: <AANLkTin_FnKTtC_nHsYpan1kCLwnJ=nSqo3qnkAeK+H-@mail.gmail.com>
Subject: C# client on qpid 0.6
To: users@qpid.apache.org
Content-Type: text/plain; charset=ISO-8859-1

Hello everyone.

I'm currently testing qpid 0.6 and have a few problems.

I've first tried the Messaging API.
On the C++ 0.6 broker, it simply doesn't work. Well, it's in the
documentation (http://qpid.apache.org/compatibility.html) so I won't
try more that way.
I then tried the Java 0.6 broker but wasn't able to receive message at
all. Even in debug trace, the message are received by the broker and
forwarded to the right queue but I never receive them.
Am I missing something ?
I'm creating the queue, binding it to the exchange amq.direct with the
correct routing_key.

static void Main(string[] args)
{
   Console.WriteLine("Init");

   var info = new QpidConnectionInfo();
   info.AddBrokerInfo(new AmqBrokerInfo("tcp", "localhost", 5672, false));
   info.Username = "guest";
   info.Password = "guest";

   using (var connection = new AMQConnection(info))
   {
       using (var ch = connection.CreateChannel(false,
Apache.Qpid.Messaging.AcknowledgeMode.PreAcknowledge))
       {
           ch.DeclareQueue("message_queue", true, false, false);
           ch.Bind("message_queue", "amq.direct", "test");

           var builder = ch.CreateConsumerBuilder("message_queue");
           using (var consumer = builder.Create())
           {
               Console.WriteLine("Ready");

               while (true)
               {
                   var message = consumer.Receive();
                   //var message = consumer.Receive(10000);
                   if (message != null)
                   {
                       Console.WriteLine("message received");
                   }
               }
           }
       }
   }
}

Then I tried the 0-10 API on the Java broker, but have strange behavior.
I can send and receive messages, but the messages are kept in the
queue. I receive the message only once but, when I restart my
consumer, then message are sent back to me.
As they aren't removed from the queue, I guess the queue will become
filled up very fast and stop working.

static void Main(string[] args)
{
   Console.WriteLine("Init");

   var client = new Client();
   client.Connect("localhost", 5672, "", "guest", "guest");
   var ch = client.CreateSession(10000);

   ch.QueueDeclare("message_queue", Option.DURABLE);
   ch.ExchangeBind("message_queue", "amq.direct", "test");

   ch.AttachMessageListener(new Listener(), "message_queue");
   ch.MessageSubscribe("message_queue");

   Console.WriteLine("Press enter to exit");
   Console.ReadLine();
   Console.WriteLine("Stopping");
   ch.Close();
   client.Close();
}

With a class Listener displaying the message received.
I haven't found a way to acknoledge received message in the 0-10 API,
only the listener way.
How is it possible to ack received message ?

In the list archive, I've found a message regarding which API
implementation to choose and the Messaging one was preferred. Do you
think it still applies now ?

Thanks for reading my (too) long message.

Nekresh

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org