public abstract class AbstractAmqpChannel extends AbstractMessageChannel implements ConnectionListener
AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
interceptors, meters
EXPRESSION_PARSER, logger
INDEFINITE_TIMEOUT
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
修飾子と型 | メソッドと説明 |
---|---|
void | destroy() |
protected abstract void | doDeclares() |
protected boolean | doSend(Message<?> message, long timeout) サブクラスはこのメソッドを実装する必要があります。 |
protected AmqpAdmin | getAdmin() |
protected AmqpTemplate | getAmqpTemplate() |
protected ConnectionFactory | getConnectionFactory() |
protected StringSE | getExchangeName() サブクラスはこのメソッドをオーバーライドして、Exchange 名を返す場合があります。 |
protected AmqpHeaderMapper | getInboundHeaderMapper() |
protected RabbitTemplate | getRabbitTemplate() |
protected StringSE | getRoutingKey() サブクラスは、このメソッドをオーバーライドしてルーティングキーを返す場合があります。 |
protected boolean | isExtractPayload() |
boolean | isLoggingEnabled() ロギングが有効かどうかを返します。 |
void | onClose(Connection connection) |
void | onCreate(Connection connection) |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
protected void | setAdmin(AmqpAdmin admin) |
protected void | setConnectionFactory(ConnectionFactory connectionFactory) |
void | setDefaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode) メッセージに "amqp_deliveryMode" ヘッダーがなく、メッセージプロパティが MessagePropertiesConverter によって設定されていない場合に使用する配信モードを設定します。 |
void | setExtractPayload(boolean extractPayload) true に設定すると、ペイロードが抽出され、ヘッダーがマップされます。それ以外の場合は、メッセージ全体が変換されて送信されます。 |
void | setHeadersMappedLast(boolean headersMappedLast) 送信メッセージのヘッダーをマッピングする場合、メッセージが変換される前にヘッダーをマッピングするか、その後にヘッダーをマッピングするかを決定します。 |
void | setLoggingEnabled(boolean loggingEnabled) ロギングを有効にするかどうか。 |
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
onShutDown
getManagedName, getManagedType, getThisAs, setManagedName, setManagedType
getBeanName, getComponentName
public boolean isLoggingEnabled()
IntegrationManagement
IntegrationManagement
の isLoggingEnabled
AbstractMessageChannel
の isLoggingEnabled
public void setLoggingEnabled(boolean loggingEnabled)
IntegrationManagement
IntegrationManagement
の setLoggingEnabled
AbstractMessageChannel
の setLoggingEnabled
loggingEnabled
- 無効にする dalse。public void setDefaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)
MessagePropertiesConverter
によって設定されていない場合に使用する配信モードを設定します。defaultDeliveryMode
- デフォルトの配信モード。public void setExtractPayload(boolean extractPayload)
extractPayload
- 抽出してマッピングするのは本当です。protected boolean isExtractPayload()
setExtractPayload(boolean)
public void setHeadersMappedLast(boolean headersMappedLast)
SimpleMessageConverter
を使用する場合は、これを true に設定することをお勧めします。コンバーターはコンテンツ型を text/plain
に設定します。これは、AmqpHeaders.CONTENT_TYPE
メッセージヘッダーを設定することで application/json
にオーバーライドできます。extractPayload
が true の場合にのみ適用されます。デフォルト: false。headersMappedLast
- 変換後にヘッダーがマップされる場合は true。protected StringSE getExchangeName()
protected StringSE getRoutingKey()
protected AmqpHeaderMapper getInboundHeaderMapper()
protected AmqpTemplate getAmqpTemplate()
protected RabbitTemplate getRabbitTemplate()
protected final void setAdmin(AmqpAdmin admin)
protected final void setConnectionFactory(ConnectionFactory connectionFactory)
protected AmqpAdmin getAdmin()
protected ConnectionFactory getConnectionFactory()
protected void onInit()
IntegrationObjectSupport
AbstractMessageChannel
の onInit
public void destroy()
DisposableBean
の destroy
IntegrationManagement
の destroy
AbstractMessageChannel
の destroy
protected boolean doSend(Message<?> message, long timeout)
AbstractMessageChannel
AbstractMessageChannel
の doSend
message
- メッセージ。timeout
- タイムアウト。public void onCreate(Connection connection)
ConnectionListener
の onCreate
public void onClose(Connection connection)
ConnectionListener
の onClose
protected abstract void doDeclares()