Clebert - I'm not sure you're patch is correct. Can't we just do: | | ConsumerState consumerState = getState(invocation); ClientConsumer clientConsumer = consumerState.getClientConsumer(); try { // We make sure closing is called on the ServerConsumerEndpoint. // This returns us the last delivery id sent Long l = (Long)invocation.invokeNext(); long lastDeliveryId = l.longValue(); // First we call close on the ClientConsumer which waits for onMessage invocations // to complete and the last delivery to arrive clientConsumer.close(lastDeliveryId); ... ... return l; } catch (Exception e) { if (!(e instanceof MessagingNetworkFailureException) && !clientConsumer.isClosed()) { //Make sure we close the client consumer - but we don't want to do this //in a failover situation clientConsumer.close(-1); } throw e; } View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4099572#... Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...