org.openimaj.picslurper.output

Class ZMQOutputListener

java.lang.Object

org.openimaj.picslurper.output.ZMQOutputListener

All Implemented Interfaces:

OutputListener

public class ZMQOutputListener
extends Object
implements OutputListener

Using ZeroMQ (because it is awesome and I wanted to learn it so fuck off) we set up a subscription based server which tells anyone listening about any new images. The name of the queue can be specified

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

Constructor Summary

Constructors

Constructor and Description
ZMQOutputListener() Construct the publishing connector

Method Summary

Modifier and Type	Method and Description
void	failedURL(URL url, String reason) Called for every URL that is a failure
void	finished() When the picslurper is done
void	newImageDownloaded(WriteableImageOutput written) Called for each image successfully downloaded.
void	prepare() start things off

Methods inherited from class java.lang.Object

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

Constructor Detail

ZMQOutputListener

public ZMQOutputListener()

Construct the publishing connector

Method Detail

newImageDownloaded

public void newImageDownloaded(WriteableImageOutput written)

Description copied from interface: OutputListener

Called for each image successfully downloaded. This function is told about the status which generated the image, the url from which the image was eventually downloaded (after various redirects) and the output file. The StatusConsumption instance from the StatusConsumer that processed the status is also provided

Specified by:

newImageDownloaded in interface OutputListener

failedURL

public void failedURL(URL url,
                      String reason)

Description copied from interface: OutputListener

Called for every URL that is a failure

Specified by:

failedURL in interface OutputListener

finished

public void finished()

Description copied from interface: OutputListener

When the picslurper is done

Specified by:

finished in interface OutputListener

prepare

public void prepare()

Description copied from interface: OutputListener

start things off

Specified by:

prepare in interface OutputListener