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

Copyright © 2011. All Rights Reserved.