subject:"incubator\-nifi git commit\: NIFI\-724\: Enable bulletins for reporting tasks and controller services"

[05/50] [abbrv] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

2015-07-16 Thread mcgilman

NIFI-724: Enable bulletins for reporting tasks and controller services


Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/e240e07a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/e240e07a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/e240e07a

Branch: refs/heads/master
Commit: e240e07aaebea1fd66b22fce8aec3f0005fd3f60
Parents: e767f5c
Author: Mark Payne marka...@hotmail.com
Authored: Wed Jun 24 14:03:34 2015 -0400
Committer: Mark Payne marka...@hotmail.com
Committed: Thu Jun 25 10:56:49 2015 -0400

--
 .../org/apache/nifi/reporting/Bulletin.java | 11 ++-
 .../apache/nifi/reporting/ComponentType.java| 58 ++
 .../manager/impl/ClusteredReportingContext.java | 46 ++-
 .../cluster/manager/impl/WebClusterManager.java | 80 
 .../org/apache/nifi/events/BulletinFactory.java | 30 ++--
 .../org/apache/nifi/events/SystemBulletin.java  |  2 +
 .../nifi/logging/LogRepositoryFactory.java  |  6 +-
 .../apache/nifi/controller/FlowController.java  | 35 ++---
 .../service/ControllerServiceLoader.java| 11 +--
 .../nifi/events/VolatileBulletinRepository.java | 18 +++--
 .../org/apache/nifi/jaxb/AdaptedBulletin.java   | 10 +++
 .../org/apache/nifi/jaxb/BulletinAdapter.java   |  3 +-
 .../logging/ControllerServiceLogObserver.java   | 45 +++
 .../nifi/logging/ReportingTaskLogObserver.java  | 45 +++
 .../nifi/remote/StandardRemoteProcessGroup.java | 16 ++--
 .../nifi/remote/StandardRootGroupPort.java  |  4 +-
 16 files changed, 349 insertions(+), 71 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/e240e07a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
