austince commented on a change in pull request #12056:
URL: https://github.com/apache/flink/pull/12056#discussion_r446989048
##########
File path:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java
##########
@@ -382,6 +414,27 @@ public boolean isEndOfStream(String nextElement) {
}
}
+ private class CustomDeserializationSchema implements
RMQDeserializationSchema<String> {
+ @Override
+ public TypeInformation<String> getProducedType() {
+ return TypeExtractor.getForClass(String.class);
+ }
+
+ @Override
+ public void processMessage(Envelope envelope,
AMQP.BasicProperties properties, byte[] body, RMQCollector collector) throws
IOException {
+ List<String> messages = new ArrayList();
+ messages.add("I Love Turtles");
+ messages.add("Brush your teeth");
Review comment:
Ha! I really like your test data, fun data over everything!
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
