public class PubSubInboundChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
Constructor and Description |
---|
PubSubInboundChannelAdapter(PubSubOperations pubSubTemplate,
String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
AckMode |
getAckMode() |
org.springframework.messaging.converter.MessageConverter |
getMessageConverter() |
void |
setAckMode(AckMode ackMode) |
void |
setMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter)
Sets the
MessageConverter to convert the payload of the incoming message from
Pub/Sub. |
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString
public PubSubInboundChannelAdapter(PubSubOperations pubSubTemplate, String subscriptionName)
protected void doStart()
doStart
in class org.springframework.integration.endpoint.MessageProducerSupport
protected void doStop()
doStop
in class org.springframework.integration.endpoint.MessageProducerSupport
public AckMode getAckMode()
public void setAckMode(AckMode ackMode)
public org.springframework.messaging.converter.MessageConverter getMessageConverter()
public void setMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter)
MessageConverter
to convert the payload of the incoming message from
Pub/Sub.
If messageConverter
is null, the payload of the Pub/Sub message is converted to
byte[]
and returned in that form.messageConverter
- converts the payload of the incoming message from Pub/SubCopyright © 2018 Pivotal Software, Inc.. All rights reserved.