Client client = state.getCallbackClient(); client.removeListener(state.getMessageCallbackHandler()); client.disconnect();
ConnectionState cState = (ConnectionState)state.getParent().getParent();  cState.getRemotingConnection().getCallbackManager().unregisterHandler(state.getConsumerID());
   public Object handleClosing(Invocation invocation) throws Throwable   {            ConsumerState state = getState(invocation);      Client client = state.getCallbackClient();      client.removeListener(state.getMessageCallbackHandler());      client.disconnect();            state.getMessageCallbackHandler().close();              return invocation.invokeNext();   }