[rabbitmq-discuss] Failure to return from call to newConnection()

Mon Oct 8 22:22:10 BST 2012

The stack trace you have posted really does look like a standard case of 
the TCP connection timing out. I suggest you make absolutely sure that 
you really are connecting to the host/port you think you are.

Cheers, Simon

On 08/10/2012 9:02PM, McMahon, James S (TASC) wrote:
>        I am experiencing a problem that I have been unable to pin down.
> When I attempt to use a java class to listen for messages bound to a
> particular exchange by a particular routing key, I get a "Connection
> timed out" error. Here is my code:
>
>
> public class ReceiveLogsDirect {
>
>    private static final String EXCHANGE_NAME = "ABC_SERVER";
>
>    public static void main(String[] argv) throws Exception {
>
>        String hostName = "localhost";
>        int portNumber = 5672;
>
>        if (argv.length < 1 || argv.length == 2 || argv.length > 3){
>            System.err.println("Usage: ReceiveLogsDirect [session ID]
> [RabbitMQ server IP, optional] [RabbitMQ server port #, optional]");
>            System.exit(1);
>        }
>        else if (argv.length == 1) {
>            hostName = "localhost";
>            portNumber = 5672; // default port that rabbitMQ listens to
>        }
>        else if  (argv.length == 3) {
>            hostName = argv[1];
>            portNumber = Integer.parseInt(argv[2]);
>        }
>
>        ConnectionFactory factory = new ConnectionFactory();
>
>
>        factory.setHost(hostName);
>        factory.setPort(portNumber);
>        factory.setUsername("guest");
>        factory.setPassword("guest");
>        factory.setVirtualHost("/");
>
>        System.out.println(" [*] HERE 1");
>        Connection connection = factory.newConnection();
>        System.out.println(" [*] HERE 2");
>        Channel channel = connection.createChannel();
>
>
>      channel.exchangeDeclare(EXCHANGE_NAME, "direct");
>      String queueName = channel.queueDeclare().getQueue();
>
>          channel.queueBind(queueName, EXCHANGE_NAME, argv[0]);
>          System.out.println(" [*] bindingKey " + argv[0]  +  " is bound
> to queue on exchange " + EXCHANGE_NAME );
>
>      System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
>
>      QueueingConsumer consumer = new QueueingConsumer(channel);
>      channel.basicConsume(queueName, true, consumer);
>
>      while (true) {
>        QueueingConsumer.Delivery delivery = consumer.nextDelivery();
>        String message = new String(delivery.getBody());
>        String routingKey = delivery.getEnvelope().getRoutingKey();
>
>        System.out.println(" [x] Received message for " + routingKey + "
>  >>>" + message);
>      }
>    }
>
> I used simple print statements to pinpoint the source of the problem at
> the line where I call newConnection().
>
>       The error I get is this:
>
>   [*] HERE 1
> Exception in thread "main" java.net.ConnectException: Connection timed
> out: connect
>      at java.net.PlainSocketImpl.socketConnect(Native Method)
>      at java.net.PlainSocketImpl.doConnect(Unknown Source)
>      at java.net.PlainSocketImpl.connectToAddress(Unknown Source)
>      at java.net.PlainSocketImpl.connect(Unknown Source)
>      at java.net.SocksSocketImpl.connect(Unknown Source)
>      at java.net.Socket.connect(Unknown Source)
>      at
> com.rabbitmq.client.ConnectionFactory.createFrameHandler(ConnectionFactory.java:441)
>      at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:480)
>      at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:509)
>      at
> com.tasc.prism.queue.ReceiveLogsDirect.main(ReceiveLogsDirect.java:55)
>
>       My install of rabbitMQ is 2.7.0. Oddly, I have been able to
> execute this in another command shell window and it works. I am
> wondering why I'm having trouble in the second shell? Surely I must be
> able to execute multiple instances of ReceiveLogsDirect simultaneously,
> right?
>
>      Could it be a runtime environment problem? I set my class path
> exactly the same in both shells.
>
>      Any thoughts or similar experience with such a problem? Thank you.
>
> - Jim
>
>
> CONFIDENTIALITY NOTICE: This message and any attachments or files
> transmitted with it (collectively, the "Message") are intended only for
> the addressee and may contain information that is privileged,
> proprietary and/or prohibited from disclosure by law or contract. If you
> are not the intended recipient: (a) please do not read, copy or
> retransmit the Message; (b) permanently delete and/or destroy all
> electronic and hard copies of the Message; (c) notify us by return
> email; and (d) you are hereby notified that any dissemination,
> distribution or copying of the Message is strictly prohibited.
>
>
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>