org.robokind.impl.messaging.config
Class RKMessagingComponentConfigUtils
java.lang.Object
org.robokind.impl.messaging.config.RKMessagingComponentConfigUtils
public class RKMessagingComponentConfigUtils
- extends Object
- Author:
- Matthew Stevenson
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 |
RKMessagingComponentConfigUtils
public RKMessagingComponentConfigUtils()
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.