DanielLeens commented on issue #12883: URL: https://github.com/apache/seatunnel/issues/12883#issuecomment-6266961893
Thanks for the well-scoped request. Classification: D / Connector-V2 ActiveMQ source consumption semantics. The current source exposes only format, field delimiter, and max-in-flight settings, and its reader uses a fixed receive wait; the sink-side connection-factory settings are not part of the source option rule. I found no matching open implementation PR. Please make this one focused PR only after the option contract is written down: use an explicit `message_selector` passed to the JMS consumer, name and validate a millisecond receive-timeout option (including its zero/negative behavior), and decide which connection-factory settings are genuinely shared source/sink options rather than importing a sink-specific API. Include broker-backed source tests for selector behavior, timeout behavior, credentials/client-id configuration, checkpoint/ack behavior, and EN/ZH option documentation. Do not change the default polling behavior or broaden the URI parser in this slice. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
