[ 
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ph.Duveau updated FLINK-8468:
-----------------------------
    Description: Make the connector to take advantage of AMQP features by 
adding a constructor and an interface to implement  (was: We extend RMQSink to 
get a variable routingkey using fields from the "value" and also to have a 
configurable exchange to publish to. But we got problems with the class 
attribute "logFailuresOnly" of RMQSink which is private (should be protected 
scope).)
        Summary: Make the connector to take advantage of AMQP features (routing 
key, exchange and message properties)  (was: Allow RMQSink to be extended )

> Make the connector to take advantage of AMQP features (routing key, exchange 
> and message properties)
> ----------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-8468
>                 URL: https://issues.apache.org/jira/browse/FLINK-8468
>             Project: Flink
>          Issue Type: Improvement
>          Components: RabbitMQ Connector
>    Affects Versions: 1.4.0
>            Reporter: Ph.Duveau
>            Priority: Major
>
> Make the connector to take advantage of AMQP features by adding a constructor 
> and an interface to implement



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to