org.hobbit.core.rabbit

Interface DataSender

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

DataSenderImpl, PairedDataSender

public interface DataSender
extends Closeable

An interface of a class sending (large) data to a queue using data identifiers to mark single packages as part of a larger set of data.

Author:

Michael Röder (roeder@informatik.uni-leipzig.de)

Method Summary

Modifier and Type	Method and Description
void	closeWhenFinished() A blocking method that closes the sender when its work is done, i.e., all messages have been consumed by receivers from the queue.
void	sendData(byte[] data) Send the given data to the queue.
void	sendData(byte[] data, String dataId) Send the given data to the queue using the given Id as identifier.
void	sendData(InputStream is) Send the given data to the queue.
void	sendData(InputStream is, String dataId) Send the given data to the queue using the given Id as identifier.

Methods inherited from interface java.io.Closeable

close

Method Detail

sendData

void sendData(byte[] data)
       throws IOException

Send the given data to the queue.

Parameters:

data - the data that should be sent

Throws:

IOException - if an exception occurs during the communication with the queue

sendData

void sendData(byte[] data,
              String dataId)
       throws IOException

Send the given data to the queue using the given Id as identifier.

Parameters:

data - the data that should be sent

dataId - the Id that is used as identifier

Throws:

IOException - if an exception occurs during the communication with the queue

sendData

void sendData(InputStream is)
       throws IOException

Send the given data to the queue.

Parameters:

is - an InputStream from which the data is read

Throws:

IOException - if an exception occurs during the communication with the queue

sendData

void sendData(InputStream is,
              String dataId)
       throws IOException

Send the given data to the queue using the given Id as identifier.

Parameters:

is - an InputStream from which the data is read

dataId - the Id that is used as identifier

Throws:

IOException - if an exception occurs during the communication with the queue

closeWhenFinished

void closeWhenFinished()

A blocking method that closes the sender when its work is done, i.e., all messages have been consumed by receivers from the queue.