org.hobbit.core.rabbit.paired

Class PairedDataSender

java.lang.Object

org.hobbit.core.rabbit.DataSenderImpl

org.hobbit.core.rabbit.paired.PairedDataSender

All Implemented Interfaces:

Closeable, AutoCloseable, DataSender

public class PairedDataSender
extends DataSenderImpl

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PairedDataSender.Builder

Nested classes/interfaces inherited from class org.hobbit.core.rabbit.DataSenderImpl

DataSenderImpl.DataSenderConfirmHandler, DataSenderImpl.Message

Field Summary

Fields inherited from class org.hobbit.core.rabbit.DataSenderImpl

idGenerator

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static PairedDataSender.Builder	builder() Returns a newly created PairedDataSender.Builder.
void	sendData(InputStream[] is)
void	sendData(InputStream[] is, String dataId)

Methods inherited from class org.hobbit.core.rabbit.DataSenderImpl

close, closeWhenFinished, sendData, sendData, sendData, sendData, sendData, sendData

Methods inherited from class java.lang.Object

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

Constructor Detail

PairedDataSender

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

Method Detail

sendData

public void sendData(InputStream[] is)
              throws IOException

Throws:

IOException

sendData

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

Throws:

IOException

builder

public static PairedDataSender.Builder builder()

Returns a newly created PairedDataSender.Builder.

Returns:

a new PairedDataSender.Builder instance