org.robokind.impl.messaging.config
Class RKMessagingConfigUtils
java.lang.Object
org.robokind.impl.messaging.config.RKMessagingConfigUtils
public class RKMessagingConfigUtils
- extends Object
- Author:
- Matthew Stevenson
Method Summary |
static
<Msg,Rec extends org.apache.avro.generic.IndexedRecord>
org.robokind.api.common.lifecycle.ManagedService |
|
registerAvroSerializationConfig(Class<Msg> messageClass,
Class<Rec> recordClass,
org.apache.avro.Schema recordSchema,
org.jflux.api.core.Adapter<Msg,Rec> encoder,
org.jflux.api.core.Adapter<Rec,Msg> decoder,
String contentType,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerConnectionConfig(String configId,
org.jflux.api.core.config.Configuration<String> conf,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerConnectionConfig(String configId,
String ipAddress,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerConnectionConfig(String configId,
String ipAddress,
String port,
String username,
String password,
String clientName,
String virtualHost,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerDestinationConfig(String configId,
org.jflux.api.core.config.Configuration<String> conf,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerDestinationConfig(String configId,
String name,
String type,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerDestinationConfig(String configId,
String name,
String type,
String create,
String options,
String nodeOptions,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerQueueConfig(String configId,
String name,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static
<Msg,Rec> org.robokind.api.common.lifecycle.ManagedService |
|
registerSerializationConfig(Class<Msg> messageClass,
Class<Rec> recordClass,
org.jflux.api.core.Adapter<Msg,Rec> encoder,
org.jflux.api.core.Adapter<Rec,Msg> decoder,
String contentType,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerSerializationConfig(String configId,
org.jflux.api.core.config.Configuration<String> conf,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
static org.robokind.api.common.lifecycle.ManagedService |
registerTopicConfig(String configId,
String name,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMS_CONNECTION_CONFIG
public static final String JMS_CONNECTION_CONFIG
- See Also:
- Constant Field Values
JMS_DESTINATION_CONFIG
public static final String JMS_DESTINATION_CONFIG
- See Also:
- Constant Field Values
SERIALIZATION_CONFIG
public static final String SERIALIZATION_CONFIG
- See Also:
- Constant Field Values
PROP_BROKER_IP
public static final String PROP_BROKER_IP
- See Also:
- Constant Field Values
PROP_DESTINATION_NAME
public static final String PROP_DESTINATION_NAME
- See Also:
- Constant Field Values
PROP_DESTINATION_TYPE
public static final String PROP_DESTINATION_TYPE
- See Also:
- Constant Field Values
AVRO_PREFIX
public static final String AVRO_PREFIX
- See Also:
- Constant Field Values
RKMessagingConfigUtils
public RKMessagingConfigUtils()
registerConnectionConfig
public static org.robokind.api.common.lifecycle.ManagedService registerConnectionConfig(String configId,
org.jflux.api.core.config.Configuration<String> conf,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerConnectionConfig
public static org.robokind.api.common.lifecycle.ManagedService registerConnectionConfig(String configId,
String ipAddress,
String port,
String username,
String password,
String clientName,
String virtualHost,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerConnectionConfig
public static org.robokind.api.common.lifecycle.ManagedService registerConnectionConfig(String configId,
String ipAddress,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerDestinationConfig
public static org.robokind.api.common.lifecycle.ManagedService registerDestinationConfig(String configId,
org.jflux.api.core.config.Configuration<String> conf,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerDestinationConfig
public static org.robokind.api.common.lifecycle.ManagedService registerDestinationConfig(String configId,
String name,
String type,
String create,
String options,
String nodeOptions,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerDestinationConfig
public static org.robokind.api.common.lifecycle.ManagedService registerDestinationConfig(String configId,
String name,
String type,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerQueueConfig
public static org.robokind.api.common.lifecycle.ManagedService registerQueueConfig(String configId,
String name,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerTopicConfig
public static org.robokind.api.common.lifecycle.ManagedService registerTopicConfig(String configId,
String name,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerSerializationConfig
public static <Msg,Rec> org.robokind.api.common.lifecycle.ManagedService registerSerializationConfig(Class<Msg> messageClass,
Class<Rec> recordClass,
org.jflux.api.core.Adapter<Msg,Rec> encoder,
org.jflux.api.core.Adapter<Rec,Msg> decoder,
String contentType,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerAvroSerializationConfig
public static <Msg,Rec extends org.apache.avro.generic.IndexedRecord> org.robokind.api.common.lifecycle.ManagedService registerAvroSerializationConfig(Class<Msg> messageClass,
Class<Rec> recordClass,
org.apache.avro.Schema recordSchema,
org.jflux.api.core.Adapter<Msg,Rec> encoder,
org.jflux.api.core.Adapter<Rec,Msg> decoder,
String contentType,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
registerSerializationConfig
public static org.robokind.api.common.lifecycle.ManagedService registerSerializationConfig(String configId,
org.jflux.api.core.config.Configuration<String> conf,
Properties props,
org.robokind.api.common.lifecycle.utils.ManagedServiceFactory factory)
Copyright © 2011-2013. All Rights Reserved.