Module com.erudika.para.server

Package com.erudika.para.server.queue

Class River

java.lang.Object

com.erudika.para.server.queue.River

All Implemented Interfaces:

Runnable

public abstract class River
extends Object
implements Runnable

Pulls messages from a queue and processes them. Adapted from https://github.com/albogdano/elasticsearch-river-amazonsqs

Author:

Alex Bogdanovski [[email protected]]

Constructor Summary

Constructors

Constructor	Description
River()

Method Summary

Modifier and Type	Method	Description
void	run()	Starts the river.

Methods inherited from class java.lang.Object

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

Constructor Details

River

public River()

Method Details

run

public void run()

Starts the river.

Specified by:

run in interface Runnable