org.hobbit.core.rabbit

Class DataSenderImpl

java.lang.Object

org.hobbit.core.rabbit.DataSenderImpl

All Implemented Interfaces:

Closeable, AutoCloseable, DataSender

Direct Known Subclasses:

PairedDataSender

public class DataSenderImpl
extends Object
implements DataSender

Implementation of the DataSender interface.

Use the internal DataSenderImpl.Builder class for creating instances of the DataSenderImpl class. Note that the created DataSenderImpl will either use a given RabbitQueue or create a new one. In both cases the receiver will become the owner of the queue, i.e., if the DataSenderImpl instance is closed the queue will be closed as well.

Note that choosing a message buffer size smaller than DEFAULT_MESSAGE_BUFFER_SIZE=1000 might lead the sender to get stuck since confirmations might be sent rarely by the RabbitMQ broker.

Author:

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DataSenderImpl.Builder
protected class	DataSenderImpl.DataSenderConfirmHandler
protected static class	DataSenderImpl.Message

Field Summary

Fields

Modifier and Type	Field and Description
private DataSenderImpl.DataSenderConfirmHandler	confirmHandler
private static int	DEFAULT_DELIVERY_MODE
private static int	DEFAULT_MESSAGE_BUFFER_SIZE
private static int	DEFAULT_MESSAGE_SIZE
private int	deliveryMode
protected IdGenerator	idGenerator
private static org.slf4j.Logger	LOGGER
private int	maxMessageSize
private int	messageSize
private String	name
private RabbitQueue	queue

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DataSenderImpl(RabbitQueue queue, IdGenerator idGenerator, int messageSize, int deliveryMode, int messageConfirmBuffer, String name)

Method Summary

Modifier and Type	Method and Description
static DataSenderImpl.Builder	builder() Returns a newly created DataSenderImpl.Builder.
void	close()
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.
protected void	sendData(com.rabbitmq.client.AMQP.BasicProperties properties, byte[] data)
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.
protected void	sendData(InputStream is, String dataId, com.rabbitmq.client.AMQP.BasicProperties.Builder probBuilder)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

DEFAULT_MESSAGE_SIZE

private static final int DEFAULT_MESSAGE_SIZE

See Also:

Constant Field Values

DEFAULT_MESSAGE_BUFFER_SIZE

private static final int DEFAULT_MESSAGE_BUFFER_SIZE

See Also:

Constant Field Values

DEFAULT_DELIVERY_MODE

private static final int DEFAULT_DELIVERY_MODE

See Also:

Constant Field Values

idGenerator

protected IdGenerator idGenerator

queue

private RabbitQueue queue

messageSize

private final int messageSize

maxMessageSize

private final int maxMessageSize

deliveryMode

private final int deliveryMode

confirmHandler

private final DataSenderImpl.DataSenderConfirmHandler confirmHandler

name

private final String name

Constructor Detail

DataSenderImpl

protected DataSenderImpl(RabbitQueue queue,
                         IdGenerator idGenerator,
                         int messageSize,
                         int deliveryMode,
                         int messageConfirmBuffer,
                         String name)

Method Detail

sendData

public void sendData(byte[] data)
              throws IOException

Description copied from interface: DataSender

Send the given data to the queue.

Specified by:

sendData in interface DataSender

Parameters:

data - the data that should be sent

Throws:

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

sendData

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

Description copied from interface: DataSender

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

Specified by:

sendData in interface DataSender

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

public void sendData(InputStream is)
              throws IOException

Description copied from interface: DataSender

Send the given data to the queue.

Specified by:

sendData in interface DataSender

Parameters:

is - an InputStream from which the data is read

Throws:

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

sendData

public void sendData(InputStream is,
                     String dataId)
              throws IOException

Description copied from interface: DataSender

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

Specified by:

sendData in interface DataSender

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

sendData

protected void sendData(InputStream is,
                        String dataId,
                        com.rabbitmq.client.AMQP.BasicProperties.Builder probBuilder)
                 throws IOException

Throws:

IOException

sendData

protected void sendData(com.rabbitmq.client.AMQP.BasicProperties properties,
                        byte[] data)
                 throws IOException

Throws:

IOException

closeWhenFinished

public void closeWhenFinished()

Description copied from interface: DataSender

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

Specified by:

closeWhenFinished in interface DataSender

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

builder

public static DataSenderImpl.Builder builder()

Returns a newly created DataSenderImpl.Builder.

Returns:

a new DataSenderImpl.Builder instance