code: public void send( String topic, String message ) throws IOException
      {
          send( topic, message, null );
      }
docs: Non-blocking send. The message will not be really available to consumers until flush()
  or close() is called, or until another blocking send is called.