Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-2579

JMS source support durable subscriptions and message listening

    Details

    • Type: Wish
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.5.2
    • Fix Version/s: 1.8.0
    • Component/s: Sinks+Sources
    • Labels:
      None

      Description

      best wishes

        Issue Links

          Activity

          Hide
          denes Denes Arvay added a comment -

          Thanks for the patch Andras Beni, thanks for the review Attila Simon

          Show
          denes Denes Arvay added a comment - Thanks for the patch Andras Beni , thanks for the review Attila Simon
          Hide
          hudson Hudson added a comment -

          FAILURE: Integrated in Jenkins build Flume-trunk-hbase-1 #251 (See https://builds.apache.org/job/Flume-trunk-hbase-1/251/)
          FLUME-2579 Support durable subscription in JMSSource (denes: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=857df3fe9b211a0e34f17cc6d776a1296951134a)

          • (edit) flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/JMSMessageConsumerTestBase.java
          • (delete) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumerFactory.java
          • (edit) flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestIntegrationActiveMQ.java
          • (edit) flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestJMSMessageConsumer.java
          • (edit) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumer.java
          • (edit) flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestJMSSource.java
          • (edit) flume-ng-doc/sphinx/FlumeUserGuide.rst
          • (edit) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
          • (edit) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSourceConfiguration.java
          Show
          hudson Hudson added a comment - FAILURE: Integrated in Jenkins build Flume-trunk-hbase-1 #251 (See https://builds.apache.org/job/Flume-trunk-hbase-1/251/ ) FLUME-2579 Support durable subscription in JMSSource (denes: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=857df3fe9b211a0e34f17cc6d776a1296951134a ) (edit) flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/JMSMessageConsumerTestBase.java (delete) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumerFactory.java (edit) flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestIntegrationActiveMQ.java (edit) flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestJMSMessageConsumer.java (edit) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumer.java (edit) flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestJMSSource.java (edit) flume-ng-doc/sphinx/FlumeUserGuide.rst (edit) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java (edit) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSourceConfiguration.java
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

          https://github.com/apache/flume/pull/120

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/flume/pull/120
          Hide
          jira-bot ASF subversion and git services added a comment -

          Commit 857df3fe9b211a0e34f17cc6d776a1296951134a in flume's branch refs/heads/trunk from Andras Beni
          [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=857df3f ]

          FLUME-2579 Support durable subscription in JMSSource

          JMSSource has created only nondurable subscriptions which could lead to event loss in case
          of topic destination type.

          This change enables durable subscription creation and lets user specify client id.
          Also removed JMSMessageConsumerFactory which has no additional value.

          This closes #120.

          Reviewers: Attila Simon, Denes Arvay

          (Andras Beni via Denes Arvay)

          Show
          jira-bot ASF subversion and git services added a comment - Commit 857df3fe9b211a0e34f17cc6d776a1296951134a in flume's branch refs/heads/trunk from Andras Beni [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=857df3f ] FLUME-2579 Support durable subscription in JMSSource JMSSource has created only nondurable subscriptions which could lead to event loss in case of topic destination type. This change enables durable subscription creation and lets user specify client id. Also removed JMSMessageConsumerFactory which has no additional value. This closes #120. Reviewers: Attila Simon, Denes Arvay (Andras Beni via Denes Arvay)
          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user andrasbeni opened a pull request:

          https://github.com/apache/flume/pull/120

          FLUME-2579 Support durable subscription in JMSSource

          JMSSource has created only nondurable subscriptions which could lead to event loss in case of topic destination type.

          This change enables durable subscription creation and lets user specify client id.
          Also removed JMSMessageConsumerFactory which has no additional value.

          You can merge this pull request into a Git repository by running:

          $ git pull https://github.com/andrasbeni/flume FLUME-2579

          Alternatively you can review and apply these changes as the patch at:

          https://github.com/apache/flume/pull/120.patch

          To close this pull request, make a commit to your master/trunk branch
          with (at least) the following in the commit message:

          This closes #120


          commit 785b6ed7cbdbb74ee8a4536db0b669da26a08245
          Author: Andras Beni <andrasbeni@cloudera.com>
          Date: 2017-03-14T15:31:42Z

          FLUME-2579 Support durable subscription in JMSSource
          JMSSource has created only nondurable subscriptions which could lead to event loss in case of topic destination type.

          This change enables durable subscription creation and lets user specify client id.
          Also removed JMSMessageConsumerFactory which has no additional value.


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user andrasbeni opened a pull request: https://github.com/apache/flume/pull/120 FLUME-2579 Support durable subscription in JMSSource JMSSource has created only nondurable subscriptions which could lead to event loss in case of topic destination type. This change enables durable subscription creation and lets user specify client id. Also removed JMSMessageConsumerFactory which has no additional value. You can merge this pull request into a Git repository by running: $ git pull https://github.com/andrasbeni/flume FLUME-2579 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flume/pull/120.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #120 commit 785b6ed7cbdbb74ee8a4536db0b669da26a08245 Author: Andras Beni <andrasbeni@cloudera.com> Date: 2017-03-14T15:31:42Z FLUME-2579 Support durable subscription in JMSSource JMSSource has created only nondurable subscriptions which could lead to event loss in case of topic destination type. This change enables durable subscription creation and lets user specify client id. Also removed JMSMessageConsumerFactory which has no additional value.

            People

            • Assignee:
              andrasbeni Andras Beni
              Reporter:
              z772458549 zhangshengbing
            • Votes:
              1 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development