[rabbitmq-discuss] getting node.js to talk to scala over rabbitmq

Meredith Gregory lgreg.meredith at gmail.com
Tue Oct 25 00:50:07 BST 2011


Dear Rabbiters,

i'm running into a problem getting node.js to talk to scala over
rabbitmq. i'm using the node-amqp package with node.js. i installed it using
npm install amqp. i'm using the java client for rabbitmq 2.5.1 on the scala
side. i've successfully gotten scala to talk to scala and node.js to talk to
node.js. However, when i attempt to get node.js to talk to scala there
appears to be a disagreement regarding queue declaration. Thus, if i fire up
node.js first and look at the queue it creates with the rabbitmq management
plugin i see


node-simple-direct_queue<http://localhost:55672/mgmt/#/queues/%2F/node-simple-direct_queue>
ADIdle000


i then attempt to accomplish a connection from the scala side (with code
that works on scala-to-scala) and i see an exception when the code calls the
queueDeclare method.

            channel.exchangeDeclare( exQNameRoot, "direct" )
            //channel.queueDeclare(qname, true, false, false, null);
    channel.queueDeclare(qname, true, false, true, null); // <-- here we
throw an exception

java.io.IOException
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:107)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:131)
at com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:627)
at com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:59)
at
com.biosimilarity.lift.lib.AMQPBrokerScope$StdMonadicAMQPSndrRcvr.sender(AMQPMnd.scala:53)

Any help would be most welcome!

Best wishes,

--greg

-- 
L.G. Meredith
Managing Partner
Biosimilarity LLC
7329 39th Ave SW
Seattle, WA 98136

+1 206.650.3740

http://biosimilarity.blogspot.com
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20111024/2c84946a/attachment.htm>


More information about the rabbitmq-discuss mailing list