public class PubSubInboundChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
Constructor and Description |
---|
PubSubInboundChannelAdapter(PubSubTemplate pubSubTemplate,
String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
AckMode |
getAckMode() |
Class |
getPayloadType() |
void |
setAckMode(AckMode ackMode) |
void |
setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<Map<String,String>> headerMapper)
Set the header mapper to map headers from incoming
PubsubMessage into
Message . |
void |
setPayloadType(Class payloadType)
Set the desired type of the payload of the
Message constructed by
converting the incoming Pub/Sub message. |
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(PubSubTemplate 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 Class getPayloadType()
public void setPayloadType(Class payloadType)
Message
constructed by
converting the incoming Pub/Sub message. The channel adapter will use the
PubSubTemplate.getMessageConverter()
to do the conversion to the desired type.
The default payload type is byte[].class
payloadType
- the type of the payload of the Message
produce by the
adapter. Cannot be set to null.Copyright © 2018 Pivotal Software, Inc.. All rights reserved.