A B C D E F G H I J L M N O P Q R S T U

A

Activator - Class in org.robokind.impl.messaging.osgi
 
Activator() - Constructor for class org.robokind.impl.messaging.osgi.Activator
 
adapt(BytesMessage) - Method in class org.robokind.impl.messaging.utils.JMSAvroPolymorphicBytesRecordAdapter
 
adapt(BytesMessage) - Method in class org.robokind.impl.messaging.utils.JMSAvroPolymorphicBytesRecordAdapter.JMSAvroBytesRecordAdapter
 
adapt(Msg) - Method in class org.robokind.impl.messaging.utils.JMSAvroPolymorphicRecordBytesAdapter
 
adapt(A) - Method in class org.robokind.impl.messaging.utils.JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter
 
addAdapter(Class<R>, Schema, Adapter<R, Msg>, String) - Method in class org.robokind.impl.messaging.utils.JMSAvroPolymorphicBytesRecordAdapter
 
addAdapter(Adapter<Msg, R>, String) - Method in class org.robokind.impl.messaging.utils.JMSAvroPolymorphicRecordBytesAdapter
 
AVRO_MIME_TYPE - Static variable in class org.robokind.impl.messaging.JMSAvroServiceFacade
Custom content/mime type used in the JMS header for unknown avro record
AVRO_PREFIX - Static variable in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 

B

buildAvroRemoteListenerLifecycle(String, String, String, Configuration<String>) - Static method in class org.robokind.impl.messaging.config.RKMessagingComponentConfigUtils
 
buildAvroRemoteNotifierLifecycle(String, String, String, Configuration<String>) - Static method in class org.robokind.impl.messaging.config.RKMessagingComponentConfigUtils
 
buildConnectionLifecycleConfig(String, String) - Static method in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
buildDestinationLifecycleConfig(String, String) - Static method in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
buildJMSAvroPolymorphicRemoteNotifierLifecycle(String, String, String, Configuration<String>) - Static method in class org.robokind.impl.messaging.config.RKMessagingComponentConfigUtils
 
buildJMSRemoteSourceLifecycle(String, String, String, Configuration<String>) - Static method in class org.robokind.impl.messaging.config.RKMessagingComponentConfigUtils
 
buildMessagingComponentLifecycleGroupConfig(String, Properties, int, String, Configuration<String>, String, String, String, String, String) - Static method in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
buildMessagingComponentLifecycleGroupConfig(String, Properties, int, Configuration<String>, String, String) - Static method in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
buildSessionLifecycleConfig(String, String) - Static method in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
BytesMessageBlockingReceiverLifecycle<Msg> - Class in org.robokind.impl.messaging.lifecycle
 
BytesMessageBlockingReceiverLifecycle(Adapter<BytesMessage, Msg>, Class<Msg>, String, String, String) - Constructor for class org.robokind.impl.messaging.lifecycle.BytesMessageBlockingReceiverLifecycle
 
BytesMessageFactory - Class in org.robokind.impl.messaging
 
BytesMessageFactory() - Constructor for class org.robokind.impl.messaging.BytesMessageFactory
 

C

childId(String, String) - Static method in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
clearRecords() - Method in class org.robokind.impl.messaging.JMSBytesRecordBlockingReceiver
 
closeProducer() - Method in class org.robokind.impl.messaging.JMSBytesMessageSender
Closes the underlying JMS MessageProducer making it unable to send Records.
COMMAND_MIME_TYPE - Static variable in class org.robokind.impl.messaging.JMSAvroServiceFacade
Custom content/mime type used in the JMS header for service command
CONFIG_MIME_TYPE - Static variable in class org.robokind.impl.messaging.JMSAvroServiceFacade
Custom content/mime type used in the JMS header for config Records
ConnectionManager - Class in org.robokind.impl.messaging.utils
Utility methods for creating JMS Connections and Destinations and managing them within the OSGi Service Registry.
ConnectionManager() - Constructor for class org.robokind.impl.messaging.utils.ConnectionManager
 
ConnectionUtils - Class in org.robokind.impl.messaging.utils
 
ConnectionUtils() - Constructor for class org.robokind.impl.messaging.utils.ConnectionUtils
 
create(Map<String, Object>) - Method in class org.robokind.impl.messaging.lifecycle.BytesMessageBlockingReceiverLifecycle
 
create(Map<String, Object>) - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroAsyncReceiverLifecycle
 
create(Map<String, Object>) - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle
 
create(Map<String, Object>) - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroPolymorphicSenderLifecycle
 
