Package org.robokind.impl.messaging

Class Summary
BytesMessageFactory  
JMSAvroMessageAsyncReceiver<Msg,Rec extends IndexedRecord> A DefaultMessageAsyncReceiver for asynchronously receiving Avro Records over JMS (Qpid).
JMSAvroMessageSender<Msg,Rec extends IndexedRecord> DefaultMessageSender for serializing Messages to Avro Records and sending them over JMS (Qpid).
JMSAvroRecordAsyncReceiver<Rec extends IndexedRecord> Polls messages from a JMS Destination and attempts to deserialize them as a specific type of Avro Record.
JMSAvroRecordSender<T extends IndexedRecord> Sends Avro Records over JMS (Qpid).
JMSAvroServiceFacade<Config extends IndexedRecord> A facade for controlling a RemoteServiceClient using Avro and JMS (Qpid).
JMSBytesMessageSender  
JMSBytesRecordAsyncReceiver Polls for JMS BytesMessages from a JMS Destination.
JMSBytesRecordBlockingReceiver Blocks and waits for a JMS BytesMessage when called.
 



Copyright © 2011-2013. All Rights Reserved.