Class FixedSubscriberChannel
java.lang.Object
org.springframework.integration.channel.FixedSubscriberChannel
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanNameAware,NamedComponent,org.springframework.messaging.MessageChannel,org.springframework.messaging.SubscribableChannel
public final class FixedSubscriberChannel extends java.lang.Object implements org.springframework.messaging.SubscribableChannel, org.springframework.beans.factory.BeanNameAware, NamedComponent
Specialized
SubscribableChannel for a single final subscriber set up during bean instantiation (unlike
other SubscribableChannels where the MessageHandler is subscribed when the endpoint
is started). This channel does not support interceptors or data types.
Note: Stopping (unsubscribe(MessageHandler)) the subscribed (MessageHandler) has no effect.
- Since:
- 4.0
-
Field Summary
-
Constructor Summary
Constructors Constructor Description FixedSubscriberChannel()FixedSubscriberChannel(org.springframework.messaging.MessageHandler handler) -
Method Summary
Modifier and Type Method Description java.lang.StringgetBeanName()java.lang.StringgetComponentName()java.lang.StringgetComponentType()booleansend(org.springframework.messaging.Message<?> message)booleansend(org.springframework.messaging.Message<?> message, long timeout)voidsetBeanName(java.lang.String name)booleansubscribe(org.springframework.messaging.MessageHandler handler)booleanunsubscribe(org.springframework.messaging.MessageHandler handler)
-
Constructor Details
-
FixedSubscriberChannel
public FixedSubscriberChannel() -
FixedSubscriberChannel
public FixedSubscriberChannel(org.springframework.messaging.MessageHandler handler)
-
-
Method Details
-
setBeanName
public void setBeanName(java.lang.String name)- Specified by:
setBeanNamein interfaceorg.springframework.beans.factory.BeanNameAware
-
getBeanName
public java.lang.String getBeanName()- Specified by:
getBeanNamein interfaceNamedComponent
-
send
public boolean send(org.springframework.messaging.Message<?> message)- Specified by:
sendin interfaceorg.springframework.messaging.MessageChannel
-
send
public boolean send(org.springframework.messaging.Message<?> message, long timeout)- Specified by:
sendin interfaceorg.springframework.messaging.MessageChannel
-
subscribe
public boolean subscribe(org.springframework.messaging.MessageHandler handler)- Specified by:
subscribein interfaceorg.springframework.messaging.SubscribableChannel
-
unsubscribe
public boolean unsubscribe(org.springframework.messaging.MessageHandler handler)- Specified by:
unsubscribein interfaceorg.springframework.messaging.SubscribableChannel
-
getComponentType
public java.lang.String getComponentType()- Specified by:
getComponentTypein interfaceNamedComponent
-
getComponentName
public java.lang.String getComponentName()- Specified by:
getComponentNamein interfaceNamedComponent
-