[rabbitmq-discuss] ShutdownListener not triggered on server shutdown

Hi,
I'm using the rabbit java client and rabbitmq server for some simple
messaging and I can't seem to get the shutdown listener to work as expected.

Basically, I'm attaching a shutdownlistener to the connection and then start
sending messages every second. If I shutdown the server I would expect the
shutdownlistener to be invoked at some point on the client but this never
occurs. I only get an AlreadyClosedException when calling basicPublish on
the channel.

Test case:

package foobar;

import com.rabbitmq.client.*;

import java.io.IOException;


public class TestRabbitShutdownListener implements ShutdownListener,
Runnable
{
private Connection connection;
private Channel channel;
private String exchange;
private int ticket;

public static void main(String[] args) throws IOException,
InterruptedException
{
ConnectionParameters cp = new ConnectionParameters();
cp.setUsername("guest");
cp.setPassword("guest");

ConnectionFactory cf = new ConnectionFactory(cp);

TestRabbitShutdownListener trsl = new TestRabbitShutdownListener(
cf,
"foobar"
);

Thread t = new Thread(trsl);
t.start();
t.join();
Thread.sleep(5000);

}

public TestRabbitShutdownListener(ConnectionFactory connectionFactory,
String exchange) throws IOException
{
this.exchange = exchange;
this.connection = connectionFactory.newConnection("localhost");
this.connection.addShutdownListener(this);

setupChannel();
}

private void setupChannel() throws IOException
{
this.channel = connection.createChannel();
this.ticket = channel.accessRequest("/data");

channel.exchangeDeclare(
ticket,
exchange,
"fanout"
);
}

public void run()
{
while (true)
{
try
{
System.out.println("Sending msg..");

channel.basicPublish(ticket, exchange, "",
MessageProperties.BASIC, new byte[]{});
Thread.sleep(1000);
}
catch (IOException e)
{
e.printStackTrace();
return;
}
catch (InterruptedException e)
{
System.out.println("thread interrupted");
return;
}
}
}

public void shutdownCompleted(ShutdownSignalException e)
{
System.out.println("shutdownCompleted: " + e.getMessage());
e.printStackTrace();
}
}