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