public class PointToPointSubscribableAmqpChannel extends AbstractAmqpChannel
AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
interceptors, meters
EXPRESSION_PARSER, logger
INDEFINITE_TIMEOUT
DEFAULT_PHASE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
PointToPointSubscribableAmqpChannel(StringSE channelName, AbstractMessageListenerContainer container, AmqpTemplate amqpTemplate) 指定された名前、コンテナー、テンプレートでインスタンスを作成します。メッセージがマップされる場合、デフォルトのヘッダーマッパーが使用されます。 |
PointToPointSubscribableAmqpChannel(StringSE channelName, AbstractMessageListenerContainer container, AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper) 指定された名前、コンテナー、テンプレートでインスタンスを作成します。メッセージがマップされる場合、デフォルトのヘッダーマッパーが使用されます。 |
修飾子と型 | メソッドと説明 |
---|---|
protected AbstractDispatcher | createDispatcher() |
void | destroy() |
protected void | doDeclares() |
int | getPhase() |
protected StringSE | getRoutingKey() サブクラスは、このメソッドをオーバーライドしてルーティングキーを返す場合があります。 |
boolean | isAutoStartup() |
boolean | isRunning() |
protected StringSE | obtainQueueName(StringSE channelName) |
void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setMaxSubscribers(int maxSubscribers) チャネルのディスパッチャーでサポートされるサブスクライバーの最大数を指定します( AbstractDispatcher の場合)。 |
void | setQueueName(StringSE queueName) 使用するキュー名を指定します。 |
void | start() |
void | stop() |
void | stop(RunnableSE callback) |
boolean | subscribe(MessageHandler handler) |
boolean | unsubscribe(MessageHandler handler) |
doSend, getAdmin, getAmqpTemplate, getConnectionFactory, getExchangeName, getInboundHeaderMapper, getRabbitTemplate, isExtractPayload, isLoggingEnabled, onClose, onCreate, setAdmin, setConnectionFactory, setDefaultDeliveryMode, setExtractPayload, setHeadersMappedLast, setLoggingEnabled
addInterceptor, addInterceptor, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, 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
onShutDown
getManagedName, getManagedType, getThisAs, setManagedName, setManagedType
getBeanName, getComponentName
public PointToPointSubscribableAmqpChannel(StringSE channelName, AbstractMessageListenerContainer container, AmqpTemplate amqpTemplate)
channelName
- チャンネル名。container
- コンテナー。amqpTemplate
- テンプレート。AbstractAmqpChannel.setExtractPayload(boolean)
public PointToPointSubscribableAmqpChannel(StringSE channelName, AbstractMessageListenerContainer container, AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper)
channelName
- チャンネル名。container
- コンテナー。amqpTemplate
- テンプレート。outboundMapper
- 発信マッパー。inboundMapper
- 受信マッパー。AbstractAmqpChannel.setExtractPayload(boolean)
public void setQueueName(StringSE queueName)
queueName
- キュー名。protected AbstractDispatcher createDispatcher()
protected StringSE getRoutingKey()
AbstractAmqpChannel
AbstractAmqpChannel
の getRoutingKey
protected void doDeclares()
AbstractAmqpChannel
の doDeclares
public void setMaxSubscribers(int maxSubscribers)
AbstractDispatcher
の場合)。maxSubscribers
- 許可されるサブスクライバーの最大数。public boolean subscribe(MessageHandler handler)
SubscribableChannel
の subscribe
public boolean unsubscribe(MessageHandler handler)
SubscribableChannel
の unsubscribe
public void onInit()
IntegrationObjectSupport
AbstractAmqpChannel
の onInit
public boolean isAutoStartup()
SmartLifecycle
の isAutoStartup
public int getPhase()
Phased
の getPhase
SmartLifecycle
の getPhase
public boolean isRunning()
Lifecycle
の isRunning
ManageableLifecycle
の isRunning
public void start()
Lifecycle
の start
ManageableLifecycle
の start
public void stop()
Lifecycle
の stop
ManageableLifecycle
の stop
public void stop(RunnableSE callback)
SmartLifecycle
の stop
public void destroy()
DisposableBean
の destroy
IntegrationManagement
の destroy
AbstractAmqpChannel
の destroy