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

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

public class ReplicationSenderLifecycleUtils
extends Object

Author:

Matthew Stevenson

Field Summary

static String	DEFAULT_CONTENT_TYPE
static String	PROP_REPLICATION_SENDER_NODE_ID

Constructor Summary

ReplicationSenderLifecycleUtils()

Method Summary

static org.jflux.api.core.config.Configuration<String>	buildMsgHeaderLifecycleConfig(String encodeConfigIdKey, String encodeConfigId, String msgHeaderId)
static org.jflux.api.core.config.Configuration<String>	buildMsgPackerLifecycleConfig(String sessionIdKey, String sessionId, String msgPackerId)
static org.jflux.api.core.config.Configuration<String>	buildReplicationSenderLifecycleConfig(String replicationNodeId, String msgPackerId, String msgHeaderId, String senderId)
static org.jflux.api.core.config.Configuration<String>	buildSenderLifecycleConfig(String destinationIdKey, String destinationId, String sessionIdKey, String sessionId, String senderId)
static org.jflux.api.core.Adapter<List<org.jflux.avrogen.EventRecord>,org.jflux.avrogen.EventListRecord>	eventListAdapter(String eventType, String sourceRef, Map<String,String> props)
static List<org.jflux.api.core.config.Configuration<String>>	getLifecycleConfigs(String encodeConfigIdKey, String encodeConfigId, String destinationIdKey, String destinationId, String sessionIdKey, String sessionId, String msgPackerId, String msgHeaderId, String replicationNodeId, String senderId)
static org.jflux.api.core.Adapter<org.jflux.avrogen.EventListRecord,ByteArrayOutputStream>	listByteAdapter()

Methods inherited from class java.lang.Object

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

Field Detail

PROP_REPLICATION_SENDER_NODE_ID

public static final String PROP_REPLICATION_SENDER_NODE_ID

See Also:

Constant Field Values

DEFAULT_CONTENT_TYPE

public static final String DEFAULT_CONTENT_TYPE

See Also:

Constant Field Values

Constructor Detail

ReplicationSenderLifecycleUtils

public ReplicationSenderLifecycleUtils()

Method Detail

getLifecycleConfigs

public static List<org.jflux.api.core.config.Configuration<String>> getLifecycleConfigs(String encodeConfigIdKey,
                                                                                        String encodeConfigId,
                                                                                        String destinationIdKey,
                                                                                        String destinationId,
                                                                                        String sessionIdKey,
                                                                                        String sessionId,
                                                                                        String msgPackerId,
                                                                                        String msgHeaderId,
                                                                                        String replicationNodeId,
                                                                                        String senderId)

eventListAdapter

public static org.jflux.api.core.Adapter<List<org.jflux.avrogen.EventRecord>,org.jflux.avrogen.EventListRecord> eventListAdapter(String eventType,
                                                                                                                                 String sourceRef,
                                                                                                                                 Map<String,String> props)

listByteAdapter

public static org.jflux.api.core.Adapter<org.jflux.avrogen.EventListRecord,ByteArrayOutputStream> listByteAdapter()

buildMsgPackerLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildMsgPackerLifecycleConfig(String sessionIdKey,
                                                                                            String sessionId,
                                                                                            String msgPackerId)

buildMsgHeaderLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildMsgHeaderLifecycleConfig(String encodeConfigIdKey,
                                                                                            String encodeConfigId,
                                                                                            String msgHeaderId)

buildSenderLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildSenderLifecycleConfig(String destinationIdKey,
                                                                                         String destinationId,
                                                                                         String sessionIdKey,
                                                                                         String sessionId,
                                                                                         String senderId)

buildReplicationSenderLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildReplicationSenderLifecycleConfig(String replicationNodeId,
                                                                                                    String msgPackerId,
                                                                                                    String msgHeaderId,
                                                                                                    String senderId)