java.lang.Object

com.flowable.core.aws.sqs.DefaultSqsMessageListenerContainer

All Implemented Interfaces:: SqsMessageListenerContainer, org.springframework.beans.factory.DisposableBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class DefaultSqsMessageListenerContainer
extends java.lang.Object
implements SqsMessageListenerContainer, org.springframework.beans.factory.DisposableBean

Author:: Filip Hrisafov

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`protected class`	`DefaultSqsMessageListenerContainer.MessageListenerInvoker`
`protected class`	`DefaultSqsMessageListenerContainer.MessageRequestInvoker`

Field Summary

Fields
Modifier and Type	Field	Description
`protected org.springframework.core.task.AsyncTaskExecutor`	`asyncTaskExecutor`
`protected boolean`	`autoStartup`
`static int`	`DEFAULT_MAX_NUMBER_OF_MESSAGES`
`protected org.slf4j.Logger`	`logger`
`protected int`	`maxNumberOfMessages`
`protected SqsMessageDeletionPolicy`	`messageDeletionPolicy`
`protected SqsMessageListener`	`messageListener`
`protected java.lang.Object`	`monitor`
`protected int`	`phase`
`protected java.lang.String`	`queueUrl`
`protected boolean`	`running`
`protected java.util.concurrent.Future<?>`	`scheduledFuture`
`protected software.amazon.awssdk.services.sqs.SqsAsyncClient`	`sqsAsyncClient`
`protected software.amazon.awssdk.services.sqs.SqsClient`	`sqsClient`
`protected java.time.Duration`	`stopQueueTimeout`
`protected java.time.Duration`	`visibilityTimeout`
`protected java.time.Duration`	`waitTime`

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor Description

DefaultSqsMessageListenerContainer()

Method Summary

Modifier and Type	Method	Description
`protected software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest`	`createReceiveMessageRequest()`
`void`	`destroy()`
`org.springframework.core.task.AsyncTaskExecutor`	`getAsyncTaskExecutor()`
`SqsMessageDeletionPolicy`	`getMessageDeletionPolicy()`
`int`	`getPhase()`
`java.lang.String`	`getQueueUrl()`
`software.amazon.awssdk.services.sqs.SqsAsyncClient`	`getSqsAsyncClient()`
`software.amazon.awssdk.services.sqs.SqsClient`	`getSqsClient()`
`java.time.Duration`	`getStopQueueTimeout()`
`boolean`	`isAutoStartup()`
`boolean`	`isRunning()`
`void`	`setAsyncTaskExecutor(org.springframework.core.task.AsyncTaskExecutor asyncTaskExecutor)`
`void`	`setMaxNumberOfMessages(int maxNumberOfMessages)`
`void`	`setMessageDeletionPolicy(SqsMessageDeletionPolicy messageDeletionPolicy)`
`void`	`setQueueUrl(java.lang.String queueUrl)`
`void`	`setSqsAsyncClient(software.amazon.awssdk.services.sqs.SqsAsyncClient sqsAsyncClient)`
`void`	`setSqsClient(software.amazon.awssdk.services.sqs.SqsClient sqsClient)`
`void`	`setStopQueueTimeout(java.time.Duration stopQueueTimeout)`
`void`	`setupMessageListener(SqsMessageListener messageListener)`
`void`	`setVisibilityTimeout(java.time.Duration visibilityTimeout)`
`void`	`setWaitTime(java.time.Duration waitTime)`
`void`	`start()`
`void`	`stop()`
`protected void`	`submitExecution(java.lang.Runnable runnable)`

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.SmartLifecycle

stop

Field Details
- DEFAULT_MAX_NUMBER_OF_MESSAGES
  
  public static final int DEFAULT_MAX_NUMBER_OF_MESSAGES
  
  See Also:
  
  Constant Field Values
- logger
  
  protected final org.slf4j.Logger logger
- monitor
  
  protected final java.lang.Object monitor
- running
  
  protected volatile boolean running
- phase
  
  protected int phase
- autoStartup
  
  protected boolean autoStartup
- sqsAsyncClient
  
  protected software.amazon.awssdk.services.sqs.SqsAsyncClient sqsAsyncClient
