org.robokind.demo.robot.replication.chain
Class NodeLinkLifecycleUtils

java.lang.Object
  org.robokind.demo.robot.replication.chain.NodeLinkLifecycleUtils

public class NodeLinkLifecycleUtils
extends Object

Author:

Matthew Stevenson

Field Summary

static String

PROP_NODE_LINK_ID

Constructor Summary

NodeLinkLifecycleUtils()

Method Summary

static <T,N extends org.jflux.api.core.node.Node> org.jflux.api.core.config.Configuration<String>	buildListeningDepConfig(Class<N> nodeClass, String nodeIdKey, String nodeId, Properties props)
static <T,A extends org.jflux.api.core.node.Node,B extends org.jflux.api.core.node.Node> org.jflux.api.core.config.Configuration<String>	buildNodeLifecycleConfig(String linkIdKey, String linkId, org.jflux.api.core.config.Configuration<String> notifyingConfig, org.jflux.api.core.config.Configuration<String> listeningConfig, Properties linkProperties, org.jflux.api.core.Adapter<A,org.jflux.api.core.Notifier<T>> adapterA, org.jflux.api.core.Adapter<B,org.jflux.api.core.Listener<T>> adapterB)
static <T,N extends org.jflux.api.core.node.Node> org.jflux.api.core.config.Configuration<String>	buildNotifyingDepConfig(Class<N> nodeClass, String nodeIdKey, String nodeId, Properties props)
static <T,A extends org.jflux.api.core.node.Node,B extends org.jflux.api.core.node.Node> org.jflux.api.core.config.Configuration<String>	nodeLinkLifecycleConfig(String idKey, String id, Properties linkProps, Class<A> notifyingNodeClass, String notifyingNodeIdKey, String notifyingNodeId, Properties notifyingProps, org.jflux.api.core.Adapter<A,org.jflux.api.core.Notifier<T>> adapterA, Class<B> listeningNodeClass, String listeningNodeIdKey, String listeningNodeId, Properties listeningProps, org.jflux.api.core.Adapter<B,org.jflux.api.core.Listener<T>> adapterB)
static <T> org.jflux.api.core.config.Configuration<String>	processorConsumerLinkLifecycleConfig(String id, Properties linkProps, String notifyingNodeIdKey, String notifyingNodeId, Properties notifyingProps, String listeningNodeIdKey, String listeningNodeId, Properties listeningProps)
static <T> org.jflux.api.core.config.Configuration<String>	processorLinkLifecycleConfig(String id, Properties linkProps, String notifyingNodeIdKey, String notifyingNodeId, Properties notifyingProps, String listeningNodeIdKey, String listeningNodeId, Properties listeningProps)
static <T> org.jflux.api.core.config.Configuration<String>	producerConsumerLinkLifecycleConfig(String id, Properties linkProps, String notifyingNodeIdKey, String notifyingNodeId, Properties notifyingProps, String listeningNodeIdKey, String listeningNodeId, Properties listeningProps)
static <T> org.jflux.api.core.config.Configuration<String>	producerProcessorLinkLifecycleConfig(String id, Properties linkProps, String notifyingNodeIdKey, String notifyingNodeId, Properties notifyingProps, String listeningNodeIdKey, String listeningNodeId, Properties listeningProps)

Methods inherited from class java.lang.Object

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

Field Detail

PROP_NODE_LINK_ID

public static final String PROP_NODE_LINK_ID

See Also:

Constant Field Values

Constructor Detail

NodeLinkLifecycleUtils

public NodeLinkLifecycleUtils()

Method Detail

producerConsumerLinkLifecycleConfig

public static <T> org.jflux.api.core.config.Configuration<String> producerConsumerLinkLifecycleConfig(String id,
                                                                                                      Properties linkProps,
                                                                                                      String notifyingNodeIdKey,
                                                                                                      String notifyingNodeId,
                                                                                                      Properties notifyingProps,
                                                                                                      String listeningNodeIdKey,
                                                                                                      String listeningNodeId,
                                                                                                      Properties listeningProps)

producerProcessorLinkLifecycleConfig

public static <T> org.jflux.api.core.config.Configuration<String> producerProcessorLinkLifecycleConfig(String id,
                                                                                                       Properties linkProps,
                                                                                                       String notifyingNodeIdKey,
                                                                                                       String notifyingNodeId,
                                                                                                       Properties notifyingProps,
                                                                                                       String listeningNodeIdKey,
                                                                                                       String listeningNodeId,
                                                                                                       Properties listeningProps)

processorConsumerLinkLifecycleConfig

public static <T> org.jflux.api.core.config.Configuration<String> processorConsumerLinkLifecycleConfig(String id,
                                                                                                       Properties linkProps,
                                                                                                       String notifyingNodeIdKey,
                                                                                                       String notifyingNodeId,
                                                                                                       Properties notifyingProps,
                                                                                                       String listeningNodeIdKey,
                                                                                                       String listeningNodeId,
                                                                                                       Properties listeningProps)

processorLinkLifecycleConfig

public static <T> org.jflux.api.core.config.Configuration<String> processorLinkLifecycleConfig(String id,
                                                                                               Properties linkProps,
                                                                                               String notifyingNodeIdKey,
                                                                                               String notifyingNodeId,
                                                                                               Properties notifyingProps,
                                                                                               String listeningNodeIdKey,
                                                                                               String listeningNodeId,
                                                                                               Properties listeningProps)

nodeLinkLifecycleConfig

public static <T,A extends org.jflux.api.core.node.Node,B extends org.jflux.api.core.node.Node> org.jflux.api.core.config.Configuration<String> nodeLinkLifecycleConfig(String idKey,
                                                                                                                                                                        String id,
                                                                                                                                                                        Properties linkProps,
                                                                                                                                                                        Class<A> notifyingNodeClass,
                                                                                                                                                                        String notifyingNodeIdKey,
                                                                                                                                                                        String notifyingNodeId,
                                                                                                                                                                        Properties notifyingProps,
                                                                                                                                                                        org.jflux.api.core.Adapter<A,org.jflux.api.core.Notifier<T>> adapterA,
                                                                                                                                                                        Class<B> listeningNodeClass,
                                                                                                                                                                        String listeningNodeIdKey,
                                                                                                                                                                        String listeningNodeId,
                                                                                                                                                                        Properties listeningProps,
                                                                                                                                                                        org.jflux.api.core.Adapter<B,org.jflux.api.core.Listener<T>> adapterB)

buildNodeLifecycleConfig

public static <T,A extends org.jflux.api.core.node.Node,B extends org.jflux.api.core.node.Node> org.jflux.api.core.config.Configuration<String> buildNodeLifecycleConfig(String linkIdKey,
                                                                                                                                                                         String linkId,
                                                                                                                                                                         org.jflux.api.core.config.Configuration<String> notifyingConfig,
                                                                                                                                                                         org.jflux.api.core.config.Configuration<String> listeningConfig,
                                                                                                                                                                         Properties linkProperties,
                                                                                                                                                                         org.jflux.api.core.Adapter<A,org.jflux.api.core.Notifier<T>> adapterA,
                                                                                                                                                                         org.jflux.api.core.Adapter<B,org.jflux.api.core.Listener<T>> adapterB)

buildNotifyingDepConfig

public static <T,N extends org.jflux.api.core.node.Node> org.jflux.api.core.config.Configuration<String> buildNotifyingDepConfig(Class<N> nodeClass,
                                                                                                                                 String nodeIdKey,
                                                                                                                                 String nodeId,
                                                                                                                                 Properties props)

buildListeningDepConfig

public static <T,N extends org.jflux.api.core.node.Node> org.jflux.api.core.config.Configuration<String> buildListeningDepConfig(Class<N> nodeClass,
                                                                                                                                 String nodeIdKey,
                                                                                                                                 String nodeId,
                                                                                                                                 Properties props)