public abstract class AbstractSubscribableChannel extends AbstractMessageChannel implements SubscribableChannel, SubscribableChannelManagement
AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
interceptors, meters
EXPRESSION_PARSER, logger
INDEFINITE_TIMEOUT
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
AbstractSubscribableChannel() |
修飾子と型 | メソッドと説明 |
---|---|
protected boolean | doSend(Message<?> message, long timeout) サブクラスはこのメソッドを実装する必要があります。 |
protected abstract MessageDispatcher | getDispatcher() |
int | getSubscriberCount() このチャネルに現在サブスクライブしているメッセージハンドラーの数。 |
boolean | subscribe(MessageHandler handler) |
boolean | unsubscribe(MessageHandler handle) |
addInterceptor, addInterceptor, destroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, onInit, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrack
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
send, send
getManagedName, getManagedType, getThisAs, setManagedName, setManagedType
getBeanName, getComponentName
public int getSubscriberCount()
SubscribableChannelManagement
SubscribableChannelManagement
の getSubscriberCount
public boolean subscribe(MessageHandler handler)
SubscribableChannel
の subscribe
public boolean unsubscribe(MessageHandler handle)
SubscribableChannel
の unsubscribe
protected boolean doSend(Message<?> message, long timeout)
AbstractMessageChannel
AbstractMessageChannel
の doSend
message
- メッセージ。timeout
- タイムアウト。protected abstract MessageDispatcher getDispatcher()