[rabbitmq-discuss] Working with Java Client

[Ram Muthiah]

Hi Paul,

I am not running the client in the same machine as the server. I installed rabbitmq in our server. I am testing the PC clients that communicate with rabbitmq server. I left the username and password as it is, so their values are still "guest". However, the hostname is changed, so I am not able to use TestMain out of the box. The documentation should clearly state that runjava.bat com.rabbitmq.examples.TestMain would work only if the broker is installed in the same machine as the client. 

Going to the "stuck" part of my development effort -- I have the following code that is supposed to connect the consumer to the broker. 

package rabbitmq;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;

public class SimpleConsumer {
    public static void main(String[] args) {
        try {
            String hostName = (args.length > 0) ? args[0] : "dev.rabbitmq.com";
            int portNumber = (args.length > 1) ? Integer.parseInt(args[1]) : AMQP.PROTOCOL.PORT;
            String queueName = (args.length > 2) ? args[2] : "SimpleQueue";

            ConnectionFactory connFactory = new ConnectionFactory();
            Connection conn = connFactory.newConnection(hostName, portNumber);

            final Channel ch = conn.createChannel();

            ch.queueDeclare(queueName);

            QueueingConsumer consumer = new QueueingConsumer(ch);
            ch.basicConsume(queueName, consumer);
            while (true) {
                QueueingConsumer.Delivery delivery = consumer.nextDelivery();
                System.out.println("Message: " + new String(delivery.getBody()));
                ch.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
            }
        } catch (Exception ex) {
            System.err.println("Main thread caught exception: " + ex);
            ex.printStackTrace();
            System.exit(1);
        }
    }
}

When I run the above code, I get the following error message: 

Main thread caught exception: java.io.IOException
java.io.IOException
        at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:121)
        at com.rabbitmq.client.impl.AMQConnection.open(AMQConnection.java:363)
        at com.rabbitmq.client.impl.AMQConnection.<init>(AMQConnection.java:208)
        at com.rabbitmq.client.impl.AMQConnection.<init>(AMQConnection.java:178)
        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:165)
        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:213)
        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:227)
        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:238)
        at rabbitmq.SimpleConsumer.main(SimpleConsumer.java:48)
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.lang.NoClassDefFoundError: org/apache/commons/io/input/ProxyInputStream
        at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:599)
        at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:465)
Caused by: java.lang.NoClassDefFoundError: org/apache/commons/io/input/ProxyInputStream
        at java.lang.ClassLoader.defineClass1(Native Method)
        at java.lang.ClassLoader.defineClass(ClassLoader.java:621)
        at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:124)
        at java.net.URLClassLoader.defineClass(URLClassLoader.java:260)
        at java.net.URLClassLoader.access$000(URLClassLoader.java:56)
        at java.net.URLClassLoader$1.run(URLClassLoader.java:195)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(URLClassLoader.java:188)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
        at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320)
        at com.rabbitmq.client.impl.MethodArgumentReader.<init>(MethodArgumentReader.java:70)
        at com.rabbitmq.client.impl.AMQImpl.readMethodFrom(AMQImpl.java:5710)
        at com.rabbitmq.client.impl.AMQCommand$Assembler.handleFrame(AMQCommand.java:275)
        at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:107)
        at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:439)
Caused by: java.lang.ClassNotFoundException: org.apache.commons.io.input.ProxyInputStream
        at java.net.URLClassLoader$1.run(URLClassLoader.java:200)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(URLClassLoader.java:188)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
        at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320)


What I am looking for is complete working example of java code for the client. Simple example like just connecting to the broker and receiving the message (on the consumer side) from the producer. 

Thanks
Ram





________________________________
From: Paul Jones <pauljones23 at gmail.com>
To: Ram Muthiah <ram.muthiah at yahoo.com>
Cc: rabbitmq-discuss at lists.rabbitmq.com
Sent: Thursday, August 20, 2009 11:07:42 AM
Subject: Re: [rabbitmq-discuss] Working with Java Client

Ram,


On Thu, Aug 20, 2009 at 6:40 PM, Ram Muthiah <ram.muthiah at yahoo.com> wrote:

I feel the examples document needs to be more detailed. Examples page instructs to run runjava.bat com.rabbitmq.examples.TestMain to run the TestMain class. But, don't we need to change hostname, guest, password, etc before running these classes? 
>

As far as I can see, the scripts default to using localhost and guest/guest. A broker running on the same machine should accept these credentials out of the box.
 

>I setup the server, I ran some basic python scripts to
> send/receive messages, they work well. I am stuck while using java client. Any help is much appreciated.
>

Unfortunately you're going to need to tell us how you're stuck before we can provide any useful assistance.

Paul.



      
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20090821/9aef9eec/attachment.htm