examples/src/main/java/clientspam/SpamClients.java
/**
   * Messages should have been published and close should wait before terminating
   */
Messages should have been published and close should wait before terminating
Messages should have been published and close should wait before terminating
private static void spamSingleOpenCloseAsync() throws InterruptedException {
    final ExchangeClient client = clientFromExchange();
    client.publishAsync(createMessage("warning"), "log.spam");
    client.publishAsync(createMessage("warning"), "log.spam");
    client.close();
  }
private static void spamSingleOpenCloseAsync ( ) throws InterruptedException { final ExchangeClient client = clientFromExchange ( ) ; client . publishAsync ( createMessage ( "warning" ) , "log.spam" ) ; client . publishAsync ( createMessage ( "warning" ) , "log.spam" ) ; client . close ( ) ; }
Messages should have been published and close should wait before terminating
Messages should have been published and close should wait before terminating