Package com.flowable.core.aws.sqs.eventregistry

Class SqsInboundChannelModel

java.lang.Object
org.flowable.eventregistry.model.ChannelModel
org.flowable.eventregistry.model.InboundChannelModel
com.flowable.core.aws.sqs.eventregistry.SqsInboundChannelModel
public class SqsInboundChannelModel
extends org.flowable.eventregistry.model.InboundChannelModel
Author:
Filip Hrisafov

  • Field Summary

    Fields 
    Modifier and Type Field Description
    protected java.lang.String maxNumberOfMessages
    The max number of messages to return when requesting messages.
    protected java.lang.String messageDeletionPolicy
    The deletion policy for the messages.
    protected java.lang.String queue
    The logical name of the queue on which the inbound channel should listen to.
    protected java.lang.String visibilityTimeout
    The duration that the received message are hidden from subsequent retrieve requests, after being retrieved.
    protected java.lang.String waitTime
    The duration for which the retrieve message calls waits for messages to arrive in the queue before returning.

    Fields inherited from class org.flowable.eventregistry.model.InboundChannelModel

    channelEventKeyDetection, channelEventTenantIdDetection, deserializerDelegateExpression, deserializerType, eventTransformerDelegateExpression, inboundEventChannelAdapter, inboundEventProcessingPipeline, payloadExtractorDelegateExpression, pipelineDelegateExpression

    Fields inherited from class org.flowable.eventregistry.model.ChannelModel

    category, channelType, description, key, name, type

  • Constructor Summary

    Constructors 
    Constructor Description
    SqsInboundChannelModel()  

  • Method Summary

    Modifier and Type Method Description
    java.lang.String getMaxNumberOfMessages()  
    java.lang.String getMessageDeletionPolicy()  
    java.lang.String getQueue()  
    java.lang.String getVisibilityTimeout()  
    java.lang.String getWaitTime()  
    void setMaxNumberOfMessages​(java.lang.String maxNumberOfMessages)  
    void setMessageDeletionPolicy​(java.lang.String messageDeletionPolicy)  
    void setQueue​(java.lang.String queue)  
    void setVisibilityTimeout​(java.lang.String visibilityTimeout)  
    void setWaitTime​(java.lang.String waitTime)  

    Methods inherited from class org.flowable.eventregistry.model.InboundChannelModel

    getChannelEventKeyDetection, getChannelEventTenantIdDetection, getDeserializerDelegateExpression, getDeserializerType, getEventTransformerDelegateExpression, getInboundEventChannelAdapter, getInboundEventProcessingPipeline, getPayloadExtractorDelegateExpression, getPipelineDelegateExpression, setChannelEventKeyDetection, setChannelEventTenantIdDetection, setDeserializerDelegateExpression, setDeserializerType, setEventTransformerDelegateExpression, setInboundEventChannelAdapter, setInboundEventProcessingPipeline, setPayloadExtractorDelegateExpression, setPipelineDelegateExpression

    Methods inherited from class org.flowable.eventregistry.model.ChannelModel

    getCategory, getChannelType, getDescription, getKey, getName, getType, setCategory, setChannelType, setDescription, setKey, setName, setType

    Methods inherited from class java.lang.Object

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

  • Field Details

    • queue

      protected java.lang.String queue
      The logical name of the queue on which the inbound channel should listen to. It is also possible to use the full url of the queue.

    • maxNumberOfMessages

      protected java.lang.String maxNumberOfMessages
      The max number of messages to return when requesting messages.

    • visibilityTimeout

      protected java.lang.String visibilityTimeout
      The duration that the received message are hidden from subsequent retrieve requests, after being retrieved.

    • waitTime

      protected java.lang.String waitTime
      The duration for which the retrieve message calls waits for messages to arrive in the queue before returning. See the AWS SDK documentation about long polling for more information.

    • messageDeletionPolicy

      protected java.lang.String messageDeletionPolicy
      The deletion policy for the messages.

  • Constructor Details

  • Method Details