The problem is that your code does account for the case where FailoverCommandCenter == null (non clustered), but it's not a MessagingShutdownException
>>The problem is that your code does account for the case where FailoverCommandCenter == null (non clustered), but it's not a MessagingShutdownException
public Object handleClosing(Invocation invocation) throws Throwable { ...... Long l = (Long) invocation.invokeNext(); <<<< --- this line will fail iif the server was killed... .... consumerState.getClientConsumer().close(lastDeliveryId); <<< -- if the server was killed, nothing will close the clientConsumer ....