public class SubscribableRedisChannel extends AbstractMessageChannel implements org.springframework.messaging.SubscribableChannel, org.springframework.context.SmartLifecycle, org.springframework.beans.factory.DisposableBean
AbstractMessageChannel.ChannelInterceptorListIntegrationManagement.ManagementOverridesinterceptorsEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
SubscribableRedisChannel(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
java.lang.String topicName) |
| Modifier and Type | Method and Description |
|---|---|
void |
destroy() |
protected boolean |
doSend(org.springframework.messaging.Message<?> message,
long arg1)
Subclasses must implement this method.
|
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setMaxSubscribers(int maxSubscribers)
Specify the maximum number of subscribers supported by the
channel's dispatcher.
|
void |
setMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter)
Specify the
MessageConverter to use when trying to convert to
one of this channel's supported datatypes (in order) for a Message whose payload
does not already match. |
void |
setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer) |
void |
setTaskExecutor(java.util.concurrent.Executor taskExecutor) |
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
boolean |
subscribe(org.springframework.messaging.MessageHandler handler) |
boolean |
unsubscribe(org.springframework.messaging.MessageHandler handler) |
addInterceptor, addInterceptor, configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, 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, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, 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, waitgetComponentNamepublic SubscribableRedisChannel(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
java.lang.String topicName)
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
public void setMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter)
AbstractMessageChannelMessageConverter to use when trying to convert to
one of this channel's supported datatypes (in order) for a Message whose payload
does not already match.
Note: only the MessageConverter.fromMessage(Message, Class)
method is used. If the returned object is not a Message, the inbound
headers will be copied; if the returned object is a Message, it is
expected that the converter will have fully populated the headers; no
further action is performed by the channel. If null is returned,
conversion to the next datatype (if any) will be attempted.
Defaults to a DefaultDatatypeChannelMessageConverter.
setMessageConverter in class AbstractMessageChannelmessageConverter - The message converter.public void setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)
public void setMaxSubscribers(int maxSubscribers)
maxSubscribers - The maximum number of subscribers allowed.public 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.SubscribableChannelprotected boolean doSend(org.springframework.messaging.Message<?> message,
long arg1)
AbstractMessageChanneldoSend in class AbstractMessageChannelmessage - The message.arg1 - The timeout.public void onInit()
throws java.lang.Exception
IntegrationObjectSupportonInit in class AbstractMessageChanneljava.lang.Exception - Any exception.public boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic int getPhase()
getPhase in interface org.springframework.context.PhasedgetPhase in interface org.springframework.context.SmartLifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic 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 void destroy()
throws java.lang.Exception
destroy in interface org.springframework.beans.factory.DisposableBeanjava.lang.Exception