Package
Class
Use
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
B
C
G
I
J
M
O
P
R
S
U
B
buildConnectionTracker(BundleContext, String, String)
- Static method in class org.robokind.impl.messaging.
ConnectionManager
buildDestinationTracker(BundleContext, String, String)
- Static method in class org.robokind.impl.messaging.
ConnectionManager
C
closeProducer()
- Method in class org.robokind.impl.messaging.
JMSRecordSender
Closes the underlying JMS MessageProducer making it unable to send Records.
COMMAND_MIME_TYPE
- Static variable in class org.robokind.impl.messaging.
RemoteServiceFacade
CONFIG_MIME_TYPE
- Static variable in class org.robokind.impl.messaging.
RemoteServiceFacade
ConnectionManager
- Class in
org.robokind.impl.messaging
ConnectionManager()
- Constructor for class org.robokind.impl.messaging.
ConnectionManager
createConnection(String, String, String, String, String)
- Static method in class org.robokind.impl.messaging.
ConnectionManager
createConnection(String)
- Static method in class org.robokind.impl.messaging.
ConnectionManager
G
getConfigClass()
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
getReusableConfig()
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
I
initialize(Config)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
J
JMSMessageReceiver
<
Msg
,
Rec
extends org.apache.avro.generic.IndexedRecord,
L
extends org.robokind.api.common.utils.Listener<
Msg
>> - Class in
org.robokind.impl.messaging
A DefaultMessageReceiver for receiving Avro Records over JMS (Qpid).
JMSMessageReceiver(Session, Destination, Class<Rec>, Schema)
- Constructor for class org.robokind.impl.messaging.
JMSMessageReceiver
Creates a new JMSMessageReceiver
JMSMessageSender
<
Msg
,
Rec
extends org.apache.avro.generic.IndexedRecord,
L
extends org.robokind.api.common.utils.Listener<
Msg
>> - Class in
org.robokind.impl.messaging
DefaultMessageSender for serializing to Avro Records and sending over JMS (Qpid).
JMSMessageSender(Session, Destination, Class<Rec>)
- Constructor for class org.robokind.impl.messaging.
JMSMessageSender
Creates a new JMSMessageSender
JMSRecordReceiver
<
T
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.
JMSRecordReceiver(Class<T>, Schema, MessageConsumer)
- Constructor for class org.robokind.impl.messaging.
JMSRecordReceiver
Creates a new JMSRecordReceiver.
JMSRecordSender
<
T
extends org.apache.avro.generic.IndexedRecord> - Class in
org.robokind.impl.messaging
Sends Avro Records over JMS (Qpid).
JMSRecordSender(Class<T>)
- Constructor for class org.robokind.impl.messaging.
JMSRecordSender
Creates a new JMSRecordSender.
M
myClass
- Variable in class org.robokind.impl.messaging.
JMSRecordSender
myDestination
- Variable in class org.robokind.impl.messaging.
JMSRecordSender
myMessageProducer
- Variable in class org.robokind.impl.messaging.
JMSRecordSender
mySession
- Variable in class org.robokind.impl.messaging.
JMSRecordSender
O
onComplete(long)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
onPause(long)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
onResume(long)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
onStart(long)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
onStop(long)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
openProducer()
- Method in class org.robokind.impl.messaging.
JMSRecordSender
Opens the underlying JMS MessageProducer, allowing it to begin sending Records.
org.robokind.impl.messaging
- package org.robokind.impl.messaging
P
pause()
- Method in class org.robokind.impl.messaging.
JMSRecordReceiver
PROP_CONNECTION_ID
- Static variable in class org.robokind.impl.messaging.
ConnectionManager
PROP_DESTINATION_ID
- Static variable in class org.robokind.impl.messaging.
ConnectionManager
R
registerConnection(BundleContext, String, Connection, Properties)
- Static method in class org.robokind.impl.messaging.
ConnectionManager
registerDestination(BundleContext, String, Destination, Properties)
- Static method in class org.robokind.impl.messaging.
ConnectionManager
RemoteServiceFacade
<
Config
extends org.apache.avro.generic.IndexedRecord> - Class in
org.robokind.impl.messaging
A facade for controlling a RemoteService using Avro and JMS (Qpid).
RemoteServiceFacade(Class<Config>, Config, Session, Destination, Destination)
- Constructor for class org.robokind.impl.messaging.
RemoteServiceFacade
RemoteServiceFacade(Class<Config>, Config, Session, MessageProducer, MessageConsumer)
- Constructor for class org.robokind.impl.messaging.
RemoteServiceFacade
resume()
- Method in class org.robokind.impl.messaging.
JMSRecordReceiver
S
send(Class<C>, C, String)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
sendCommand(ServiceCommandType)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
sendRecord(T)
- Method in class org.robokind.impl.messaging.
JMSRecordSender
Serializes the given Avro Record to a byte array, packs it into a JMS BytesMessage, and sends it to the JMS Destination.
setDestination(Destination)
- Method in class org.robokind.impl.messaging.
JMSRecordSender
Sets the JMS Destination to send to.
setReceiver(MessageConsumer)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
setRecordHandler(RecordReceiver.RecordHandler<T>)
- Method in class org.robokind.impl.messaging.
JMSRecordReceiver
setSender(MessageProducer)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
setSession(Session)
- Method in class org.robokind.impl.messaging.
JMSRecordSender
Sets the JMS Session to use for sending
setSession(Session)
- Method in class org.robokind.impl.messaging.
RemoteServiceFacade
start()
- Method in class org.robokind.impl.messaging.
JMSMessageReceiver
Start the JMSMessageReceiver receiving Message.
start()
- Method in class org.robokind.impl.messaging.
JMSMessageSender
Creates and opens a new JMSRecordSender for sending the Avro Records.
start()
- Method in class org.robokind.impl.messaging.
JMSRecordReceiver
Creates and starts an Polling Thread to fetch Records over JMS.
stop()
- Method in class org.robokind.impl.messaging.
JMSMessageSender
Closes the JMSRecordReceiver.
stop()
- Method in class org.robokind.impl.messaging.
JMSRecordReceiver
U
unsetRecordHandler()
- Method in class org.robokind.impl.messaging.
JMSRecordReceiver
B
C
G
I
J
M
O
P
R
S
U
Package
Class
Use
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
Copyright © 2011. All Rights Reserved.