public abstract class AbstractSubscribableChannel extends AbstractMessageChannel implements SubscribableChannel, SubscribableChannelManagement
AbstractMessageChannel.ChannelInterceptorListIntegrationManagement.ManagementOverridesinterceptors, metersEXPRESSION_PARSER, loggerINDEFINITE_TIMEOUTMETER_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, setShouldTrackafterPropertiesSet, 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, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEsend, sendgetManagedName, getManagedType, getThisAs, setManagedName, setManagedTypegetBeanName, getComponentNamepublic int getSubscriberCount()
SubscribableChannelManagementSubscribableChannelManagement の getSubscriberCount public boolean subscribe(MessageHandler handler)
SubscribableChannel の subscribe public boolean unsubscribe(MessageHandler handle)
SubscribableChannel の unsubscribe protected boolean doSend(Message<?> message, long timeout)
AbstractMessageChannelAbstractMessageChannel の doSend message - メッセージ。timeout - タイムアウト。protected abstract MessageDispatcher getDispatcher()