org.robokind.impl.messaging.config
Class RKMessagingConfigUtils

java.lang.Object
  extended by org.robokind.impl.messaging.config.RKMessagingConfigUtils

public class RKMessagingConfigUtils
extends Object

Author:
Matthew Stevenson

Field Summary
static String AVRO_PREFIX
           
static String JMS_CONNECTION_CONFIG
           
static String JMS_DESTINATION_CONFIG
           
static String PROP_BROKER_IP
           
static String PROP_DESTINATION_NAME
           
static String PROP_DESTINATION_TYPE
           
static String SERIALIZATION_CONFIG
           
 
Constructor Summary
RKMessagingConfigUtils()
           
 
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
 

Field Detail

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
Constructor Detail

RKMessagingConfigUtils

public RKMessagingConfigUtils()
Method Detail

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.