Package org.hobbit.core.rabbit
-
Interface Summary Interface Description DataHandler DataReceiver An interface for a class that receives data and offers methods to close the receiving when it is finished and to check the receiver for errors that might have been encountered.DataSender An interface of a class sending data to a queue.RabbitQueueFactory -
Class Summary Class Description DataReceiverImpl Implementation of theDataReceiverinterface.DataReceiverImpl.Builder DataSenderImpl Implementation of theDataSenderinterface.DataSenderImpl.Builder DataSenderImpl.Message RabbitMQUtils Contains utility methods for working with RabbitMQ.RabbitQueueFactoryImpl RabbitRpcClient This class implements a thread safe client that can process several RPC calls in parallel.RabbitRpcClient.RabbitRpcClientConsumer Internal implementation of a Consumer that receives messages on the reply queue and callsRabbitRpcClient.processResponseForRequest(String, byte[])of itsRabbitRpcClient.RabbitRpcClientConsumer.client.RabbitRpcClient.RabbitRpcRequest Simple extension of theAbstractFutureclass that waits for the response which is set by theRabbitRpcClient.RabbitRpcRequest.setResponse(byte[] response).SimpleFileReceiver SimpleFileReceiver.MessageProcessing SimpleFileSender A simple class that can be used to send files, i.e., small or large sized data with a single name, via RabbitMQ using a queue with the given name.