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.

Sign up for GitHub

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

Jump to bottom

[BEAM-13] Add JmsIO #299

Closed
wants to merge 15 commits into from
Closed

[BEAM-13] Add JmsIO #299

wants to merge 15 commits into from

Commits on Jul 27, 2016

  1. [BEAM-13] Add JmsIO

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    604bb48 View commit details
    Browse the repository at this point in the history

  2. [BEAM-13] Fix JMS IO Test execution

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    ffe1498 View commit details
    Browse the repository at this point in the history

  3. [BEAM-13] Use check* method for JMS writer

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    7bdec54 View commit details
    Browse the repository at this point in the history

  4. [BEAM-13] Remove transient on connection factory to be able to validate

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    ecf6acf View commit details
    Browse the repository at this point in the history

  5. [BEAM-13] Use NeedsRunner category in the JmsIOTest

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    b608f19 View commit details
    Browse the repository at this point in the history

  6. [BEAM-13] Remove unused headers map

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    a65a858 View commit details
    Browse the repository at this point in the history

  7. [BEAM-13] Explicitly define the dependencies in pom.xml

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    d73cc4d View commit details
    Browse the repository at this point in the history

  8. [BEAM-13] Use CLIENT_ACK mode and checkpoint mark to deal with messages

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    1f028d8 View commit details
    Browse the repository at this point in the history

  9. [BEAM-13] See the current to null when no message has been consumed

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    18798ab View commit details
    Browse the repository at this point in the history

  10. [BEAM-13] Fix dependencies declaration

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    3ec9839 View commit details
    Browse the repository at this point in the history

  11. [BEAM-13] Cleanup destination attribute in the reader

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    bd08171 View commit details
    Browse the repository at this point in the history

  12. [BEAM-13] Improve watermark by storing the oldest pending message tim… 

    …estamp as watermark
    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    7c748f6 View commit details
    Browse the repository at this point in the history

  13. [BEAM-13] Use JodaTime Instant to manipulate the timestamp

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    2c8999c View commit details
    Browse the repository at this point in the history

  14. [BEAM-13] Add a comment to describe the finalize checkpoint, change t… 

    …he visibility on the checkpoint mark
    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    93ccc62 View commit details
    Browse the repository at this point in the history

  15. [BEAM-13] Add now required package-info.java

    @jbonofre
    jbonofre committed Jul 27, 2016
    Configuration menu
    Copy the full SHA
    de4522a View commit details
    Browse the repository at this point in the history