Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51441043
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-nar/src/main/resources/META-INF/LICENSE
---
@@ -0,0 +1,319 @@
+
+
GitHub user olegz opened a pull request:
https://github.com/apache/nifi/pull/199
[REVIEW ONLY]]NIFI-865 added initial support for AMQP publish/subscribe
Still working on docs and tests
You can merge this pull request into a Git repository by running:
$ git pull
Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51441537
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
---
@@ -0,0 +1,78 @@
Github user olegz commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51445239
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/test/resources/log4j.properties
---
@@ -0,0 +1,22 @@
+# Licensed to the Apache Software
Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51441942
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPPublisher.java
---
@@ -0,0 +1,128 @@
Github user olegz commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51444249
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPPublisher.java
---
@@ -0,0 +1,128 @@
+/*
Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51444798
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/test/resources/log4j.properties
---
@@ -0,0 +1,22 @@
+# Licensed to the Apache
Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51442155
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPWorker.java
---
@@ -0,0 +1,104 @@
+/*
Github user olegz commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51442275
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
---
@@ -0,0 +1,78 @@
+/*
Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r5168
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
---
@@ -0,0 +1,78 @@
Github user olegz commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51444624
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
---
@@ -0,0 +1,78 @@
+/*
Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51441125
--- Diff: nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/pom.xml ---
@@ -0,0 +1,74 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user olegz commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51443924
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPWorker.java
---
@@ -0,0 +1,104 @@
+/*
Github user olegz commented on the pull request:
https://github.com/apache/nifi/pull/199#issuecomment-178159306
Closing it after initial review. Will open a new one once all comments are
addressed and cleanup.
---
If your project is set up for it, you can reply to this email and
Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/199#discussion_r51442712
--- Diff:
nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
---
@@ -0,0 +1,78 @@
15 matches
Mail list logo