[ 
https://issues.apache.org/jira/browse/FLINK-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15105076#comment-15105076
 ] 

Robert Metzger commented on FLINK-3248:
---------------------------------------

I would prefer the {{ConnectionFactory}} variant. How would you serialize the 
factory? (Using Kryo? manually?)

> RMQSource does not provide a constructor for credentials or other options
> -------------------------------------------------------------------------
>
>                 Key: FLINK-3248
>                 URL: https://issues.apache.org/jira/browse/FLINK-3248
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming Connectors
>    Affects Versions: 1.0.0
>            Reporter: Maximilian Michels
>            Assignee: Maximilian Michels
>             Fix For: 1.0.0
>
>
> We could either add a new constructor for credentials (username and password) 
> or let the user pass a {{ConnectionFactory}} to the source. The latter would 
> enable us to support all potential options for the connection. Note that, 
> {{ConnectionFactory}} is not serializable. It would have to be serialized to 
> a byte array for shipping.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to