senegalo commented on a change in pull request #12056:
URL: https://github.com/apache/flink/pull/12056#discussion_r446636396
##########
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:
i am sorry i am known to play around with tests strings :D i can change
it ... but then what do you have against teeth brushing !? explain yourself
mister ! :D
----------------------------------------------------------------
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]
