org.springframework.integration.redis.channel
Class SubscribableRedisChannel
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.redis.channel.SubscribableRedisChannel
- All Implemented Interfaces:
- org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.NamedComponent, org.springframework.integration.core.SubscribableChannel, org.springframework.integration.history.TrackableComponent, org.springframework.integration.MessageChannel
public class SubscribableRedisChannel
- extends org.springframework.integration.channel.AbstractMessageChannel
- implements org.springframework.integration.core.SubscribableChannel, org.springframework.context.SmartLifecycle, org.springframework.beans.factory.DisposableBean
- Since:
- 2.0
| Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel |
org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList |
| Fields inherited from class org.springframework.integration.channel.AbstractMessageChannel |
logger |
|
Constructor Summary |
SubscribableRedisChannel(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
java.lang.String topicName)
|
|
Method Summary |
void |
destroy()
|
protected boolean |
doSend(org.springframework.integration.Message<?> message,
long arg1)
|
int |
getPhase()
|
boolean |
isAutoStartup()
|
boolean |
isRunning()
|
void |
onInit()
|
void |
setMaxSubscribers(int maxSubscribers)
Specify the maximum number of subscribers supported by the
channel's dispatcher. |
void |
setMessageConverter(org.springframework.integration.support.converter.MessageConverter messageConverter)
|
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.integration.core.MessageHandler handler)
|
boolean |
unsubscribe(org.springframework.integration.core.MessageHandler handler)
|
| Methods inherited from class org.springframework.integration.channel.AbstractMessageChannel |
addInterceptor, getComponentType, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrack |
| Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setTaskScheduler, toString |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Methods inherited from interface org.springframework.integration.MessageChannel |
send, send |
| Methods inherited from interface org.springframework.integration.context.NamedComponent |
getComponentName |
SubscribableRedisChannel
public SubscribableRedisChannel(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
java.lang.String topicName)
setTaskExecutor
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
setMessageConverter
public void setMessageConverter(org.springframework.integration.support.converter.MessageConverter messageConverter)
setSerializer
public void setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)
setMaxSubscribers
public void setMaxSubscribers(int maxSubscribers)
- Specify the maximum number of subscribers supported by the
channel's dispatcher.
- Parameters:
maxSubscribers -
subscribe
public boolean subscribe(org.springframework.integration.core.MessageHandler handler)
- Specified by:
subscribe in interface org.springframework.integration.core.SubscribableChannel
unsubscribe
public boolean unsubscribe(org.springframework.integration.core.MessageHandler handler)
- Specified by:
unsubscribe in interface org.springframework.integration.core.SubscribableChannel
doSend
protected boolean doSend(org.springframework.integration.Message<?> message,
long arg1)
- Specified by:
doSend in class org.springframework.integration.channel.AbstractMessageChannel
onInit
public void onInit()
throws java.lang.Exception
- Overrides:
onInit in class org.springframework.integration.context.IntegrationObjectSupport
- Throws:
java.lang.Exception
isAutoStartup
public boolean isAutoStartup()
- Specified by:
isAutoStartup in interface org.springframework.context.SmartLifecycle
getPhase
public int getPhase()
- Specified by:
getPhase in interface org.springframework.context.Phased
isRunning
public boolean isRunning()
- Specified by:
isRunning in interface org.springframework.context.Lifecycle
start
public void start()
- Specified by:
start in interface org.springframework.context.Lifecycle
stop
public void stop()
- Specified by:
stop in interface org.springframework.context.Lifecycle
stop
public void stop(java.lang.Runnable callback)
- Specified by:
stop in interface org.springframework.context.SmartLifecycle
destroy
public void destroy()
throws java.lang.Exception
- Specified by:
destroy in interface org.springframework.beans.factory.DisposableBean
- Throws:
java.lang.Exception