public class SubscribableKafkaChannel extends AbstractKafkaChannel implements org.springframework.messaging.SubscribableChannel, org.springframework.context.SmartLifecycle
logger, topicinterceptors, meters| Constructor and Description |
|---|
SubscribableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?,?> template,
org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory,
java.lang.String channelTopic)
Construct an instance with the provided parameters.
|
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.integration.dispatcher.MessageDispatcher |
createDispatcher() |
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
protected void |
onInit() |
void |
setAutoStartup(boolean autoStartup)
Set the auto startup.
|
void |
setPhase(int phase)
Set the phase.
|
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
boolean |
subscribe(org.springframework.messaging.MessageHandler handler) |
boolean |
unsubscribe(org.springframework.messaging.MessageHandler handler) |
doSend, getGroupId, setGroupIdaddInterceptor, addInterceptor, configureMetrics, destroy, getComponentType, getErrorRate, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMetricsCaptor, getMinSendDuration, getOverrides, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, registerMetricsCaptor, removeInterceptor, removeInterceptor, reset, send, send, setCountsEnabled, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrack, setStatsEnabledafterPropertiesSet, 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, waitpublic SubscribableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?,?> template,
org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory,
java.lang.String channelTopic)
template - template for sending.factory - factory for creating a container for receiving.channelTopic - the topic.public int getPhase()
getPhase in interface org.springframework.context.PhasedgetPhase in interface org.springframework.context.SmartLifecyclepublic void setPhase(int phase)
phase - the phase.Phasedpublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic void setAutoStartup(boolean autoStartup)
autoStartup - true to automatically start.SmartLifecyclepublic boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecycleprotected void onInit()
onInit in class org.springframework.integration.channel.AbstractMessageChannelprotected org.springframework.integration.dispatcher.MessageDispatcher createDispatcher()
public void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecyclepublic boolean subscribe(org.springframework.messaging.MessageHandler handler)
subscribe in interface org.springframework.messaging.SubscribableChannelpublic boolean unsubscribe(org.springframework.messaging.MessageHandler handler)
unsubscribe in interface org.springframework.messaging.SubscribableChannel