code: @Override
  	public void close()
      {
          closeTransport(false);
          
          // Wait for threads to complete
          try
  		{
          	if (receiverThread != null && Thread.currentThread() != receiverThread)
          		receiverThread.join();
  		}
  		catch (InterruptedException e)
  		{
  			log.error("#"+id+" wait for receiver thread termination was interrupted.");
  		}
  		try
  		{
          	if (senderThread != null && Thread.currentThread() != senderThread)
          		senderThread.join();
  		}
  		catch (InterruptedException e)
  		{
  			log.error("#"+id+" wait for sender thread termination was interrupted.");
  		}
      }
docs: /*
  (non-Javadoc)
  @see net.timewalker.ffmq4.remote.transport.PacketTransport#close()