Module com.erudika.para.core

Package com.erudika.para.core.queue

Class MockQueue

java.lang.Object

com.erudika.para.core.queue.MockQueue

All Implemented Interfaces:

Queue

@Singleton
public class MockQueue
extends Object
implements Queue

Author:

Alex Bogdanovski [[email protected]]

Constructor Summary

Constructors

Constructor	Description
MockQueue()	Default constructor.
MockQueue(String name)

Method Summary

Modifier and Type	Method	Description
String	getName()	Returns the name of the queue.
String	pull()	Pulls one or more messages from a queue.
void	push(String task)	Pushes a message to a queue.
void	setName(String name)	Sets the name of the queue.
void	startPolling()	Start a new async task which polls the queue and automatically processes the messages.
void	stopPolling()	Stops the polling async task manually.

Methods inherited from class java.lang.Object

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

Constructor Details

MockQueue

public MockQueue()

Default constructor.

MockQueue

public MockQueue(String name)

Parameters:

name - name

Method Details

pull

public String pull()

Description copied from interface: Queue

Pulls one or more messages from a queue.

Specified by:

pull in interface Queue

Returns:

the message

push

public void push(String task)

Description copied from interface: Queue

Pushes a message to a queue.

Specified by:

push in interface Queue

Parameters:

task - the message

getName

public String getName()

Description copied from interface: Queue

Returns the name of the queue.

Specified by:

getName in interface Queue

Returns:

the queue name

setName

public void setName(String name)

Description copied from interface: Queue

Sets the name of the queue.

Specified by:

setName in interface Queue

Parameters:

name - a name

startPolling

public void startPolling()

Description copied from interface: Queue

Start a new async task which polls the queue and automatically processes the messages. This was inspired by Elasticsearch rivers.

Specified by:

startPolling in interface Queue

stopPolling

public void stopPolling()

Description copied from interface: Queue

Stops the polling async task manually. This method should always be called on shutdown.

Specified by:

stopPolling in interface Queue