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
ConstructorDescriptionStorageQueueMessageSource
(String destination, StorageQueueTemplate storageQueueTemplate) Construct aStorageQueueMessageSource
with the specified destination andStorageQueueTemplate
.StorageQueueMessageSource
(String destination, StorageQueueTemplate storageQueueTemplate, Duration visibilityTimeout) Construct aStorageQueueMessageSource
with the specified destination,StorageQueueTemplate
and visibility timeout. -
Method Summary
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
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
Methods inherited from interface org.springframework.integration.core.MessageSource
getIntegrationPatternType
-
Constructor Details
-
StorageQueueMessageSource
Construct aStorageQueueMessageSource
with the specified destination andStorageQueueTemplate
. Default visibility timeout of 30 seconds would apply.- Parameters:
destination
- the destinationstorageQueueTemplate
- the storage queue operation
-
StorageQueueMessageSource
public StorageQueueMessageSource(String destination, StorageQueueTemplate storageQueueTemplate, Duration visibilityTimeout) Construct aStorageQueueMessageSource
with the specified destination,StorageQueueTemplate
and visibility timeout.- Parameters:
destination
- the destinationstorageQueueTemplate
- the storage queue operationvisibilityTimeout
- 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
- Specified by:
doReceive
in classorg.springframework.integration.endpoint.AbstractMessageSource<org.springframework.messaging.Message<?>>
-
getComponentType
-