Package com.azure.spring.integration.storage.queue.inbound

Class StorageQueueMessageSource

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.endpoint.AbstractMessageSource<org.springframework.messaging.Message<?>>

com.azure.spring.integration.storage.queue.inbound.StorageQueueMessageSource

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.integration.core.MessageSource<org.springframework.messaging.Message<?>>, org.springframework.integration.IntegrationPattern, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.IntegrationInboundManagement, org.springframework.integration.support.management.IntegrationManagement

public class StorageQueueMessageSource
extends org.springframework.integration.endpoint.AbstractMessageSource<org.springframework.messaging.Message<?>>

Inbound Message Source to receive messages from Azure Storage Queue.

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor	Description
StorageQueueMessageSource(String destination, StorageQueueTemplate storageQueueTemplate)	Construct a StorageQueueMessageSource with the specified destination and StorageQueueTemplate.
StorageQueueMessageSource(String destination, StorageQueueTemplate storageQueueTemplate, Duration visibilityTimeout)	Construct a StorageQueueMessageSource with the specified destination, StorageQueueTemplate and visibility timeout.

Method Summary

Modifier and Type	Method	Description
Object	doReceive()
String	getComponentType()

Methods inherited from class org.springframework.integration.endpoint.AbstractMessageSource

buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType

Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService, setSimpleEvaluationContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs, isObserved, registerObservationRegistry

Methods inherited from interface org.springframework.integration.core.MessageSource

getIntegrationPatternType

Constructor Details

StorageQueueMessageSource

public StorageQueueMessageSource(String destination,
 StorageQueueTemplate storageQueueTemplate)

Construct a StorageQueueMessageSource with the specified destination and StorageQueueTemplate. Default visibility timeout of 30 seconds would apply.

Parameters:

destination - the destination

storageQueueTemplate - the storage queue operation

StorageQueueMessageSource

public StorageQueueMessageSource(String destination,
 StorageQueueTemplate storageQueueTemplate,
 Duration visibilityTimeout)

Construct a StorageQueueMessageSource with the specified destination, StorageQueueTemplate and visibility timeout.

Parameters:

destination - the destination

storageQueueTemplate - the storage queue operation

visibilityTimeout - The timeout period for how long the message is invisible in the queue. If left empty the dequeued messages will be invisible for 30 seconds. The timeout must be between 1 second and 7 days

Method Details

doReceive

public Object doReceive()

Specified by:

doReceive in class org.springframework.integration.endpoint.AbstractMessageSource<org.springframework.messaging.Message<?>>

getComponentType

public String getComponentType()