public class ThroughputSampleIntegrationTests {
@Test
public void logsThroughputWhenControlMessagesReceived() {
PublishSubscribeChannel pubsub = new PublishSubscribeChannel();
pubsub.subscribe(new ThroughputSamplerMessageHandler());
int msgs = 100000;
pubsub.send(new GenericMessage<String>("START"));
for (int i = 0; i < msgs; i++) {
pubsub.send(new GenericMessage<Object>(new Object()));