code: @Override
  	protected void onConnectionClose()
      {
      	super.onConnectionClose();
      	
      	try
          {
          	if (transport != null && !transport.isClosed())
          	{
  	            log.debug("#"+id+" Closing transport");
  	            this.transport.close();
          	}
          }
          catch (Exception e)
          {
              log.error("Could not close transport",e);
          }
      }
docs: /* (non-Javadoc)
  @see net.timewalker.ffmq4.common.connection.AbstractConnection#onConnectionClose()