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 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
Fields inherited from interface org.springframework.messaging.MessageChannel
INDEFINITE_TIMEOUT -
Constructor Summary
ConstructorsConstructorDescriptionFixedSubscriberChannel(org.springframework.messaging.MessageHandler handler) -
Method Summary
Modifier and TypeMethodDescriptionbooleansend(org.springframework.messaging.Message<?> message) booleansend(org.springframework.messaging.Message<?> message, long timeout) voidsetBeanName(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
- Specified by:
setBeanNamein interfaceorg.springframework.beans.factory.BeanNameAware
-
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
- Specified by:
getComponentTypein interfaceNamedComponent
-
getComponentName
- Specified by:
getComponentNamein interfaceNamedComponent
-