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

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

public class ReplicationSenderGroupLifecycleUtils
extends Object

Author:

Matthew Stevenson

Field Summary

static String	BUF_EVENT_ENCODER_ID
static String	BUF_EVENT_FACTORY_ID
static String	COLLECTION_TIMER_ID
static String	EVENT_BUFFER_TRACKER_ID
static String	EVENT_COLLECTOR_ID
static String	EVENT_LIST_RECORD_ENCODE_CONFIG_FULL_ID
static String	GROUP_TYPE
static String	LINK_COLLECTION_TIMER_ID
static String	LINK_SENDER_ID
static String	MESSAGE_HEADER_ID
static String	MESSAGE_PACKER_ID
static String	REMOTE_REPLICATION_NODE_ID
static String	REPLICATION_CONNECTION_ID
static String	REPLICATION_DESTINATION_ID
static String	REPLICATION_SENDER_ID
static String	REPLICATION_SESSION_ID

Constructor Summary

ReplicationSenderGroupLifecycleUtils()

Method Summary

static List<org.jflux.api.core.config.Configuration<String>>	getAlternateReplicationBufferLifecycleConfigs(String groupId, String eventBufferId, String encodeConfigId, org.jflux.api.core.Source valueSource)
static List<org.jflux.api.core.config.Configuration<String>>	getCollectorLifecycleConfigs(String groupId, org.osgi.framework.BundleContext context, Properties collectorProps, long initialDelay, long period, Properties timerProps)
static List<org.jflux.api.core.config.Configuration<String>>	getJMSLifecycleConfigs(String groupId, String destinationConfId, String connectionConfId)
static List<org.jflux.api.core.config.Configuration<String>>	getReplicationBufferLifecycleConfigs(String groupId, String eventBufferId, String encodeConfigId, Properties bufferProps, int bufferCapacity)
static List<org.jflux.api.core.config.Configuration<String>>	getReplicationSenderLifecycleConfigs(String groupId)
static String	id(String groupId, String part)

Methods inherited from class java.lang.Object

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

Field Detail

EVENT_LIST_RECORD_ENCODE_CONFIG_FULL_ID

public static final String EVENT_LIST_RECORD_ENCODE_CONFIG_FULL_ID

REPLICATION_DESTINATION_ID

public static final String REPLICATION_DESTINATION_ID

See Also:

Constant Field Values

REPLICATION_CONNECTION_ID

public static final String REPLICATION_CONNECTION_ID

See Also:

Constant Field Values

REPLICATION_SESSION_ID

public static final String REPLICATION_SESSION_ID

See Also:

Constant Field Values

MESSAGE_PACKER_ID

public static final String MESSAGE_PACKER_ID

See Also:

Constant Field Values

MESSAGE_HEADER_ID

public static final String MESSAGE_HEADER_ID

See Also:

Constant Field Values

REMOTE_REPLICATION_NODE_ID

public static final String REMOTE_REPLICATION_NODE_ID

See Also:

Constant Field Values

REPLICATION_SENDER_ID

public static final String REPLICATION_SENDER_ID

See Also:

Constant Field Values

BUF_EVENT_FACTORY_ID

public static final String BUF_EVENT_FACTORY_ID

See Also:

Constant Field Values

BUF_EVENT_ENCODER_ID

public static final String BUF_EVENT_ENCODER_ID

See Also:

Constant Field Values

EVENT_COLLECTOR_ID

public static final String EVENT_COLLECTOR_ID

See Also:

Constant Field Values

EVENT_BUFFER_TRACKER_ID

public static final String EVENT_BUFFER_TRACKER_ID

See Also:

Constant Field Values

LINK_SENDER_ID

public static final String LINK_SENDER_ID

See Also:

Constant Field Values

LINK_COLLECTION_TIMER_ID

public static final String LINK_COLLECTION_TIMER_ID

See Also:

Constant Field Values

COLLECTION_TIMER_ID

public static final String COLLECTION_TIMER_ID

See Also:

Constant Field Values

GROUP_TYPE

public static final String GROUP_TYPE

See Also:

Constant Field Values

Constructor Detail

ReplicationSenderGroupLifecycleUtils

public ReplicationSenderGroupLifecycleUtils()

Method Detail

id

public static String id(String groupId,
                        String part)

getReplicationSenderLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getReplicationSenderLifecycleConfigs(String groupId)

getJMSLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getJMSLifecycleConfigs(String groupId,
                                                                                           String destinationConfId,
                                                                                           String connectionConfId)

getReplicationBufferLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getReplicationBufferLifecycleConfigs(String groupId,
                                                                                                         String eventBufferId,
                                                                                                         String encodeConfigId,
                                                                                                         Properties bufferProps,
                                                                                                         int bufferCapacity)

getAlternateReplicationBufferLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getAlternateReplicationBufferLifecycleConfigs(String groupId,
                                                                                                                  String eventBufferId,
                                                                                                                  String encodeConfigId,
                                                                                                                  org.jflux.api.core.Source valueSource)

getCollectorLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getCollectorLifecycleConfigs(String groupId,
                                                                                                 org.osgi.framework.BundleContext context,
                                                                                                 Properties collectorProps,
                                                                                                 long initialDelay,
                                                                                                 long period,
                                                                                                 Properties timerProps)