Connecting to RabbitMQ using Qpid Messaging API and .NET using AMQP 1.0

[m4tthall]

Hi,

So I am pretty new to all this but this is what I have done so far:

* Installed the AMQP 1.0 plugin on RabbitMQ
* Got someone else to build me org.apache.qpid.messaging.dll
* Created a test client in .NET that attempts to send a message to RabbitMQ
using the org.apache.qpid.messaging reference

The results are:

* App hangs (as in sits there doing nothing) on connection.Open()
* RabbitMQ log shows the following corresponding entries

accepting AMQP connection <0.1096.0> ([::1]:62242 -> [::1]:5672)
closing AMQP connection <0.1096.0> ([::1]:62242 -> [::1]:5672):
{bad_version,{1,1,0,10}}

I have spent a fair bit of time trying to investigate this and the only
thing I can find is that bad_version might be due to using AMQP 0-10 rather
than AMQP 1.0 as RabbitMQ only supports 0-9-1 or 1.0 via the plugin.

So, I have a couple of questions:

* Have I setup something incorrectly?
* Do I need to specify something on the Qpid client to force it to use AMQP
1.0?

Here is a snippet of the code in case that provides any clues

String host = "localhost:5672";
String addr = "amq.direct/key";
Int32 nMsg = 10;

Console.WriteLine("csharp.direct.sender");
Console.WriteLine("host : {0}", host);
Console.WriteLine("addr : {0}", addr);
Console.WriteLine("nMsg : {0}", nMsg);
Console.WriteLine();

Connection connection = null;
try
{
   connection = new Connection(host);
   connection.Open(); <--- FAILS HERE, NO EXCEPTION BEING CAUGHT
   if (!connection.IsOpen) {
      Console.WriteLine("Failed to open connection to host : {0}", host);
   } else {
      Session session = connection.CreateSession();
      Sender sender = session.CreateSender(addr);
      for (int i = 0; i < nMsg; i++) {
         Message message = new Message(String.Format("Test Message {0}",
i));
         sender.Send(message);
      }
      session.Sync();
      connection.Close();
      return;
   }
} catch (Exception e) {
   Console.WriteLine("Exception {0}.", e);
   if (null != connection)
      connection.Close();
}

Thanks in advance for any help



--
View this message in context: 
http://qpid.2158936.n2.nabble.com/Connecting-to-RabbitMQ-using-Qpid-Messaging-API-and-NET-using-AMQP-1-0-tp7603069.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.

---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org
For additional commands, e-mail: users-h...@qpid.apache.org