in flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQDeserializationSchemaWrapper.java [41:48]
public void deserialize(
Envelope envelope,
AMQP.BasicProperties properties,
byte[] body,
RMQCollector<OUT> collector)
throws IOException {
collector.collect(schema.deserialize(body));
}