Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-8390

cannot set useCorrelationId on RabbitMqIO Read

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • 2.15.0
    • 2.17.0
    • io-java-rabbitmq
    • None

    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.

      Attachments

        Issue Links

          Activity

            People

              drobert Daniel Robert
              drobert Daniel Robert
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 40m
                  40m