public class PubSubMessageSource extends org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource<Object>
AbstractMessageSource
.Constructor and Description |
---|
PubSubMessageSource(PubSubSubscriberOperations pubSubSubscriberOperations,
String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
protected Object |
doReceive(int fetchSize)
Provides a single polled message.
|
String |
getComponentType() |
void |
setAckMode(AckMode ackMode) |
void |
setBlockOnPull(boolean blockOnPull)
Instructs synchronous pull to wait until at least one message is available.
|
void |
setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<Map<String,String>> headerMapper) |
void |
setPayloadType(Class<?> payloadType) |
doReceive, getMaxFetchSize, setMaxFetchSize
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getManagedName, getManagedType, getMessageCount, getMessageCountLong, messageCount, setManagedName, setManagedType
public PubSubMessageSource(PubSubSubscriberOperations pubSubSubscriberOperations, String subscriptionName)
public void setAckMode(AckMode ackMode)
public void setPayloadType(Class<?> payloadType)
public void setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<Map<String,String>> headerMapper)
public void setBlockOnPull(boolean blockOnPull)
blockOnPull
- whether to block until a message is availableprotected Object doReceive(int fetchSize)
Messages are received from Pub/Sub by synchronous pull, in batches determined
by fetchSize
.
doReceive
in class org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource<Object>
fetchSize
- number of messages to fetch from Pub/Sub.Message
wrapper containing the original message.public String getComponentType()
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.