[rabbitmq-discuss] Broken Pipe in RabbitMQ ConnectionFactory.newConnection()

Sun Sep 8 22:56:19 BST 2013

Michael,

Actually I am opening and closing connections quite a lot (once every ~3
RPC requests on average). Is that bad and I'm supposed to pool them?

The client code is (split into multiple methods actually, but roughly):

            factory = new ConnectionFactory();
           connection = factory.newConnection();
    channel = connection.createChannel();

    Map<String, Object> arguments = new HashMap<String, Object>();
    arguments.put("x-expires", 10*60*1000); // 10 min
replyQueueName = channel.queueDeclare("", false, true, true,
arguments).getQueue();

    consumer = new QueueingConsumer(channel);
    channel.basicConsume(replyQueueName, true, consumer);

            String response = null;
    String corrId = UUID.randomUUID().toString();

    BasicProperties props = new BasicProperties.Builder()
     .correlationId(corrId)
     .expiration(DEFAULT_TIMEOUT + "")
     .replyTo(replyQueueName)
     .build();

    channel.basicPublish("", queueName, props, message.getBytes());

                while (true) {
        QueueingConsumer.Delivery delivery = null;
try {
delivery = consumer.nextDelivery(100);
} catch (InterruptedException e) {}
 if (delivery == null) {
  continue;
}
        if (delivery.getProperties().getCorrelationId().equals(corrId)) {
            response = new String(delivery.getBody());

            break;
        } else {
         continue;
        }
    }

if (connection != null)
connection.abort(); // .close seemed to hang at
com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:492) ->
com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:50)

On Sun, Sep 8, 2013 at 9:11 PM, Michael Klishin <michael at rabbitmq.com>wrote:

> John M.:
>
> > I've reviewed the Rabbit logs and the only kind of errors I find there
> are:
> >
> >     =ERROR REPORT==== 6-Sep-2013::21:36:59 ===
> >     closing AMQP connection <0.3105.1297> (10.118.69.132:42582 ->
> 10.12.111.134:5672):
> >     {handshake_timeout,frame_header}
>
> John,
>
> Can you post a snippet of your code that demonstrates what operations lead
> [presumably] to this error? Is it possible that you are opening and
> closing connections
> constantly or only creating and deleting reply queues?
>
> MK
>
>
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130908/54eb1872/attachment.htm>