alopresto commented on a change in pull request #4289:
URL: https://github.com/apache/nifi/pull/4289#discussion_r435634210
##########
File path:
nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/PeerStatusProvider.java
##########
@@ -52,12 +51,25 @@
* Fetch peer statuses from a remote NiFi cluster.
* Implementation of this method should fetch peer statuses from the node
* represented by the passed PeerDescription using its transport protocol.
+ *
* @param peerDescription a bootstrap node or one of query-able nodes
lastly fetched successfully
* @return Remote peer statuses
* @throws IOException thrown when it fails to fetch peer statuses of the
remote cluster from the specified peer
*/
Set<PeerStatus> fetchRemotePeerStatuses(final PeerDescription
peerDescription) throws IOException;
+ /**
+ * Fetch peer statuses from a remote NiFi cluster.
+ * Implementation of this method should fetch peer statuses from the node
+ * represented by the passed PeerDescription using its transport protocol.
+ *
+ * @param peerDescription a bootstrap node or one of query-able nodes
lastly fetched successfully
+ * @param communicator the communication mechanism provider can be
provided directly
+ * @return Remote peer statuses
+ * @throws IOException thrown when it fails to fetch peer statuses of the
remote cluster from the specified peer
+ */
+ Set<PeerStatus> fetchRemotePeerStatuses(final PeerDescription
peerDescription, SiteToSiteCommunicator communicator) throws IOException;
Review comment:
This was only used once internal to `HttpClient`, so I just removed it
from the interface and cleaned up the unsupported implementation.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
