@Test public void shouldPublishTwice() { new Expectations() { { capturingMessageProducer.send(anyString, null, (OdeData) any); times = 1; } }; testMessagePublisher.publish(mockOdeBsmData, "topic"); }
public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); objectProducer.send(topic, null, msg); }
OdeDataPublisher extends MessagePublisher { public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); objectProducer.send(topic, null, msg); } }
OdeDataPublisher extends MessagePublisher { public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); objectProducer.send(topic, null, msg); } OdeDataPublisher(OdeProperties odeProps, String serializer); }
OdeDataPublisher extends MessagePublisher { public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); objectProducer.send(topic, null, msg); } OdeDataPublisher(OdeProperties odeProps, String serializer); void publish(OdeData msg, String topic); }
OdeDataPublisher extends MessagePublisher { public void publish(OdeData msg, String topic) { logger.debug("Publishing to {}: {}", topic, msg); objectProducer.send(topic, null, msg); } OdeDataPublisher(OdeProperties odeProps, String serializer); void publish(OdeData msg, String topic);  }