public CompletableFuture<String> publish(final String topic,final Message message){
  final TopicQueue queue=topics.computeIfAbsent(topic,null);
  final CompletableFuture<String> future=queue.send(message);
  listener.publishingMessage(this,topic,message,future);
  return future;
}

public CompletableFuture < String > publish ( final String topic , final Message message ) { final TopicQueue queue = topics . computeIfAbsent ( topic , null ) ; final CompletableFuture < String > future = queue . send ( message ) ; listener . publishingMessage ( this , topic , message , future ) ; return future ; }
publish a message on a specific topic .
