public class SimpleFileReceiver extends Object
| Modifier and Type | Class and Description |
|---|---|
protected static class |
SimpleFileReceiver.MessageProcessing |
| 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 |
| Modifier | Constructor and Description |
|---|---|
protected |
SimpleFileReceiver(RabbitQueue queue,
com.rabbitmq.client.QueueingConsumer consumer) |
| 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() |
private static final org.slf4j.Logger LOGGER
private static final long DEFAULT_TIMEOUT
private RabbitQueue queue
private com.rabbitmq.client.QueueingConsumer consumer
private Map<String,FileReceiveState> fileStates
private boolean terminated
private int errorCount
private ExecutorService executor
protected SimpleFileReceiver(RabbitQueue queue, com.rabbitmq.client.QueueingConsumer consumer)
public static SimpleFileReceiver create(RabbitQueueFactory factory, String queueName) throws IOException
IOExceptionpublic static SimpleFileReceiver create(RabbitQueue queue) throws IOException
IOExceptionpublic String[] receiveData(String outputDirectory) throws IOException, com.rabbitmq.client.ShutdownSignalException, com.rabbitmq.client.ConsumerCancelledException, InterruptedException
IOExceptioncom.rabbitmq.client.ShutdownSignalExceptioncom.rabbitmq.client.ConsumerCancelledExceptionInterruptedExceptionpublic void terminate()
public void forceTermination()
protected void increaseErrorCount()
public int getErrorCount()
protected void close()
Copyright © 2017. All rights reserved.