org.dice_research.ldcbench.rabbit

Class SimpleFileQueueConsumer

java.lang.Object

org.dice_research.ldcbench.rabbit.SimpleFileQueueConsumer

All Implemented Interfaces:

Closeable, AutoCloseable

public class SimpleFileQueueConsumer
extends Object
implements Closeable

This class implements receiving SimpleFile-s coming through a queue.

Field Summary

Fields

Modifier and Type	Field and Description
private String	outputDir
private org.hobbit.core.rabbit.SimpleFileReceiver	receiver
private Thread	thread

Constructor Summary

Constructors

Constructor and Description
SimpleFileQueueConsumer(org.hobbit.core.rabbit.RabbitQueueFactory queueFactory, String queueName) Initializes consuming of messages coming through specified queue.

Method Summary

Modifier and Type	Method and Description
void	close() Terminates the receiving and waits until remaining data is processed.
private static String	getTempDir()
void	handle(String[] files) Abstract method which is called when receiving is terminated.

Methods inherited from class java.lang.Object

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

Field Detail

outputDir

private String outputDir

receiver

private org.hobbit.core.rabbit.SimpleFileReceiver receiver

thread

private Thread thread

Constructor Detail

SimpleFileQueueConsumer

public SimpleFileQueueConsumer(org.hobbit.core.rabbit.RabbitQueueFactory queueFactory,
                               String queueName)
                        throws IOException

Initializes consuming of messages coming through specified queue.

Parameters:

queueFactory - factory to create queues with

queueName - name of the queue

Throws:

IOException

Method Detail

getTempDir

private static String getTempDir()
                          throws IOException

Throws:

IOException

close

public void close()

Terminates the receiving and waits until remaining data is processed.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

handle

public void handle(String[] files)

Abstract method which is called when receiving is terminated.

Parameters:

files - array of file names received