Package com.nt.udc.testnodechain.callbacks.helper

Class TNCReceiverManager

java.lang.Object
com.nt.udc.testnodechain.callbacks.helper.TNCReceiverManager
public class TNCReceiverManager extends Object
Manages the receivers for TNC events, handling mappings between test IDs, receiver IDs, and corresponding event receivers. Additionally, the class provides various methods for querying test and receiver-specific details. Internally a failureCounter map keeps track of the number of failures encountered while sending events to each receiver, and receivers exceeding the defined failure threshold will be removed and the registered removeReceiverCallback would be called.

  • Constructor Details

    • TNCReceiverManager

      public TNCReceiverManager(Function<String,Boolean> removeReceiverCallback)
      Constructs a TNCReceiverManager with the provided callback function. The callback method is called when a receiver is removed due to failure threshold breach

  • Method Details

    • addReceiver

      public void addReceiver(String receiverID, TNCEventReceiverIfc receiver)

    • addReceiver

      public void addReceiver(String receiverID, TNCEventReceiverIfc receiver, boolean subForAllTests)

    • subscribeForTest

      public boolean subscribeForTest(String receiverID, String testID)

    • getAllReceivers

      public Set<String> getAllReceivers()

    • getAllTests

      public Set<String> getAllTests()

    • getBroadcastReceivers

      public Set<String> getBroadcastReceivers()

    • getTestExclusiveReceivers

      public Set<String> getTestExclusiveReceivers(String testId)

    • getTestReceivers

      public Set<String> getTestReceivers(Set<String> testIds)

    • getTestReceiver

      public Set<String> getTestReceiver(String testId)

    • getReceiver

      public TNCEventReceiverIfc getReceiver(String receiverId)

    • removeReceiver

      public void removeReceiver(String receiverID)

    • unsubscribeReceiversFromTest

      public void unsubscribeReceiversFromTest(String testId)

    • incrementFailureCount

      public void incrementFailureCount(String receiverID)

    • logInfo

      public void logInfo(String x, Exception e)

    • logInfo

      public void logInfo(String x)

    • logDebug

      public void logDebug(Supplier<String> x)

    • logDebug

      public void logDebug(Supplier<String> x, Exception e)

    • clear

      public void clear()

    • toString

      public String toString()
      Overrides:
      toString in class Object