@Test public void publishShouldCallMessageProducer() { new Expectations() { { capturingMessageProducer.send(anyString, null, anyString); times = 1; } }; testOdeStringPublisher.publish(new OdeData(), "testTopic"); }
public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); stringProducer.send(topic, null, msg.toJson()); }
OdeStringPublisher extends MessagePublisher { public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); stringProducer.send(topic, null, msg.toJson()); } }
OdeStringPublisher extends MessagePublisher { public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); stringProducer.send(topic, null, msg.toJson()); } OdeStringPublisher(OdeProperties odeProps); }
OdeStringPublisher extends MessagePublisher { public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); stringProducer.send(topic, null, msg.toJson()); } OdeStringPublisher(OdeProperties odeProps); void publish(OdeData msg, String topic); }
OdeStringPublisher extends MessagePublisher { public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); stringProducer.send(topic, null, msg.toJson()); } OdeStringPublisher(OdeProperties odeProps); void publish(OdeData msg, String topic);  }