org.hobbit.core.rabbit

Class SimpleFileReceiver

java.lang.Object

org.hobbit.core.rabbit.SimpleFileReceiver

public class SimpleFileReceiver
extends Object

Author:

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	SimpleFileReceiver.MessageProcessing

Field Summary

Fields

Modifier and Type	Field and Description
private com.rabbitmq.client.QueueingConsumer	consumer
private static long	DEFAULT_TIMEOUT
private int	errorCount
private ExecutorService	executor
private Map<String,FileReceiveState>	fileStates
private static org.slf4j.Logger	LOGGER
private RabbitQueue	queue
private boolean	terminated

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpleFileReceiver(RabbitQueue queue, com.rabbitmq.client.QueueingConsumer consumer)

Method Summary

Modifier and Type	Method and Description
protected void	close()
static SimpleFileReceiver	create(RabbitQueue queue)
static SimpleFileReceiver	create(RabbitQueueFactory factory, String queueName)
void	forceTermination()
int	getErrorCount()
protected void	increaseErrorCount()
String[]	receiveData(String outputDirectory)
void	terminate()

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_TIMEOUT

private static final long DEFAULT_TIMEOUT

See Also:

Constant Field Values

queue

private RabbitQueue queue

consumer

private com.rabbitmq.client.QueueingConsumer consumer

fileStates

private Map<String,FileReceiveState> fileStates

terminated

private boolean terminated

errorCount

private int errorCount

executor

private ExecutorService executor

Constructor Detail

SimpleFileReceiver

protected SimpleFileReceiver(RabbitQueue queue,
                             com.rabbitmq.client.QueueingConsumer consumer)

Method Detail

create

public static SimpleFileReceiver create(RabbitQueueFactory factory,
                                        String queueName)
                                 throws IOException

Throws:

IOException

create

public static SimpleFileReceiver create(RabbitQueue queue)
                                 throws IOException

Throws:

IOException

receiveData

public String[] receiveData(String outputDirectory)
                     throws IOException,
                            com.rabbitmq.client.ShutdownSignalException,
                            com.rabbitmq.client.ConsumerCancelledException,
                            InterruptedException

Throws:

IOException

com.rabbitmq.client.ShutdownSignalException

com.rabbitmq.client.ConsumerCancelledException

InterruptedException

terminate

public void terminate()

forceTermination

public void forceTermination()

increaseErrorCount

protected void increaseErrorCount()

getErrorCount

public int getErrorCount()

close

protected void close()