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

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

public class EventBufferUtils
extends Object

Author:

Matthew Stevenson

Nested Class Summary

static class

EventBufferUtils.EventBuffer<T>

Field Summary

static String	PROP_EVENT_BUFFER_NODE_ID
static String	PROP_EVENT_TYPE

Constructor Summary

EventBufferUtils()

Method Summary

static <T> org.jflux.api.core.config.Configuration<String>	buildAlternateEventBufferLifecycleConfig(String eventBufferId, String eventFactId, String eventEncoderId, org.jflux.api.core.Source<T> valueSource)
static org.jflux.api.core.config.Configuration<String>	buildDataEventFactoryLifecycleConfig(String encodeConfigIdKey, String encodeConfigId, String eventFactoryId, String eventKey, String sourceRef)
static <T> org.jflux.api.core.config.Configuration<String>	buildEventBufferLifecycleConfig(String eventBufferId, Properties bufferProps, int capacity, String eventFactId, String eventEncoderId)
static <T,R extends org.apache.avro.generic.IndexedRecord> org.jflux.api.core.config.Configuration<String>	buildEventEncoderLifecycleConfig(String encodeConfigIdKey, String encodeConfigId, String eventEncoderId)
static List<org.jflux.api.core.config.Configuration<String>>	getAlternateLifecycleConfigs(String encodeConfigIdKey, String encodeConfigId, String eventFactoryId, String eventKey, String sourceRef, String eventEncoderId, String eventBufferId, org.jflux.api.core.Source<?> valueSource)
static List<org.jflux.api.core.config.Configuration<String>>	getLifecycleConfigs(String encodeConfigIdKey, String encodeConfigId, String eventFactoryId, String eventKey, String sourceRef, String eventEncoderId, String eventBufferId, Properties bufferProps, int capacity)

Methods inherited from class java.lang.Object

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

Field Detail

PROP_EVENT_BUFFER_NODE_ID

public static final String PROP_EVENT_BUFFER_NODE_ID

See Also:

Constant Field Values

PROP_EVENT_TYPE

public static final String PROP_EVENT_TYPE

See Also:

Constant Field Values

Constructor Detail

EventBufferUtils

public EventBufferUtils()

Method Detail

getLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getLifecycleConfigs(String encodeConfigIdKey,
                                                                                        String encodeConfigId,
                                                                                        String eventFactoryId,
                                                                                        String eventKey,
                                                                                        String sourceRef,
                                                                                        String eventEncoderId,
                                                                                        String eventBufferId,
                                                                                        Properties bufferProps,
                                                                                        int capacity)

buildDataEventFactoryLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildDataEventFactoryLifecycleConfig(String encodeConfigIdKey,
                                                                                                   String encodeConfigId,
                                                                                                   String eventFactoryId,
                                                                                                   String eventKey,
                                                                                                   String sourceRef)

buildEventEncoderLifecycleConfig

public static <T,R extends org.apache.avro.generic.IndexedRecord> org.jflux.api.core.config.Configuration<String> buildEventEncoderLifecycleConfig(String encodeConfigIdKey,
                                                                                                                                                   String encodeConfigId,
                                                                                                                                                   String eventEncoderId)

buildEventBufferLifecycleConfig

public static <T> org.jflux.api.core.config.Configuration<String> buildEventBufferLifecycleConfig(String eventBufferId,
                                                                                                  Properties bufferProps,
                                                                                                  int capacity,
                                                                                                  String eventFactId,
                                                                                                  String eventEncoderId)

getAlternateLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getAlternateLifecycleConfigs(String encodeConfigIdKey,
                                                                                                 String encodeConfigId,
                                                                                                 String eventFactoryId,
                                                                                                 String eventKey,
                                                                                                 String sourceRef,
                                                                                                 String eventEncoderId,
                                                                                                 String eventBufferId,
                                                                                                 org.jflux.api.core.Source<?> valueSource)

buildAlternateEventBufferLifecycleConfig

public static <T> org.jflux.api.core.config.Configuration<String> buildAlternateEventBufferLifecycleConfig(String eventBufferId,
                                                                                                           String eventFactId,
                                                                                                           String eventEncoderId,
                                                                                                           org.jflux.api.core.Source<T> valueSource)