code: public synchronized void doStop() {
          if(_connection != null) {
              delegate.getLogger().debug("stomp: closing connection to remote broker");
              try {transmit(CMD_DISCONNECT, null, null, null, null);} catch (IOException ioe) {/* ignore it */}
              final IStreamConnection c= _connection;
              _connection= null;
              c.close();
              
              try {
                  _receiver.stop();
                  _receiver.waitForState(2000, AbstractSingleThreadRunner.STOPPED);
              } catch (InterruptedException ie) {
                  delegate.getLogger().warn("stomp: could not stop receiver", ie);
              }
              
              _transformer= null;
          }
      }
docs: === Initialisation Methods === //