Package 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	Description
protected static class	SimpleFileReceiver.MessageProcessing

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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	setWaitingForMsgTimeout(long waitingForMsgTimeout)
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

protected static final long DEFAULT_TIMEOUT

See Also:

Constant Field Values

queue

protected RabbitQueue queue

consumer

protected com.rabbitmq.client.QueueingConsumer consumer

fileStates

protected Map<String,FileReceiveState> fileStates

terminated

protected boolean terminated

errorCount

protected int errorCount

executor

protected ExecutorService executor

waitingForMsgTimeout

protected long waitingForMsgTimeout

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()

setWaitingForMsgTimeout

public void setWaitingForMsgTimeout(long waitingForMsgTimeout)

close

protected void close()