org.apache.nifi.cluster.protocol

Class ConnectionResponse

java.lang.Object

org.apache.nifi.cluster.protocol.ConnectionResponse

public class ConnectionResponse
extends java.lang.Object

The cluster manager's response to a node's connection request. If the manager has a current copy of the data flow, then it is returned with a node identifier to the node. Otherwise, the manager will provide a "try again in X seconds" response to the node in hopes that a current data flow will be available upon subsequent requests.

Constructor Summary

Constructors

Constructor and Description
ConnectionResponse(int tryLaterSeconds, java.lang.String explanation)
ConnectionResponse(NodeIdentifier nodeIdentifier, DataFlow dataFlow, java.lang.String instanceId, java.util.List<NodeConnectionStatus> nodeStatuses, java.util.List<ComponentRevision> componentRevisions)

Method Summary

Modifier and Type	Method and Description
static ConnectionResponse	createBlockedByFirewallResponse()
static ConnectionResponse	createConflictingNodeIdResponse(java.lang.String otherNode)
static ConnectionResponse	createRejectionResponse(java.lang.String explanation)
java.util.List<ComponentRevision>	getComponentRevisions()
DataFlow	getDataFlow()
java.lang.String	getInstanceId()
java.util.List<NodeConnectionStatus>	getNodeConnectionStatuses()
NodeIdentifier	getNodeIdentifier()
java.lang.String	getRejectionReason()
int	getTryLaterSeconds()
boolean	shouldTryLater()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectionResponse

public ConnectionResponse(NodeIdentifier nodeIdentifier,
                          DataFlow dataFlow,
                          java.lang.String instanceId,
                          java.util.List<NodeConnectionStatus> nodeStatuses,
                          java.util.List<ComponentRevision> componentRevisions)

ConnectionResponse

public ConnectionResponse(int tryLaterSeconds,
                          java.lang.String explanation)

Method Detail

createBlockedByFirewallResponse

public static ConnectionResponse createBlockedByFirewallResponse()

createConflictingNodeIdResponse

public static ConnectionResponse createConflictingNodeIdResponse(java.lang.String otherNode)

createRejectionResponse

public static ConnectionResponse createRejectionResponse(java.lang.String explanation)

shouldTryLater

public boolean shouldTryLater()

getRejectionReason

public java.lang.String getRejectionReason()

getTryLaterSeconds

public int getTryLaterSeconds()

getDataFlow

public DataFlow getDataFlow()

getNodeIdentifier

public NodeIdentifier getNodeIdentifier()

getInstanceId

public java.lang.String getInstanceId()

getNodeConnectionStatuses

public java.util.List<NodeConnectionStatus> getNodeConnectionStatuses()

getComponentRevisions

public java.util.List<ComponentRevision> getComponentRevisions()