Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jms connection status #1252

Merged
merged 9 commits into from
Oct 30, 2018
Merged

Commits on Oct 27, 2018

  1. JmsConnector status

    Stream-based connection status
    
      Connection status is now exposed as stream of updates. For the Java
      interface, a Java enum is exposed, for the Scala interface, a sealed
      trait with case objects and a case class is used.
    
    Fix reconnect attempts
    
      Now also retry to connect (for a limited amount of times and after
      delay) if creating sessions, consumers, producers or destinations fail
    
    Fix flaky 'disconnect exceptional completion' test
    
      Fixes akka#1231
      Fixes akka#1031
    andreas-sa-schroeder committed Oct 27, 2018
    Configuration menu
    Copy the full SHA
    40b58ba View commit details
    Browse the repository at this point in the history
  2. Add more connection status tests and minor fixes

    - Add tests for connection status and reconnects on session creation
      failures
    - Connecting status attempt number was off-by-one for JmsConsumer
    - Session creation failure was not properly handled
    andreas-sa-schroeder committed Oct 27, 2018
    Configuration menu
    Copy the full SHA
    8457a7b View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    6082ace View commit details
    Browse the repository at this point in the history
  4. Split Stopping state into Completed and Failed

    - Also made sure that published states are natural: no intermediate
      disconnected state is published on failure
    - Also improved logic handling consumer downstream completion
    - Also ensured that access to state and state queue is safe
    - Added more tests for connection status
    andreas-sa-schroeder committed Oct 27, 2018
    Configuration menu
    Copy the full SHA
    94ee6d2 View commit details
    Browse the repository at this point in the history
  5. Configuration menu
    Copy the full SHA
    8590a82 View commit details
    Browse the repository at this point in the history
  6. Use consumer control and producer status consistently and extend docs

    - Breaking change: using JmsConsumerControl and JmsProducerStatus in all
      JmsProducer and JmsConsumer factory methods
    - Adjusted and extended docs
    - Also renamed stage state source to connectorState
    - Also fixed flaky test "abort connection on security exception"
    - Also simplified openConnection method
    andreas-sa-schroeder committed Oct 27, 2018
    Configuration menu
    Copy the full SHA
    cf7e220 View commit details
    Browse the repository at this point in the history
  7. Configuration menu
    Copy the full SHA
    de2d2f7 View commit details
    Browse the repository at this point in the history
  8. Fix openConnection behavior under failure

    - Reverted openConnection simplification, as it did not handle
      exceptions on connection.setExceptionListener
    - Added test that demonstrates the simplification was invalid
    - Removed unnecessary broker forced restart in Spec
    andreas-sa-schroeder committed Oct 27, 2018
    Configuration menu
    Copy the full SHA
    82b235a View commit details
    Browse the repository at this point in the history

Commits on Oct 30, 2018

  1. Configuration menu
    Copy the full SHA
    6a406b7 View commit details
    Browse the repository at this point in the history