Class SQSQueuePoller

java.lang.Object

com.kingsrook.qqq.backend.core.actions.queues.SQSQueuePoller

All Implemented Interfaces:

Runnable

public class SQSQueuePoller
extends Object
implements Runnable

Class to poll an SQS queue, and run process code for each message found.

Constructor Summary

Constructors

Constructor	Description
SQSQueuePoller()

Method Summary

Modifier and Type	Method	Description
void	run()
void	setQInstance(QInstance qInstance)	Setter for qInstance
void	setQueueMetaData(QQueueMetaData queueMetaData)	Setter for queueMetaData
void	setQueueProviderMetaData(SQSQueueProviderMetaData queueProviderMetaData)	Setter for queueProviderMetaData
void	setSessionSupplier(Supplier<QSession> sessionSupplier)	Setter for sessionSupplier

Methods inherited from class java.lang.Object

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

Constructor Details

SQSQueuePoller

public SQSQueuePoller()

Method Details

run

public void run()

Specified by:

run in interface Runnable

setQueueProviderMetaData

public void setQueueProviderMetaData(SQSQueueProviderMetaData queueProviderMetaData)

Setter for queueProviderMetaData

setQueueMetaData

public void setQueueMetaData(QQueueMetaData queueMetaData)

Setter for queueMetaData

setQInstance

public void setQInstance(QInstance qInstance)

Setter for qInstance

setSessionSupplier

public void setSessionSupplier(Supplier<QSession> sessionSupplier)

Setter for sessionSupplier