org.robokind.demo.robot.replication
Class ReplicationUtils

java.lang.Object
  org.robokind.demo.robot.replication.ReplicationUtils

public class ReplicationUtils
extends Object

Author:

matt

Field Summary

static String	BUFFER_LINK_ID_SUFFIX
static String	DECODER_LINK_ID_SUFFIX
static String	ROUTE_LINK_ID_SUFFIX

Constructor Summary

ReplicationUtils()

Method Summary

static <T> ManagedServiceGroup	createAlternateReplicationBuffer(String replicationGroupId, String bufferRouteKey, org.jflux.api.core.Source<T> valueSource, Class<T> messageClass, ManagedServiceFactory fact)
static <T> ManagedServiceGroup	createReceiverRoute(String receiverGroupId, String routingKey, String consumerIdKey, String consumerId, Class<T> messageClass, ManagedServiceFactory fact)
static <T> ManagedServiceGroup	createReplicationBuffer(String replicationGroupId, String bufferId, String producerIdKey, String producerId, int bufferCapacity, Class<T> messageClass, ManagedServiceFactory fact)
static ManagedServiceGroup	startReceiver(String receiverGroupId, String destConfigId, String connectionConfigId, ManagedServiceFactory fact)
static ManagedServiceGroup	startReplicator(org.osgi.framework.BundleContext context, String replicationGroupId, String destConfigId, String connectionConfigId, long initialReplicationDelay, long replicationPeriod, ManagedServiceFactory fact)

Methods inherited from class java.lang.Object

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

Field Detail

BUFFER_LINK_ID_SUFFIX

public static final String BUFFER_LINK_ID_SUFFIX

See Also:

Constant Field Values

ROUTE_LINK_ID_SUFFIX

public static final String ROUTE_LINK_ID_SUFFIX

See Also:

Constant Field Values

DECODER_LINK_ID_SUFFIX

public static final String DECODER_LINK_ID_SUFFIX

See Also:

Constant Field Values

Constructor Detail

ReplicationUtils

public ReplicationUtils()

Method Detail

startReplicator

public static ManagedServiceGroup startReplicator(org.osgi.framework.BundleContext context,
                                                  String replicationGroupId,
                                                  String destConfigId,
                                                  String connectionConfigId,
                                                  long initialReplicationDelay,
                                                  long replicationPeriod,
                                                  ManagedServiceFactory fact)

createReplicationBuffer

public static <T> ManagedServiceGroup createReplicationBuffer(String replicationGroupId,
                                                              String bufferId,
                                                              String producerIdKey,
                                                              String producerId,
                                                              int bufferCapacity,
                                                              Class<T> messageClass,
                                                              ManagedServiceFactory fact)

createAlternateReplicationBuffer

public static <T> ManagedServiceGroup createAlternateReplicationBuffer(String replicationGroupId,
                                                                       String bufferRouteKey,
                                                                       org.jflux.api.core.Source<T> valueSource,
                                                                       Class<T> messageClass,
                                                                       ManagedServiceFactory fact)

createReceiverRoute

public static <T> ManagedServiceGroup createReceiverRoute(String receiverGroupId,
                                                          String routingKey,
                                                          String consumerIdKey,
                                                          String consumerId,
                                                          Class<T> messageClass,
                                                          ManagedServiceFactory fact)

startReceiver

public static ManagedServiceGroup startReceiver(String receiverGroupId,
                                                String destConfigId,
                                                String connectionConfigId,
                                                ManagedServiceFactory fact)