Module com.erudika.para.server

Package com.erudika.para.server.queue

Class AWSQueue

java.lang.Object

com.erudika.para.server.queue.AWSQueue

All Implemented Interfaces:

com.erudika.para.core.queue.Queue

@Singleton
public class AWSQueue
extends Object
implements com.erudika.para.core.queue.Queue

An implementation of the Queue interface using the AWS Simple Queue Service.

Author:

Alex Bogdanovski [[email protected]]

Constructor Summary

Constructors

Constructor	Description
AWSQueue()	No-args constructor.
AWSQueue(String name)	Default consturctor.

Method Summary

Modifier and Type	Method	Description
String	getName()
String	getUrl()	Returns the queue URL on SQS.
String	pull()
void	push(String msg)
void	setName(String name)
void	startPolling()
void	stopPolling()

Methods inherited from class java.lang.Object

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

Constructor Details

AWSQueue

public AWSQueue()

No-args constructor.

AWSQueue

public AWSQueue(String name)

Default consturctor. This queue contains only messages in JSON format.

Parameters:

name - name of the queue

Method Details

push

public void push(String msg)

Specified by:

push in interface com.erudika.para.core.queue.Queue

pull

public String pull()

Specified by:

pull in interface com.erudika.para.core.queue.Queue

startPolling

public void startPolling()

Specified by:

startPolling in interface com.erudika.para.core.queue.Queue

stopPolling

public void stopPolling()

Specified by:

stopPolling in interface com.erudika.para.core.queue.Queue

getName

public String getName()

Specified by:

getName in interface com.erudika.para.core.queue.Queue

setName

public void setName(String name)

Specified by:

setName in interface com.erudika.para.core.queue.Queue

getUrl

public String getUrl()

Returns the queue URL on SQS.

Returns:

returns the URL of this queue