Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-853

[A-MQ7, Core client] Core client should be notified if consumer is closed on broker side

    XMLWordPrintable

Details

    • Bug
    • Resolution: Unresolved
    • Major
    • None
    • None
    • core-protocol
    • None
    • Hide
      1. Start broker
      2. Create address named Test
      3. Create address named Test
      4. Start core client and connect to broker as receiver using e.g. following command:
        java -jar /var/dtests/node_data/clients/acce.jar receiver --timeout 3600 --log-msgs dict --broker "localhost:61616" --conn-username admin --conn-password admin --address "Test" --count 20
        
      5. Kill consumer (representation of this client on broker's side), e.g. using Hawtio console (see attached screenshot)
      6. Try to send messages to given queue -> client wont receive any.
      Show
      Start broker Create address named Test Create address named Test Start core client and connect to broker as receiver using e.g. following command: java -jar /var/dtests/node_data/clients/acce.jar receiver --timeout 3600 --log-msgs dict --broker "localhost:61616" --conn-username admin --conn-password admin --address "Test" --count 20 Kill consumer (representation of this client on broker's side), e.g. using Hawtio console (see attached screenshot) Try to send messages to given queue -> client wont receive any.

    Description

      If consumer is closed on broker using e.g. Hawtio console, client connected as that consumer (representation of broker resource) should be notified about that fact and react to that. It doesn't seem to react. If consumer is closed, as a result of not being notified, client hangs in the air and cannot receive messages.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              rvais Roman Vais
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated: