org.robokind.demo.robot.replication.lifecycle
Class ReplicationReceiverLifecycleUtils

java.lang.Object
  org.robokind.demo.robot.replication.lifecycle.ReplicationReceiverLifecycleUtils

public class ReplicationReceiverLifecycleUtils
extends Object

Author:

Matthew Stevenson

Constructor Summary

ReplicationReceiverLifecycleUtils()

Method Summary

static <T,R extends org.apache.avro.specific.SpecificRecordBase> org.jflux.api.core.config.Configuration<String>	buildDecoderRouteLinkLifecycleConfig(String linkIdKey, String linkId, String routerIdKey, String routerId, String encodeConfigIdKey, String encodeConfigId)
static org.jflux.api.core.config.Configuration<String>	buildEventListDecoderNodeLifecycleConfig(String eventListDecoderIdKey, String eventListDecoderId)
static <T> org.jflux.api.core.config.Configuration<String>	buildEventRouteLinkLifecycleConfig(String linkIdKey, String linkId, String routerIdKey, String routerId, String consumerIdKey, String consumerId, String routeKey)
static org.jflux.api.core.config.Configuration<String>	buildListDecoderRouterLinkLifecycleConfigs(String listDecoderRouterLinkId, String listDecoderIdKey, String listDecoderId, String routerIdKey, String routerId)
static org.jflux.api.core.config.Configuration<String>	buildReceiverLifecycleConfig(String receiverIdKey, String receiverId, String destinationIdKey, String destinationId, String sessionIdKey, String sessionId)
static org.jflux.api.core.config.Configuration<String>	buildReceiverListDecoderLinkLifecycleConfigs(String receiverListDecoderLinkId, String receiverIdKey, String receiverId, String listDecoderIdKey, String listDecoderId)
static org.jflux.api.core.config.Configuration<String>	buildRoutingDecoderLifecycleConfig(String nodeIdKey, String nodeId)
static List<org.jflux.api.core.config.Configuration<String>>	getLifecycleConfigs(String routerNodeIdKey, String routerNodeId, String eventListDecoderIdKey, String eventListDecoderId, String receiverIdKey, String receiverId, String destinationIdKey, String destinationId, String sessionIdKey, String sessionId, String receiverListDecoderLinkId, String listDecoderRouterLinkId)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationReceiverLifecycleUtils

public ReplicationReceiverLifecycleUtils()

Method Detail

getLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getLifecycleConfigs(String routerNodeIdKey,
                                                                                        String routerNodeId,
                                                                                        String eventListDecoderIdKey,
                                                                                        String eventListDecoderId,
                                                                                        String receiverIdKey,
                                                                                        String receiverId,
                                                                                        String destinationIdKey,
                                                                                        String destinationId,
                                                                                        String sessionIdKey,
                                                                                        String sessionId,
                                                                                        String receiverListDecoderLinkId,
                                                                                        String listDecoderRouterLinkId)

buildReceiverListDecoderLinkLifecycleConfigs

public static org.jflux.api.core.config.Configuration<String> buildReceiverListDecoderLinkLifecycleConfigs(String receiverListDecoderLinkId,
                                                                                                           String receiverIdKey,
                                                                                                           String receiverId,
                                                                                                           String listDecoderIdKey,
                                                                                                           String listDecoderId)

buildListDecoderRouterLinkLifecycleConfigs

public static org.jflux.api.core.config.Configuration<String> buildListDecoderRouterLinkLifecycleConfigs(String listDecoderRouterLinkId,
                                                                                                         String listDecoderIdKey,
                                                                                                         String listDecoderId,
                                                                                                         String routerIdKey,
                                                                                                         String routerId)

buildEventListDecoderNodeLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildEventListDecoderNodeLifecycleConfig(String eventListDecoderIdKey,
                                                                                                       String eventListDecoderId)

buildReceiverLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildReceiverLifecycleConfig(String receiverIdKey,
                                                                                           String receiverId,
                                                                                           String destinationIdKey,
                                                                                           String destinationId,
                                                                                           String sessionIdKey,
                                                                                           String sessionId)

buildRoutingDecoderLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildRoutingDecoderLifecycleConfig(String nodeIdKey,
                                                                                                 String nodeId)

buildDecoderRouteLinkLifecycleConfig

public static <T,R extends org.apache.avro.specific.SpecificRecordBase> org.jflux.api.core.config.Configuration<String> buildDecoderRouteLinkLifecycleConfig(String linkIdKey,
                                                                                                                                                             String linkId,
                                                                                                                                                             String routerIdKey,
                                                                                                                                                             String routerId,
                                                                                                                                                             String encodeConfigIdKey,
                                                                                                                                                             String encodeConfigId)

buildEventRouteLinkLifecycleConfig

public static <T> org.jflux.api.core.config.Configuration<String> buildEventRouteLinkLifecycleConfig(String linkIdKey,
                                                                                                     String linkId,
                                                                                                     String routerIdKey,
                                                                                                     String routerId,
                                                                                                     String consumerIdKey,
                                                                                                     String consumerId,
                                                                                                     String routeKey)