@Test public void testNoSubscriber() throws Exception { pubSubService.publish("topicVoid", "something".getBytes(UTF_8)); }
@Override public void publish(String topic, byte[] message) { localPublish(topic, message); }
MemPubSubProvider extends AbstractPubSubProvider { @Override public void publish(String topic, byte[] message) { localPublish(topic, message); } }
MemPubSubProvider extends AbstractPubSubProvider { @Override public void publish(String topic, byte[] message) { localPublish(topic, message); }  }
MemPubSubProvider extends AbstractPubSubProvider { @Override public void publish(String topic, byte[] message) { localPublish(topic, message); }  @Override void initialize(Map<String, String> options, Map<String, List<BiConsumer<String, byte[]>>> subscribers); @Override void close(); @Override void publish(String topic, byte[] message); }
MemPubSubProvider extends AbstractPubSubProvider { @Override public void publish(String topic, byte[] message) { localPublish(topic, message); }  @Override void initialize(Map<String, String> options, Map<String, List<BiConsumer<String, byte[]>>> subscribers); @Override void close(); @Override void publish(String topic, byte[] message);  }