@Test public void shouldPublishTwice() { new Expectations() { { capturingMessageProducer.send(anyString, null, (byte[]) any); times = 1; } }; testMessagePublisher.publish(mockOdeBsmData, "topic"); }
public void publish(byte[] msg, String topic) { logger.debug("Publishing binary data to {}", topic); bytesProducer.send(topic, null, msg); }
ByteArrayPublisher extends MessagePublisher { public void publish(byte[] msg, String topic) { logger.debug("Publishing binary data to {}", topic); bytesProducer.send(topic, null, msg); } }
ByteArrayPublisher extends MessagePublisher { public void publish(byte[] msg, String topic) { logger.debug("Publishing binary data to {}", topic); bytesProducer.send(topic, null, msg); } ByteArrayPublisher(OdeProperties odeProps); }
ByteArrayPublisher extends MessagePublisher { public void publish(byte[] msg, String topic) { logger.debug("Publishing binary data to {}", topic); bytesProducer.send(topic, null, msg); } ByteArrayPublisher(OdeProperties odeProps); void publish(byte[] msg, String topic); }
ByteArrayPublisher extends MessagePublisher { public void publish(byte[] msg, String topic) { logger.debug("Publishing binary data to {}", topic); bytesProducer.send(topic, null, msg); } ByteArrayPublisher(OdeProperties odeProps); void publish(byte[] msg, String topic);  }