org.robokind.impl.messaging.config
Class RKMessagingComponentConfigUtils

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

public class RKMessagingComponentConfigUtils
extends Object

Author:
Matthew Stevenson

Constructor Summary
RKMessagingComponentConfigUtils()
           
 
Method Summary
static
<Msg,Rec extends org.apache.avro.generic.IndexedRecord>
org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageAsyncReceiver>
buildAvroRemoteListenerLifecycle(String remoteListenerId, String destinatinId, String sessionId, org.jflux.api.core.config.Configuration<String> avroConfig)
           
static
<Msg,Rec extends org.apache.avro.generic.IndexedRecord>
org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageSender>
buildAvroRemoteNotifierLifecycle(String remoteNotifierId, String destinatinId, String sessionId, org.jflux.api.core.config.Configuration<String> avroConfig)
           
static
<Msg> org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageSender>
buildJMSAvroPolymorphicRemoteNotifierLifecycle(String remoteNotifierId, String destinatinId, String sessionId, org.jflux.api.core.config.Configuration<String> config)
           
static
<Msg> org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageBlockingReceiver>
buildJMSRemoteSourceLifecycle(String remoteSourceId, String destinatinId, String sessionId, org.jflux.api.core.config.Configuration<String> config)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RKMessagingComponentConfigUtils

public RKMessagingComponentConfigUtils()
Method Detail

buildAvroRemoteNotifierLifecycle

public static <Msg,Rec extends org.apache.avro.generic.IndexedRecord> org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageSender> buildAvroRemoteNotifierLifecycle(String remoteNotifierId,
                                                                                                                                                                                                            String destinatinId,
                                                                                                                                                                                                            String sessionId,
                                                                                                                                                                                                            org.jflux.api.core.config.Configuration<String> avroConfig)

buildAvroRemoteListenerLifecycle

public static <Msg,Rec extends org.apache.avro.generic.IndexedRecord> org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageAsyncReceiver> buildAvroRemoteListenerLifecycle(String remoteListenerId,
                                                                                                                                                                                                                   String destinatinId,
                                                                                                                                                                                                                   String sessionId,
                                                                                                                                                                                                                   org.jflux.api.core.config.Configuration<String> avroConfig)

buildJMSRemoteSourceLifecycle

public static <Msg> org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageBlockingReceiver> buildJMSRemoteSourceLifecycle(String remoteSourceId,
                                                                                                                                                                 String destinatinId,
                                                                                                                                                                 String sessionId,
                                                                                                                                                                 org.jflux.api.core.config.Configuration<String> config)

buildJMSAvroPolymorphicRemoteNotifierLifecycle

public static <Msg> org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageSender> buildJMSAvroPolymorphicRemoteNotifierLifecycle(String remoteNotifierId,
                                                                                                                                                                        String destinatinId,
                                                                                                                                                                        String sessionId,
                                                                                                                                                                        org.jflux.api.core.config.Configuration<String> config)


Copyright © 2011-2013. All Rights Reserved.