public void deserialize()

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));
    }