CheramiPublisherImpl implements CheramiPublisher, Reconfigurable { @Override public synchronized void open() throws InterruptedException, IOException { if (!isOpen.get()) { connectionManager.open(); isOpen.set(true); logger.info("Publisher opened"); } } CheramiPublisherImpl(CheramiClient client, String path, PublisherOptions options, MetricsReporter reporter); @Override synchronized void open(); @Override synchronized void close(); @Override SendReceipt write(PublisherMessage message); @Override CheramiFuture<SendReceipt> writeAsync(PublisherMessage message); @Override void refreshNow();  }
@Test public void openTest() throws Exception { publisher.open(); assert (publisher.isOpen() == true); publisher.close(); logger.info("CheramiPublisherImplTest: PASSED: OpenTest"); }