Overview
Package
Class
Use
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
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
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
Copyright © 2011-2013. All Rights Reserved.