@Test
public void invokePublishBytesToQueue() throws Exception {

	RMQSink<String> rmqSink = createRMQSink();
	rmqSink.invoke(MESSAGE_STR, SinkContextUtil.forTimestamp(0));
	verify(serializationSchema).serialize(MESSAGE_STR);
	verify(channel).basicPublish("", QUEUE_NAME, null, MESSAGE);
}