Wojciech Luczkow created FLINK-8510:
---------------------------------------
Summary: Provide access to Delivery envelope in RabbitMQ Source
Key: FLINK-8510
URL: https://issues.apache.org/jira/browse/FLINK-8510
Project: Flink
Issue Type: Wish
Reporter: Wojciech Luczkow
Currently RMQSource is limited to get AMQP message body in resulting Stream,
sometimes it would be good to get access to Envelope
For example
if subscribing to Topic using Routing Key amq.topic.#
it is impossible to distinguish whether message came from amq.topic.1 or
amq.topic.2
Studying current implementation I think the easiest option from consumer point
of view would be to change RMQSource<OUT> to provide Stream<RMQMessage<OUT>>
which will break Flink API...
Another would be to create something like detailedsource with different API -
provide generic Wrapper with message content <OUT> and Map with message
properties (and protected method to override and fill that map).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
