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-1237] Create AmqpIO #1725

Closed
wants to merge 10 commits into from
Closed

[BEAM-1237] Create AmqpIO #1725

wants to merge 10 commits into from

Commits on Jun 27, 2017

  1. [BEAM-1237] Create AmqpIO

    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    c22b22e View commit details
    Browse the repository at this point in the history

  2. [BEAM-1237] Add AmqpMessageCoderProviderRegistrar and AmqpMessageCode… 

    …r deals the whole message (not only the body)

TODO: fix the Coder
    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    a82b440 View commit details
    Browse the repository at this point in the history

  3. [BEAM-1237] Improve the AmqpMessageCoder and add a test on the coder

    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    5674be8 View commit details
    Browse the repository at this point in the history

  4. [BEAM-1237] Create a AmqpMessage wrapper to provide equals()

    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    83a4865 View commit details
    Browse the repository at this point in the history

  5. [BEAM-1237] Directly use ProtonJ Message in the PCollection, simplify… 

    … the Write, change the watermark
    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    b4c4d06 View commit details
    Browse the repository at this point in the history

  6. [BEAM-1237] Cleanup on the test

    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    1d2c3d5 View commit details
    Browse the repository at this point in the history

  7. [BEAM-1237] AmqpMessageCoder supports different message sizes and thr… 

    …ows an exception is the message is larger than supported
    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    97d7fdf View commit details
    Browse the repository at this point in the history

  8. [BEAM-1237] Improve code style and tests

    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    7b63c94 View commit details
    Browse the repository at this point in the history

  9. [BEAM-1237] Use try/finally in test

    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    f8a14b3 View commit details
    Browse the repository at this point in the history

  10. [BEAM-1237] Sort IO modules by alphanumeric order

    @jbonofre
    jbonofre committed Jun 27, 2017
    Configuration menu
    Copy the full SHA
    ac944e1 View commit details
    Browse the repository at this point in the history