create(String, String, String) - Method in class org.robokind.impl.messaging.services.PortableServiceCommand.Factory
 
createAMQPConnectionURL(String, String, String, String, String) - Static method in class org.robokind.impl.messaging.utils.ConnectionManager
Formats an AMQP connection URL from the given details.
createConnection(String, String, String, String, String) - Static method in class org.robokind.impl.messaging.utils.ConnectionManager
Create a JMS Connection from the given details.
createConnection(String) - Static method in class org.robokind.impl.messaging.utils.ConnectionManager
Creates an JMS Connection from the given connection URL
createDependencyListener(String, String, Class, Listener<Configuration<String>>, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.DependentLifecycle
 
createDestination(String) - Static method in class org.robokind.impl.messaging.utils.ConnectionManager
Creates a JMS Destination from the given destination String
createQueue(String) - Static method in class org.robokind.impl.messaging.utils.ConnectionManager
 
createTopic(String) - Static method in class org.robokind.impl.messaging.utils.ConnectionManager
 

D

DependentLifecycle - Class in org.robokind.impl.messaging.config
 
DependentLifecycle() - Constructor for class org.robokind.impl.messaging.config.DependentLifecycle
 

E

ensureConnection(BundleContext, String, Connection, Properties) - Static method in class org.robokind.impl.messaging.utils.ConnectionUtils
 
ensureDestination(BundleContext, String, String, int, Properties) - Static method in class org.robokind.impl.messaging.utils.ConnectionUtils
Creates and registers a Destination if there is not one already registered to the given id.
ensureDestinations(BundleContext, Object...) - Static method in class org.robokind.impl.messaging.utils.ConnectionUtils
Makes calls to ensureDestination with the given parameters.
ensureSession(BundleContext, String, Connection, Properties) - Static method in class org.robokind.impl.messaging.utils.ConnectionUtils
Registers the Connection if there is not one already registered to the given id.

F

fetchRecord(long) - Method in class org.robokind.impl.messaging.JMSBytesRecordBlockingReceiver
 

G

getClientId() - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
getConfigClass() - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
getHostId() - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
getReusableConfig() - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
getServiceClass() - Method in class org.robokind.impl.messaging.lifecycle.BytesMessageBlockingReceiverLifecycle
 
getServiceClass() - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroAsyncReceiverLifecycle
 
getServiceClass() - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle
 
getServiceClass() - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroPolymorphicSenderLifecycle
 
getValue() - Method in class org.robokind.impl.messaging.BytesMessageFactory
 
GROUP_PREFIX - Static variable in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 

H

handleChange(String, Object, Map<String, Object>) - Method in class org.robokind.impl.messaging.lifecycle.BytesMessageBlockingReceiverLifecycle
 
handleChange(String, Object, Map<String, Object>) - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroAsyncReceiverLifecycle
 
handleChange(String, Object, Map<String, Object>) - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle
 
handleChange(String, Object, Map<String, Object>) - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroPolymorphicSenderLifecycle
 

I

initialize(Config) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 

J

JMS_CONNECTION_CONFIG - Static variable in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
JMS_DESTINATION_CONFIG - Static variable in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
JMSAvroAsyncReceiverLifecycle<Msg,Rec extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging.lifecycle
 
JMSAvroAsyncReceiverLifecycle(Adapter<Rec, Msg>, Class<Msg>, Class<Rec>, Schema, String, String, String) - Constructor for class org.robokind.impl.messaging.lifecycle.JMSAvroAsyncReceiverLifecycle
Asynchronously receives Avro Records over JMS and adapts them to a Message.
JMSAvroMessageAsyncReceiver<Msg,Rec extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging
A DefaultMessageAsyncReceiver for asynchronously receiving Avro Records over JMS (Qpid).
JMSAvroMessageAsyncReceiver(Session, Destination, Class<Rec>, Schema) - Constructor for class org.robokind.impl.messaging.JMSAvroMessageAsyncReceiver
Creates a new JMSAvroMessageAsyncReceiver
JMSAvroMessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging
DefaultMessageSender for serializing Messages to Avro Records and sending them over JMS (Qpid).
JMSAvroMessageSender(Session, Destination) - Constructor for class org.robokind.impl.messaging.JMSAvroMessageSender
Creates a new JMSAvroMessageSender to send Records to the given destination using the given session.
JMSAvroMessageSender(JMSBytesMessageSender) - Constructor for class org.robokind.impl.messaging.JMSAvroMessageSender
Creates a new JMSAvroMessageSender using the given sender for sending Records.
JMSAvroMessageSenderLifecycle<Msg,Rec extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging.lifecycle
 
JMSAvroMessageSenderLifecycle(Adapter<Msg, Rec>, Class<Msg>, Class<Rec>, String, String, String, String) - Constructor for class org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle
 
JMSAvroMessageSenderLifecycle(Adapter<Msg, Rec>, Class<Msg>, Class<Rec>, String, String, String) - Constructor for class org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle
 
JMSAvroPolymorphicBytesRecordAdapter<Msg> - Class in org.robokind.impl.messaging.utils
 
JMSAvroPolymorphicBytesRecordAdapter() - Constructor for class org.robokind.impl.messaging.utils.JMSAvroPolymorphicBytesRecordAdapter
 
JMSAvroPolymorphicBytesRecordAdapter.JMSAvroBytesRecordAdapter<Rec extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging.utils
 
JMSAvroPolymorphicBytesRecordAdapter.JMSAvroBytesRecordAdapter(Class<Rec>, Schema) - Constructor for class org.robokind.impl.messaging.utils.JMSAvroPolymorphicBytesRecordAdapter.JMSAvroBytesRecordAdapter
 
JMSAvroPolymorphicRecordBytesAdapter<Msg> - Class in org.robokind.impl.messaging.utils
 
JMSAvroPolymorphicRecordBytesAdapter(PolymorphicAdapter.AdapterKeyMap<Msg>) - Constructor for class org.robokind.impl.messaging.utils.JMSAvroPolymorphicRecordBytesAdapter
 
JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter<A extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging.utils
 
JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter(Source<JMSBytesMessage>, String) - Constructor for class org.robokind.impl.messaging.utils.JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter
 
JMSAvroPolymorphicSenderLifecycle<Msg> - Class in org.robokind.impl.messaging.lifecycle
 
JMSAvroPolymorphicSenderLifecycle(JMSAvroPolymorphicRecordBytesAdapter<Msg>, Class<Msg>, String, String, String) - Constructor for class org.robokind.impl.messaging.lifecycle.JMSAvroPolymorphicSenderLifecycle
 
JMSAvroRecordAsyncReceiver<Rec extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging
Polls messages from a JMS Destination and attempts to deserialize them as a specific type of Avro Record.
JMSAvroRecordAsyncReceiver(Class<Rec>, Schema, MessageConsumer) - Constructor for class org.robokind.impl.messaging.JMSAvroRecordAsyncReceiver
Creates a new JMSAvroRecordAsyncReceiver.
JMSAvroRecordSender<T extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging
Sends Avro Records over JMS (Qpid).
JMSAvroRecordSender(JMSBytesMessageSender) - Constructor for class org.robokind.impl.messaging.JMSAvroRecordSender
Creates a new JMSAvroRecordSender.
JMSAvroServiceFacade<Config extends org.apache.avro.generic.IndexedRecord> - Class in org.robokind.impl.messaging
A facade for controlling a RemoteServiceClient using Avro and JMS (Qpid).
JMSAvroServiceFacade(Class<Config>, Config, Session, Destination, Destination) - Constructor for class org.robokind.impl.messaging.JMSAvroServiceFacade
Creates a new JMSAvroServiceFacade.
JMSAvroServiceFacade(Class<Config>, Config, Session, MessageProducer, MessageConsumer) - Constructor for class org.robokind.impl.messaging.JMSAvroServiceFacade
Creates a new JMSAvroServiceFacade.
JMSBytesMessageSender - Class in org.robokind.impl.messaging
 
JMSBytesMessageSender() - Constructor for class org.robokind.impl.messaging.JMSBytesMessageSender
Creates an empty JMSBytesSender.
JMSBytesRecordAsyncReceiver - Class in org.robokind.impl.messaging
Polls for JMS BytesMessages from a JMS Destination.
JMSBytesRecordAsyncReceiver(MessageConsumer) - Constructor for class org.robokind.impl.messaging.JMSBytesRecordAsyncReceiver
Creates a new JMSBytesRecordAsyncReceiver.
JMSBytesRecordBlockingReceiver - Class in org.robokind.impl.messaging
Blocks and waits for a JMS BytesMessage when called.
JMSBytesRecordBlockingReceiver(MessageConsumer) - Constructor for class org.robokind.impl.messaging.JMSBytesRecordBlockingReceiver
Creates a new JMSBytesRecordBlcokingReceiver which uses the given MessageConsumer.

L

LISTENER_COMPONENT - Static variable in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 

M

MessagingLifecycleGroupConfigUtils - Class in org.robokind.impl.messaging.config
 
MessagingLifecycleGroupConfigUtils() - Constructor for class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 

N

NOTIFIER_COMPONENT - Static variable in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
notifyListeners(Msg) - Method in class org.robokind.impl.messaging.JMSAvroMessageSender
 

O

onComplete(long) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
onPause(long) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
onResume(long) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
onStart(long) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
onStop(long) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
openProducer() - Method in class org.robokind.impl.messaging.JMSBytesMessageSender
Opens the underlying JMS MessageProducer, allowing it to begin sending Records.
org.robokind.impl.messaging - package org.robokind.impl.messaging
 
org.robokind.impl.messaging.config - package org.robokind.impl.messaging.config
 
org.robokind.impl.messaging.lifecycle - package org.robokind.impl.messaging.lifecycle
 
org.robokind.impl.messaging.osgi - package org.robokind.impl.messaging.osgi
 
org.robokind.impl.messaging.services - package org.robokind.impl.messaging.services
 
org.robokind.impl.messaging.utils - package org.robokind.impl.messaging.utils
 

P

pause() - Method in class org.robokind.impl.messaging.JMSAvroRecordAsyncReceiver
 
pause() - Method in class org.robokind.impl.messaging.JMSBytesRecordAsyncReceiver
 
PortableServiceCommand - Class in org.robokind.impl.messaging.services
 
PortableServiceCommand() - Constructor for class org.robokind.impl.messaging.services.PortableServiceCommand
 
PortableServiceCommand.Factory - Class in org.robokind.impl.messaging.services
 
PortableServiceCommand.Factory() - Constructor for class org.robokind.impl.messaging.services.PortableServiceCommand.Factory
 
PROP_BROKER_IP - Static variable in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
PROP_CONNECTION_ID - Static variable in class org.robokind.impl.messaging.utils.ConnectionManager
Property name for a Connection's unique id within the OSGi Service Registry.
PROP_DESTINATION_ID - Static variable in class org.robokind.impl.messaging.utils.ConnectionManager
Property name for a Destination's unique id within the OSGi Service Registry.
PROP_DESTINATION_NAME - Static variable in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
PROP_DESTINATION_TYPE - Static variable in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 

Q

QUEUE - Static variable in class org.robokind.impl.messaging.utils.ConnectionUtils
Indicates a JMS Queue where Message go to one consumer.

R

registerAvroSerializationConfig(Class<Msg>, Class<Rec>, Schema, Adapter<Msg, Rec>, Adapter<Rec, Msg>, String, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerConnection(BundleContext, String, Connection, Properties) - Static method in class org.robokind.impl.messaging.utils.ConnectionManager
Registers a JMS Connection to OSGi Service Registry, using a unique id.
registerConnectionConfig(String, Configuration<String>, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerConnectionConfig(String, String, String, String, String, String, String, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerConnectionConfig(String, String, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerDestination(BundleContext, String, Destination, Properties) - Static method in class org.robokind.impl.messaging.utils.ConnectionManager
Registers a JMS Connection to OSGi Service Registry, using a unique id.
registerDestinationConfig(String, Configuration<String>, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerDestinationConfig(String, String, String, String, String, String, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerDestinationConfig(String, String, String, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerQueueConfig(String, String, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerSerializationConfig(Class<Msg>, Class<Rec>, Adapter<Msg, Rec>, Adapter<Rec, Msg>, String, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerSerializationConfig(String, Configuration<String>, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
registerTopicConfig(String, String, Properties, ManagedServiceFactory) - Static method in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
REMOTE_LISTENER - Static variable in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
REMOTE_NOTIFIER - Static variable in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
REMOTE_POLY_NOTIFIER - Static variable in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
REMOTE_SOURCE - Static variable in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
resume() - Method in class org.robokind.impl.messaging.JMSAvroRecordAsyncReceiver
 
resume() - Method in class org.robokind.impl.messaging.JMSBytesRecordAsyncReceiver
 
RKMessagingComponentConfigUtils - Class in org.robokind.impl.messaging.config
 
RKMessagingComponentConfigUtils() - Constructor for class org.robokind.impl.messaging.config.RKMessagingComponentConfigUtils
 
RKMessagingConfigUtils - Class in org.robokind.impl.messaging.config
 
RKMessagingConfigUtils() - Constructor for class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 

S

send(T, String) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
Sends a custom Avro Record to the service.
sendCommand(String) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
Sends a service command.
sendMessage(Msg, String) - Method in class org.robokind.impl.messaging.JMSAvroMessageSender
Adapts the given Message to an Avro Record and sends it via JMS with the given JMS header content type.
sendRecord(T) - Method in class org.robokind.impl.messaging.JMSAvroRecordSender
Serializes the given Avro Record to a byte array, packs it into a JMS BytesMessage, and sends it to the JMS Destination.
sendRecord(T, String) - Method in class org.robokind.impl.messaging.JMSAvroRecordSender
Packs the given Avro Record into a JMS BytesMessage and sends it.
sendRecord(BytesMessage) - Method in class org.robokind.impl.messaging.JMSBytesMessageSender
Sends a BytesMessage
SERIALIZATION_CONFIG - Static variable in class org.robokind.impl.messaging.config.RKMessagingConfigUtils
 
setCommandFactory(ServiceCommandFactory) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
setCommandSender(MessageSender<ServiceCommand>) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
setConfigSender(MessageSender<Config>) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
setDefaultContentType(String) - Method in class org.robokind.impl.messaging.JMSAvroMessageSender
 
setDestination(Destination) - Method in class org.robokind.impl.messaging.JMSBytesMessageSender
Sets the JMS Destination to send to.
setErrorReceiver(MessageAsyncReceiver<ServiceError>) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
 
setReceiver(MessageConsumer) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
Sets the MessageConsumer to receive errors.
setRecordHandler(RecordAsyncReceiver.RecordHandler<Rec>) - Method in class org.robokind.impl.messaging.JMSAvroRecordAsyncReceiver
 
setRecordHandler(RecordAsyncReceiver.RecordHandler<BytesMessage>) - Method in class org.robokind.impl.messaging.JMSBytesRecordAsyncReceiver
 
setSender(MessageProducer) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
Sets the MessagePropducer to send commands.
setSession(Session) - Method in class org.robokind.impl.messaging.BytesMessageFactory
 
setSession(Session) - Method in class org.robokind.impl.messaging.JMSAvroServiceFacade
Sets the JMS Session for creating BytesMessages.
setSession(Session) - Method in class org.robokind.impl.messaging.JMSBytesMessageSender
Sets the JMS Session to use for sending
setSession(Session) - Method in class org.robokind.impl.messaging.utils.JMSAvroPolymorphicRecordBytesAdapter
 
SOURCE_COMPONENT - Static variable in class org.robokind.impl.messaging.config.MessagingLifecycleGroupConfigUtils
 
start() - Method in class org.robokind.impl.messaging.JMSAvroMessageAsyncReceiver
Start the JMSAvroMessageAsyncReceiver receiving Message.
start() - Method in class org.robokind.impl.messaging.JMSAvroMessageSender
Creates and opens a new JMSAvroRecordSender for sending the Avro Records.
start() - Method in class org.robokind.impl.messaging.JMSAvroRecordAsyncReceiver
Creates and starts an Polling Thread to fetch Records over JMS.
start() - Method in class org.robokind.impl.messaging.JMSBytesRecordAsyncReceiver
Creates and starts an Polling Thread to fetch Records over JMS.
start(BundleContext) - Method in class org.robokind.impl.messaging.osgi.Activator
 
stop() - Method in class org.robokind.impl.messaging.JMSAvroMessageSender
Closes the JMSRecordReceiver.
stop() - Method in class org.robokind.impl.messaging.JMSAvroRecordAsyncReceiver
 
stop() - Method in class org.robokind.impl.messaging.JMSBytesRecordAsyncReceiver
 
stop() - Method in class org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle
 
stop(BundleContext) - Method in class org.robokind.impl.messaging.osgi.Activator
 

T

theDestination - Static variable in class org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle
 
theDestination - Static variable in class org.robokind.impl.messaging.lifecycle.JMSAvroPolymorphicSenderLifecycle
 
theSession - Static variable in class org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle
 
theSession - Static variable in class org.robokind.impl.messaging.lifecycle.JMSAvroPolymorphicSenderLifecycle
 
TOPIC - Static variable in class org.robokind.impl.messaging.utils.ConnectionUtils
Indicates a JMS Topic where Message are broadcasted to all consumers.

U

unsetRecordHandler() - Method in class org.robokind.impl.messaging.JMSAvroRecordAsyncReceiver
 
unsetRecordHandler() - Method in class org.robokind.impl.messaging.JMSBytesRecordAsyncReceiver
 

A B C D E F G H I J L M N O P Q R S T U

Copyright © 2011-2013. All Rights Reserved.