org.springframework.integration.channel

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

Author:

Gary Russell

Field Summary

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
FixedSubscriberChannel()
FixedSubscriberChannel(org.springframework.messaging.MessageHandler handler)

Method Summary

Modifier and Type	Method and Description
String	getComponentName()
String	getComponentType()
boolean	send(org.springframework.messaging.Message<?> message)
boolean	send(org.springframework.messaging.Message<?> message, long timeout)
void	setBeanName(String name)
boolean	subscribe(org.springframework.messaging.MessageHandler handler)
boolean	unsubscribe(org.springframework.messaging.MessageHandler handler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FixedSubscriberChannel

public FixedSubscriberChannel()

FixedSubscriberChannel

public FixedSubscriberChannel(org.springframework.messaging.MessageHandler handler)

Method Detail

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

send

public boolean send(org.springframework.messaging.Message<?> message)

Specified by:

send in interface org.springframework.messaging.MessageChannel

send

public boolean send(org.springframework.messaging.Message<?> message,
                    long timeout)

Specified by:

send in interface org.springframework.messaging.MessageChannel

subscribe

public boolean subscribe(org.springframework.messaging.MessageHandler handler)

Specified by:

subscribe in interface org.springframework.messaging.SubscribableChannel

unsubscribe

public boolean unsubscribe(org.springframework.messaging.MessageHandler handler)

Specified by:

unsubscribe in interface org.springframework.messaging.SubscribableChannel

getComponentType

public String getComponentType()

Specified by:

getComponentType in interface NamedComponent

getComponentName

public String getComponentName()

Specified by:

getComponentName in interface NamedComponent