- sqsClient
  
  protected software.amazon.awssdk.services.sqs.SqsClient sqsClient
- asyncTaskExecutor
  
  protected org.springframework.core.task.AsyncTaskExecutor asyncTaskExecutor
- stopQueueTimeout
  
  protected java.time.Duration stopQueueTimeout
- queueUrl
  
  protected java.lang.String queueUrl
- maxNumberOfMessages
  
  protected int maxNumberOfMessages
- visibilityTimeout
  
  protected java.time.Duration visibilityTimeout
- waitTime
  
  protected java.time.Duration waitTime
- messageDeletionPolicy
  
  protected SqsMessageDeletionPolicy messageDeletionPolicy
- messageListener
  
  protected SqsMessageListener messageListener
- scheduledFuture
  
  protected java.util.concurrent.Future<?> scheduledFuture
Constructor Details
- DefaultSqsMessageListenerContainer
  
  public DefaultSqsMessageListenerContainer()
Method Details
- destroy
  
  public void destroy()
  
  Specified by:
  
  destroy in interface org.springframework.beans.factory.DisposableBean
- isRunning
  
  public boolean isRunning()
  
  Specified by:
  
  isRunning in interface org.springframework.context.Lifecycle
- isAutoStartup
  
  public boolean isAutoStartup()
  
  Specified by:
  
  isAutoStartup in interface org.springframework.context.SmartLifecycle
- getPhase
  
  public int getPhase()
  
  Specified by:
  
  getPhase in interface org.springframework.context.Phased
  
  Specified by:
  
  getPhase in interface org.springframework.context.SmartLifecycle
- start
  
  public void start()
  
  Specified by:
  
  start in interface org.springframework.context.Lifecycle
- stop
  
  public void stop()
  
  Specified by:
  
  stop in interface org.springframework.context.Lifecycle
- submitExecution
  
  protected void submitExecution(java.lang.Runnable runnable)
- setupMessageListener
  
  public void setupMessageListener(SqsMessageListener messageListener)
  
  Specified by:
  
  setupMessageListener in interface SqsMessageListenerContainer
- createReceiveMessageRequest
  
  protected software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest createReceiveMessageRequest()
- getSqsAsyncClient
  
  public software.amazon.awssdk.services.sqs.SqsAsyncClient getSqsAsyncClient()
- setSqsAsyncClient
  
  public void setSqsAsyncClient(software.amazon.awssdk.services.sqs.SqsAsyncClient sqsAsyncClient)
- getSqsClient
  
  public software.amazon.awssdk.services.sqs.SqsClient getSqsClient()
- setSqsClient
  
  public void setSqsClient(software.amazon.awssdk.services.sqs.SqsClient sqsClient)
- getAsyncTaskExecutor
  
  public org.springframework.core.task.AsyncTaskExecutor getAsyncTaskExecutor()
- setAsyncTaskExecutor
  
  public void setAsyncTaskExecutor(org.springframework.core.task.AsyncTaskExecutor asyncTaskExecutor)
- getStopQueueTimeout
  
  public java.time.Duration getStopQueueTimeout()
- setStopQueueTimeout
  
  public void setStopQueueTimeout(java.time.Duration stopQueueTimeout)
- getQueueUrl
  
  public java.lang.String getQueueUrl()
- setQueueUrl
  
  public void setQueueUrl(java.lang.String queueUrl)
- setMaxNumberOfMessages
  
  public void setMaxNumberOfMessages(int maxNumberOfMessages)
- setVisibilityTimeout
  
  public void setVisibilityTimeout(java.time.Duration visibilityTimeout)
- setWaitTime
  
  public void setWaitTime(java.time.Duration waitTime)
- getMessageDeletionPolicy
  
  public SqsMessageDeletionPolicy getMessageDeletionPolicy()
- setMessageDeletionPolicy
  
  public void setMessageDeletionPolicy(SqsMessageDeletionPolicy messageDeletionPolicy)

Class DefaultSqsMessageListenerContainer

Nested Class Summary

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.springframework.context.SmartLifecycle

Field Details

Constructor Details

Method Details