Repository: nifi Updated Branches: refs/heads/master 9064b9763 -> b4e4f3eed
Removing erroneously included files. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/b4e4f3ee Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/b4e4f3ee Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/b4e4f3ee Branch: refs/heads/master Commit: b4e4f3eed5be766cc7e14b96db96a86a54b051ee Parents: 9064b97 Author: Aldrin Piri <[email protected]> Authored: Sat May 7 15:01:24 2016 -0400 Committer: Aldrin Piri <[email protected]> Committed: Sat May 7 15:01:24 2016 -0400 ---------------------------------------------------------------------- ...ackage: org.apache.nifi.cluster.coordination | 62 -------------------- ...ava~eded0de154e2fcb543eda68e510bee06f0779f10 | 62 -------------------- 2 files changed, 124 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/b4e4f3ee/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/message/NodeStatusChangeMessage.java~NIFI-1678: Started refactoring heartbeating mechanism, using a new package: org.apache.nifi.cluster.coordination ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/message/NodeStatusChangeMessage.java~NIFI-1678: Started refactoring heartbeating mechanism, using a new package: org.apache.nifi.cluster.coordination b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/message/NodeStatusChangeMessage.java~NIFI-1678: Started refactoring heartbeating mechanism, using a new package: org.apache.nifi.cluster.coordination deleted file mode 100644 index 7a99d0e..0000000 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/message/NodeStatusChangeMessage.java~NIFI-1678: Started refactoring heartbeating mechanism, using a new package: org.apache.nifi.cluster.coordination +++ /dev/null @@ -1,62 +0,0 @@ -/* - * 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.cluster.protocol.message; - -import javax.xml.bind.annotation.XmlRootElement; - -import org.apache.nifi.cluster.coordination.node.NodeConnectionStatus; -import org.apache.nifi.cluster.protocol.NodeIdentifier; - -/** - * Message to indicate that the status of a node in the cluster has changed - */ -@XmlRootElement(name = "nodeStatusChange") -public class NodeStatusChangeMessage extends ProtocolMessage { - private NodeConnectionStatus connectionStatus; - private NodeIdentifier nodeId; - private Long statusUpdateId = -1L; - - @Override - public MessageType getType() { - return MessageType.NODE_STATUS_CHANGE; - } - - public void setNodeConnectionStatus(final NodeConnectionStatus status) { - this.connectionStatus = status; - } - - public NodeConnectionStatus getNodeConnectionStatus() { - return connectionStatus; - } - - public NodeIdentifier getNodeId() { - return nodeId; - } - - public void setNodeId(NodeIdentifier nodeId) { - this.nodeId = nodeId; - } - - public Long getStatusUpdateIdentifier() { - return statusUpdateId; - } - - public void setStatusUpdateIdentifier(Long statusUpdateId) { - this.statusUpdateId = statusUpdateId; - } -} http://git-wip-us.apache.org/repos/asf/nifi/blob/b4e4f3ee/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/message/NodeStatusChangeMessage.java~eded0de154e2fcb543eda68e510bee06f0779f10 ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/message/NodeStatusChangeMessage.java~eded0de154e2fcb543eda68e510bee06f0779f10 b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/message/NodeStatusChangeMessage.java~eded0de154e2fcb543eda68e510bee06f0779f10 deleted file mode 100644 index 7a99d0e..0000000 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/message/NodeStatusChangeMessage.java~eded0de154e2fcb543eda68e510bee06f0779f10 +++ /dev/null @@ -1,62 +0,0 @@ -/* - * 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.cluster.protocol.message; - -import javax.xml.bind.annotation.XmlRootElement; - -import org.apache.nifi.cluster.coordination.node.NodeConnectionStatus; -import org.apache.nifi.cluster.protocol.NodeIdentifier; - -/** - * Message to indicate that the status of a node in the cluster has changed - */ -@XmlRootElement(name = "nodeStatusChange") -public class NodeStatusChangeMessage extends ProtocolMessage { - private NodeConnectionStatus connectionStatus; - private NodeIdentifier nodeId; - private Long statusUpdateId = -1L; - - @Override - public MessageType getType() { - return MessageType.NODE_STATUS_CHANGE; - } - - public void setNodeConnectionStatus(final NodeConnectionStatus status) { - this.connectionStatus = status; - } - - public NodeConnectionStatus getNodeConnectionStatus() { - return connectionStatus; - } - - public NodeIdentifier getNodeId() { - return nodeId; - } - - public void setNodeId(NodeIdentifier nodeId) { - this.nodeId = nodeId; - } - - public Long getStatusUpdateIdentifier() { - return statusUpdateId; - } - - public void setStatusUpdateIdentifier(Long statusUpdateId) { - this.statusUpdateId = statusUpdateId; - } -}