index 87443a3..fe370ae 100644
--- a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
@@ -34,6 +34,7 @@ public abstract class Bulletin implements 
ComparableBulletin {
 private String groupId;
 private String sourceId;
 private String sourceName;
+private ComponentType sourceType;
 
 protected Bulletin(final long id) {
 this.timestamp = new Date();
@@ -104,9 +105,17 @@ public abstract class Bulletin implements 
ComparableBulletin {
 this.sourceName = sourceName;
 }
 
+public ComponentType getSourceType() {
+return sourceType;
+}
+
+public void setSourceType(ComponentType sourceType) {
+this.sourceType = sourceType;
+}
+
 @Override
 public String toString() {
-return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + '}';
+return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + , sourceType= + sourceType + '}';
 }
 
 @Override

http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/e240e07a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
new file mode 100644
index 000..97f3538
--- /dev/null
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the License); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.reporting;
+
+/**
+ * An Enumeration for indicating which type of component a Bulletin is 
associated with
+ */
+public enum ComponentType {
+
+/**
+ * Bulletin is associated with a Processor
+ */
+PROCESSOR,
+
+/**
+ * Bulletin is associated with a Remote Process Group
+ */
+REMOTE_PROCESS_GROUP,
+
+/**
+ * Bulletin is

[03/50] [abbrv] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

2015-07-16 Thread mcgilman

NIFI-724: Enable bulletins for reporting tasks and controller services


Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/f1adb8bf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/f1adb8bf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/f1adb8bf

Branch: refs/heads/master
Commit: f1adb8bf034a8407dfdd655e441c74c10a61b18f
Parents: e767f5c
Author: Mark Payne marka...@hotmail.com
Authored: Wed Jun 24 14:03:34 2015 -0400
Committer: Mark Payne marka...@hotmail.com
Committed: Wed Jun 24 14:03:34 2015 -0400

--
 .../org/apache/nifi/reporting/Bulletin.java | 11 ++-
 .../apache/nifi/reporting/ComponentType.java| 58 ++
 .../manager/impl/ClusteredReportingContext.java | 46 ++-
 .../cluster/manager/impl/WebClusterManager.java | 80 
 .../org/apache/nifi/events/BulletinFactory.java | 30 ++--
 .../org/apache/nifi/events/SystemBulletin.java  |  2 +
 .../nifi/logging/LogRepositoryFactory.java  |  6 +-
 .../apache/nifi/controller/FlowController.java  | 35 ++---
 .../service/ControllerServiceLoader.java| 11 +--
 .../nifi/events/VolatileBulletinRepository.java |  7 +-
 .../org/apache/nifi/jaxb/AdaptedBulletin.java   | 10 +++
 .../org/apache/nifi/jaxb/BulletinAdapter.java   |  3 +-
 .../logging/ControllerServiceLogObserver.java   | 45 +++
 .../nifi/logging/ReportingTaskLogObserver.java  | 45 +++
 .../nifi/remote/StandardRemoteProcessGroup.java | 16 ++--
 .../nifi/remote/StandardRootGroupPort.java  |  4 +-
 16 files changed, 341 insertions(+), 68 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f1adb8bf/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
index 87443a3..fe370ae 100644
--- a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
@@ -34,6 +34,7 @@ public abstract class Bulletin implements 
ComparableBulletin {
 private String groupId;
 private String sourceId;
 private String sourceName;
+private ComponentType sourceType;
 
 protected Bulletin(final long id) {
 this.timestamp = new Date();
@@ -104,9 +105,17 @@ public abstract class Bulletin implements 
ComparableBulletin {
 this.sourceName = sourceName;
 }
 
+public ComponentType getSourceType() {
+return sourceType;
+}
+
+public void setSourceType(ComponentType sourceType) {
+this.sourceType = sourceType;
+}
+
 @Override
 public String toString() {
-return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + '}';
+return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + , sourceType= + sourceType + '}';
 }
 
 @Override

http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f1adb8bf/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
new file mode 100644
index 000..97f3538
--- /dev/null
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the License); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.reporting;
+
+/**
+ * An Enumeration for indicating which type of component a Bulletin is 
associated with
+ */
+public enum ComponentType {
+
+/**
+ * Bulletin is associated with a Processor
+ */
+PROCESSOR,
+
+/**
+ * Bulletin is associated with a Remote Process Group
+ */
+REMOTE_PROCESS_GROUP,
+
+/**
+ * Bulletin is associated

[02/10] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

2015-07-02 Thread mcgilman

NIFI-724: Enable bulletins for reporting tasks and controller services


Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/e240e07a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/e240e07a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/e240e07a

Branch: refs/heads/develop
Commit: e240e07aaebea1fd66b22fce8aec3f0005fd3f60
Parents: e767f5c
Author: Mark Payne marka...@hotmail.com
Authored: Wed Jun 24 14:03:34 2015 -0400
Committer: Mark Payne marka...@hotmail.com
Committed: Thu Jun 25 10:56:49 2015 -0400

--
 .../org/apache/nifi/reporting/Bulletin.java | 11 ++-
 .../apache/nifi/reporting/ComponentType.java| 58 ++
 .../manager/impl/ClusteredReportingContext.java | 46 ++-
 .../cluster/manager/impl/WebClusterManager.java | 80 
 .../org/apache/nifi/events/BulletinFactory.java | 30 ++--
 .../org/apache/nifi/events/SystemBulletin.java  |  2 +
 .../nifi/logging/LogRepositoryFactory.java  |  6 +-
 .../apache/nifi/controller/FlowController.java  | 35 ++---
 .../service/ControllerServiceLoader.java| 11 +--
 .../nifi/events/VolatileBulletinRepository.java | 18 +++--
 .../org/apache/nifi/jaxb/AdaptedBulletin.java   | 10 +++
 .../org/apache/nifi/jaxb/BulletinAdapter.java   |  3 +-
 .../logging/ControllerServiceLogObserver.java   | 45 +++
 .../nifi/logging/ReportingTaskLogObserver.java  | 45 +++
 .../nifi/remote/StandardRemoteProcessGroup.java | 16 ++--
 .../nifi/remote/StandardRootGroupPort.java  |  4 +-
 16 files changed, 349 insertions(+), 71 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/e240e07a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
index 87443a3..fe370ae 100644
--- a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
@@ -34,6 +34,7 @@ public abstract class Bulletin implements 
ComparableBulletin {
 private String groupId;
 private String sourceId;
 private String sourceName;
+private ComponentType sourceType;
 
 protected Bulletin(final long id) {
 this.timestamp = new Date();
@@ -104,9 +105,17 @@ public abstract class Bulletin implements 
ComparableBulletin {
 this.sourceName = sourceName;
 }
 
+public ComponentType getSourceType() {
+return sourceType;
+}
+
+public void setSourceType(ComponentType sourceType) {
+this.sourceType = sourceType;
+}
+
 @Override
 public String toString() {
-return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + '}';
+return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + , sourceType= + sourceType + '}';
 }
 
 @Override

http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/e240e07a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
new file mode 100644
index 000..97f3538
--- /dev/null
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the License); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.reporting;
+
+/**
+ * An Enumeration for indicating which type of component a Bulletin is 
associated with
+ */
+public enum ComponentType {
+
+/**
+ * Bulletin is associated with a Processor
+ */
+PROCESSOR,
+
+/**
+ * Bulletin is associated with a Remote Process Group
+ */
+REMOTE_PROCESS_GROUP,
+
+/**
+ * Bulletin is

[01/10] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

2015-07-02 Thread mcgilman

Repository: incubator-nifi
Updated Branches:
  refs/heads/develop a09180799 - eddc071b8


NIFI-724: Enable bulletins for reporting tasks and controller services


Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/f1adb8bf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/f1adb8bf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/f1adb8bf

Branch: refs/heads/develop
Commit: f1adb8bf034a8407dfdd655e441c74c10a61b18f
Parents: e767f5c
Author: Mark Payne marka...@hotmail.com
Authored: Wed Jun 24 14:03:34 2015 -0400
Committer: Mark Payne marka...@hotmail.com
Committed: Wed Jun 24 14:03:34 2015 -0400

--
 .../org/apache/nifi/reporting/Bulletin.java | 11 ++-
 .../apache/nifi/reporting/ComponentType.java| 58 ++
 .../manager/impl/ClusteredReportingContext.java | 46 ++-
 .../cluster/manager/impl/WebClusterManager.java | 80 
 .../org/apache/nifi/events/BulletinFactory.java | 30 ++--
 .../org/apache/nifi/events/SystemBulletin.java  |  2 +
 .../nifi/logging/LogRepositoryFactory.java  |  6 +-
 .../apache/nifi/controller/FlowController.java  | 35 ++---
 .../service/ControllerServiceLoader.java| 11 +--
 .../nifi/events/VolatileBulletinRepository.java |  7 +-
 .../org/apache/nifi/jaxb/AdaptedBulletin.java   | 10 +++
 .../org/apache/nifi/jaxb/BulletinAdapter.java   |  3 +-
 .../logging/ControllerServiceLogObserver.java   | 45 +++
 .../nifi/logging/ReportingTaskLogObserver.java  | 45 +++
 .../nifi/remote/StandardRemoteProcessGroup.java | 16 ++--
 .../nifi/remote/StandardRootGroupPort.java  |  4 +-
 16 files changed, 341 insertions(+), 68 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f1adb8bf/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
index 87443a3..fe370ae 100644
--- a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
@@ -34,6 +34,7 @@ public abstract class Bulletin implements 
ComparableBulletin {
 private String groupId;
 private String sourceId;
 private String sourceName;
+private ComponentType sourceType;
 
 protected Bulletin(final long id) {
 this.timestamp = new Date();
@@ -104,9 +105,17 @@ public abstract class Bulletin implements 
ComparableBulletin {
 this.sourceName = sourceName;
 }
 
+public ComponentType getSourceType() {
+return sourceType;
+}
+
+public void setSourceType(ComponentType sourceType) {
+this.sourceType = sourceType;
+}
+
 @Override
 public String toString() {
-return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + '}';
+return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + , sourceType= + sourceType + '}';
 }
 
 @Override

http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f1adb8bf/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
new file mode 100644
index 000..97f3538
--- /dev/null
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the License); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.reporting;
+
+/**
+ * An Enumeration for indicating which type of component a Bulletin is 
associated with
+ */
+public enum ComponentType {
+
+/**
+ * Bulletin is associated with a Processor
+ */
+PROCESSOR,
+
+/**
+ * Bulletin is associated with a Remote

[1/2] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

2015-06-25 Thread markap14

Repository: incubator-nifi
Updated Branches:
  refs/heads/NIFI-724 f1adb8bf0 - 0a7ab1a06


NIFI-724: Enable bulletins for reporting tasks and controller services


Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/e240e07a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/e240e07a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/e240e07a

Branch: refs/heads/NIFI-724
Commit: e240e07aaebea1fd66b22fce8aec3f0005fd3f60
Parents: e767f5c
Author: Mark Payne marka...@hotmail.com
Authored: Wed Jun 24 14:03:34 2015 -0400
Committer: Mark Payne marka...@hotmail.com
Committed: Thu Jun 25 10:56:49 2015 -0400

--
 .../org/apache/nifi/reporting/Bulletin.java | 11 ++-
 .../apache/nifi/reporting/ComponentType.java| 58 ++
 .../manager/impl/ClusteredReportingContext.java | 46 ++-
 .../cluster/manager/impl/WebClusterManager.java | 80 
 .../org/apache/nifi/events/BulletinFactory.java | 30 ++--
 .../org/apache/nifi/events/SystemBulletin.java  |  2 +
 .../nifi/logging/LogRepositoryFactory.java  |  6 +-
 .../apache/nifi/controller/FlowController.java  | 35 ++---
 .../service/ControllerServiceLoader.java| 11 +--
 .../nifi/events/VolatileBulletinRepository.java | 18 +++--
 .../org/apache/nifi/jaxb/AdaptedBulletin.java   | 10 +++
 .../org/apache/nifi/jaxb/BulletinAdapter.java   |  3 +-
 .../logging/ControllerServiceLogObserver.java   | 45 +++
 .../nifi/logging/ReportingTaskLogObserver.java  | 45 +++
 .../nifi/remote/StandardRemoteProcessGroup.java | 16 ++--
 .../nifi/remote/StandardRootGroupPort.java  |  4 +-
 16 files changed, 349 insertions(+), 71 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/e240e07a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
index 87443a3..fe370ae 100644
--- a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
@@ -34,6 +34,7 @@ public abstract class Bulletin implements 
ComparableBulletin {
 private String groupId;
 private String sourceId;
 private String sourceName;
+private ComponentType sourceType;
 
 protected Bulletin(final long id) {
 this.timestamp = new Date();
@@ -104,9 +105,17 @@ public abstract class Bulletin implements 
ComparableBulletin {
 this.sourceName = sourceName;
 }
 
+public ComponentType getSourceType() {
+return sourceType;
+}
+
+public void setSourceType(ComponentType sourceType) {
+this.sourceType = sourceType;
+}
+
 @Override
 public String toString() {
-return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + '}';
+return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + , sourceType= + sourceType + '}';
 }
 
 @Override

http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/e240e07a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
new file mode 100644
index 000..97f3538
--- /dev/null
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the License); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.reporting;
+
+/**
+ * An Enumeration for indicating which type of component a Bulletin is 
associated with
+ */
+public enum ComponentType {
+
+/**
+ * Bulletin is associated with a Processor
+ */
+PROCESSOR,
+
+/**
+ * Bulletin is associated with a

incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

2015-06-24 Thread markap14

Repository: incubator-nifi
Updated Branches:
  refs/heads/NIFI-724 [created] f1adb8bf0


NIFI-724: Enable bulletins for reporting tasks and controller services


Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/f1adb8bf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/f1adb8bf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/f1adb8bf

Branch: refs/heads/NIFI-724
Commit: f1adb8bf034a8407dfdd655e441c74c10a61b18f
Parents: e767f5c
Author: Mark Payne marka...@hotmail.com
Authored: Wed Jun 24 14:03:34 2015 -0400
Committer: Mark Payne marka...@hotmail.com
Committed: Wed Jun 24 14:03:34 2015 -0400

--
 .../org/apache/nifi/reporting/Bulletin.java | 11 ++-
 .../apache/nifi/reporting/ComponentType.java| 58 ++
 .../manager/impl/ClusteredReportingContext.java | 46 ++-
 .../cluster/manager/impl/WebClusterManager.java | 80 
 .../org/apache/nifi/events/BulletinFactory.java | 30 ++--
 .../org/apache/nifi/events/SystemBulletin.java  |  2 +
 .../nifi/logging/LogRepositoryFactory.java  |  6 +-
 .../apache/nifi/controller/FlowController.java  | 35 ++---
 .../service/ControllerServiceLoader.java| 11 +--
 .../nifi/events/VolatileBulletinRepository.java |  7 +-
 .../org/apache/nifi/jaxb/AdaptedBulletin.java   | 10 +++
 .../org/apache/nifi/jaxb/BulletinAdapter.java   |  3 +-
 .../logging/ControllerServiceLogObserver.java   | 45 +++
 .../nifi/logging/ReportingTaskLogObserver.java  | 45 +++
 .../nifi/remote/StandardRemoteProcessGroup.java | 16 ++--
 .../nifi/remote/StandardRootGroupPort.java  |  4 +-
 16 files changed, 341 insertions(+), 68 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f1adb8bf/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
index 87443a3..fe370ae 100644
--- a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/Bulletin.java
@@ -34,6 +34,7 @@ public abstract class Bulletin implements 
ComparableBulletin {
 private String groupId;
 private String sourceId;
 private String sourceName;
+private ComponentType sourceType;
 
 protected Bulletin(final long id) {
 this.timestamp = new Date();
@@ -104,9 +105,17 @@ public abstract class Bulletin implements 
ComparableBulletin {
 this.sourceName = sourceName;
 }
 
+public ComponentType getSourceType() {
+return sourceType;
+}
+
+public void setSourceType(ComponentType sourceType) {
+this.sourceType = sourceType;
+}
+
 @Override
 public String toString() {
-return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + '}';
+return Bulletin{ + id= + id + , message= + message + , 
sourceName= + sourceName + , sourceType= + sourceType + '}';
 }
 
 @Override

http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f1adb8bf/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
--
diff --git 
a/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java 
b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
new file mode 100644
index 000..97f3538
--- /dev/null
+++ b/nifi/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the License); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.reporting;
+
+/**
+ * An Enumeration for indicating which type of component a Bulletin is 
associated with
+ */
+public enum ComponentType {
+
+/**
+ * Bulletin is associated with a Processor
+ */
+PROCESSOR,
+
+/**
+ * Bulletin is associated with a Remote

[05/50] [abbrv] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

[03/50] [abbrv] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

[02/10] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

[01/10] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

[1/2] incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

incubator-nifi git commit: NIFI-724: Enable bulletins for reporting tasks and controller services

6 matches

Site Navigation

Mail list logo

Footer information