[BEAM-8390] cannot set useCorrelationId on RabbitMqIO Read

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.15.0
• Fix Version/s: 2.17.0
• Component/s: io-java-rabbitmq
• Assignee: Daniel Robert
• Reporter: Daniel Robert
• Created: 13/Oct/19 23:42
• Updated: 16/May/20 14:12
• Resolved: 16/Oct/19 15:05

Description

RabbitMqIO.Read hard-codes setUseCorrelationId(false) and there does not appear to be any means for a caller to override this.

A Builder cannot be obtained (it's package-private) and there does not seem to be a corresponding withUseCorrelationId on the resulting Read class like there is for other properties.

This looks like it was just an omission.

Issue Links

• links to: GitHub Pull Request #9782