public class PollableKafkaChannel extends AbstractKafkaChannel implements org.springframework.messaging.PollableChannel, org.springframework.integration.channel.ExecutorChannelInterceptorAware
logger, topicinterceptors, meters| Constructor and Description |
|---|
PollableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?,?> template,
KafkaMessageSource<?,?> source)
Construct an instance with the provided parameters.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor) |
void |
addInterceptor(int index,
org.springframework.messaging.support.ChannelInterceptor interceptor) |
protected org.springframework.messaging.Message<?> |
doReceive() |
boolean |
hasExecutorInterceptors() |
org.springframework.messaging.Message<?> |
receive() |
org.springframework.messaging.Message<?> |
receive(long timeout) |
boolean |
removeInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor) |
org.springframework.messaging.support.ChannelInterceptor |
removeInterceptor(int index) |
void |
setInterceptors(java.util.List<org.springframework.messaging.support.ChannelInterceptor> interceptors) |
doSend, getGroupId, setGroupIddestroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, onInit, registerMetricsCaptor, send, send, setDatatypes, setLoggingEnabled, setMessageConverter, setShouldTrackafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetInterceptorspublic PollableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?,?> template,
KafkaMessageSource<?,?> source)
template - the template for sending.source - the source for receiving.@Nullable public org.springframework.messaging.Message<?> receive()
receive in interface org.springframework.messaging.PollableChannel@Nullable public org.springframework.messaging.Message<?> receive(long timeout)
receive in interface org.springframework.messaging.PollableChannel@Nullable protected org.springframework.messaging.Message<?> doReceive()
public void setInterceptors(java.util.List<org.springframework.messaging.support.ChannelInterceptor> interceptors)
setInterceptors in interface org.springframework.messaging.support.InterceptableChannelsetInterceptors in class org.springframework.integration.channel.AbstractMessageChannelpublic void addInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor)
addInterceptor in interface org.springframework.messaging.support.InterceptableChanneladdInterceptor in class org.springframework.integration.channel.AbstractMessageChannelpublic void addInterceptor(int index,
org.springframework.messaging.support.ChannelInterceptor interceptor)
addInterceptor in interface org.springframework.messaging.support.InterceptableChanneladdInterceptor in class org.springframework.integration.channel.AbstractMessageChannelpublic boolean removeInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor)
removeInterceptor in interface org.springframework.messaging.support.InterceptableChannelremoveInterceptor in class org.springframework.integration.channel.AbstractMessageChannel@Nullable public org.springframework.messaging.support.ChannelInterceptor removeInterceptor(int index)
removeInterceptor in interface org.springframework.messaging.support.InterceptableChannelremoveInterceptor in class org.springframework.integration.channel.AbstractMessageChannelpublic boolean hasExecutorInterceptors()
hasExecutorInterceptors in interface org.springframework.integration.channel.ExecutorChannelInterceptorAware