@Test(expected = RuntimeException.class)
public void exceptionDuringPublishingIsNotIgnored() throws Exception {

	RMQSink<String> rmqSink = createRMQSink();
	doThrow(IOException.class).when(channel).basicPublish("", QUEUE_NAME, null, MESSAGE);
	rmqSink.invoke("msg", SinkContextUtil.forTimestamp(0));
}