AbstractSubscribableChannel

Abstract base class for {@link SubscribableChannel} implementations.

@author Rossen Stoyanchev @since 4.0

abstract

class AbstractSubscribableChannel : AbstractMessageChannel , SubscribableChannel {

this();

Set!(MessageHandler) getSubscribers();

bool hasSubscription(MessageHandler handler);

bool subscribe(MessageHandler handler);

bool unsubscribe(MessageHandler handler);

}

Constructors

this this(): Undocumented in source.

Members

Functions

getSubscribers Set!(MessageHandler) getSubscribers(): Undocumented in source. Be warned that the author may not have intended to support it.
hasSubscription bool hasSubscription(MessageHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe bool subscribe(MessageHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
unsubscribe bool unsubscribe(MessageHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From AbstractMessageChannel

id string id;: Undocumented in source.
setBeanName void setBeanName(string name): A message channel uses the bean name primarily for logging purposes.
getBeanName string getBeanName(): Return the bean name for this message channel.
setInterceptors void setInterceptors(ChannelInterceptor[] interceptors): Undocumented in source. Be warned that the author may not have intended to support it.
addInterceptor void addInterceptor(ChannelInterceptor interceptor): Undocumented in source. Be warned that the author may not have intended to support it.
addInterceptor void addInterceptor(int index, ChannelInterceptor interceptor): Undocumented in source. Be warned that the author may not have intended to support it.
getInterceptors List!(ChannelInterceptor) getInterceptors(): Undocumented in source. Be warned that the author may not have intended to support it.
removeInterceptor bool removeInterceptor(ChannelInterceptor interceptor): Undocumented in source. Be warned that the author may not have intended to support it.
removeInterceptor ChannelInterceptor removeInterceptor(int index): Undocumented in source. Be warned that the author may not have intended to support it.
send bool send(MessageBase message, long timeout): Undocumented in source. Be warned that the author may not have intended to support it.
sendInternal bool sendInternal(MessageBase message, long timeout): Undocumented in source.
toString string toString(): Undocumented in source. Be warned that the author may not have intended to support it.
ChannelInterceptorChain class ChannelInterceptorChain: Assists with the invocation of the configured channel interceptors.

From SubscribableChannel

subscribe bool subscribe(MessageHandler handler): Register a message handler. @return {@code true} if the handler was subscribed or {@code false} if it was already subscribed.
unsubscribe bool unsubscribe(MessageHandler handler): Un-register a message handler. @return {@code true} if the handler was un-registered, or {@code false} if was not registered.

AbstractSubscribableChannel

Constructors

Members

Functions

Inherited Members

From AbstractMessageChannel

From SubscribableChannel

Meta

Source