org.springframework.integration.amqp.channel.PollableAmqpChannel

実装されたすべてのインターフェース:: ConnectionListener、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、ExecutorChannelInterceptorAware、ComponentSourceAware、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、MessageChannel、PollableChannel、InterceptableChannel

public class PollableAmqpChannel extends AbstractAmqpChannel implements PollableChannel, ExecutorChannelInterceptorAware

AMQP キューに支えられた PollableChannel 実装。メッセージは、ルーティングキーとしてそのキューの名前を使用して、デフォルト（名前なし）の交換に送信されます。

導入:: 2.1
作成者:: Mark Fisher, Artem Bilan, Gary Russell, Ngoc Nhan

ネストされたクラスのサマリー
クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたネストクラス / インターフェース
AbstractMessageChannel.ChannelInterceptorList
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドのサマリー
クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたフィールド
interceptors, meters
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
インターフェース org.springframework.messaging.MessageChannel から継承されたフィールド
INDEFINITE_TIMEOUT
コンストラクターの概要
コンストラクター
コンストラクター
説明
PollableAmqpChannel(StringSE channelName, AmqpTemplate amqpTemplate)
テンプレートが RabbitTemplate であり、メッセージがマップされている場合に使用される、指定された名前、テンプレート、デフォルトのヘッダーマッパーを使用してインスタンスを構築します。
PollableAmqpChannel(StringSE channelName, AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper)
指定された名前、テンプレート、ヘッダーマッパーを使用してインスタンスを構築します。
メソッドのサマリー
修飾子と型
メソッド
説明
void
addInterceptor(int index, ChannelInterceptor interceptor)
リストの指定されたインデックスにチャネルインターセプターを追加します。
void
addInterceptor(ChannelInterceptor interceptor)
リストの最後にチャネルインターセプターを追加します。
protected void
doDeclares()
protected Message<?>
doReceive(LongSE timeout)
protected StringSE
getRoutingKey()
サブクラスは、このメソッドをオーバーライドしてルーティングキーを返す場合があります。
boolean
hasExecutorInterceptors()
protected void
onInit()
サブクラスは、初期化ロジック用にこれを実装できます。
protected ObjectSE
performReceive(LongSE timeout)
Message<?>
receive()
Message<?>
receive(long timeout)
ChannelInterceptor
removeInterceptor(int index)
boolean
removeInterceptor(ChannelInterceptor interceptor)
void
setAmqpAdmin(AmqpAdmin amqpAdmin)
queueName が提供されていない場合は、キューを暗黙的に宣言するための AmqpAdmin のインスタンスを提供します。
void
setInterceptors(ListSE<ChannelInterceptor> interceptors)
チャネルインターセプターのリストを設定します。
void
setQueueName(StringSE queueName)
明示的に構成されたキュー名を指定します。
クラス org.springframework.integration.amqp.channel.AbstractAmqpChannel から継承されたメソッド
destroy, doSend, getAdmin, getAmqpTemplate, getConnectionFactory, getExchangeName, getInboundHeaderMapper, getRabbitTemplate, isExtractPayload, isLoggingEnabled, onCreate, setAdmin, setConnectionFactory, setDefaultDeliveryMode, setExtractPayload, setHeadersMappedLast, setLoggingEnabled
クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたメソッド
getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isObserved, registerMetricsCaptor, registerObservationRegistry, send, send, setDatatypes, setMessageConverter, setObservationConvention, setShouldTrack
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース org.springframework.amqp.rabbit.connection.ConnectionListener から継承されたメソッド
onClose, onFailed, onShutDown
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getManagedName, getManagedType, getThisAs, setManagedName, setManagedType
インターフェース org.springframework.messaging.support.InterceptableChannel から継承されたメソッド
getInterceptors
インターフェース org.springframework.messaging.MessageChannel から継承されたメソッド
send, send
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName

コンストラクターの詳細
- PollableAmqpChannel
  public PollableAmqpChannel(StringSE channelName, AmqpTemplate amqpTemplate)
  テンプレートが RabbitTemplate であり、メッセージがマップされている場合に使用される、指定された名前、テンプレート、デフォルトのヘッダーマッパーを使用してインスタンスを構築します。
  パラメーター:
  channelName - チャンネル名。
  amqpTemplate - テンプレート。
  関連事項:
  AbstractAmqpChannel.setExtractPayload(boolean)
- PollableAmqpChannel
  public PollableAmqpChannel(StringSE channelName, AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper)
  指定された名前、テンプレート、ヘッダーマッパーを使用してインスタンスを構築します。
  パラメーター:
  channelName - チャンネル名。
  amqpTemplate - テンプレート。
  outboundMapper - 発信マッパー。
  inboundMapper - 受信マッパー。
  導入:
  4.3
  関連事項:
  AbstractAmqpChannel.setExtractPayload(boolean)
メソッドの詳細
- setQueueName
  public void setQueueName(StringSE queueName)
  明示的に構成されたキュー名を指定します。これが指定されていない場合は、キューは channelName を名前として暗黙的に作成されます。暗黙的な作成には、AmqpAdmin インスタンスが提供されているか、構成された AmqpTemplate が RabbitTemplate のインスタンスである必要があります。
  パラメーター:
  queueName - キュー名。
- setAmqpAdmin
  public void setAmqpAdmin(AmqpAdmin amqpAdmin)
  queueName が提供されていない場合は、キューを暗黙的に宣言するために AmqpAdmin のインスタンスを提供します。RabbitTemplate 実装を提供する場合、テンプレートの ConnectionFactory 参照から RabbitAdmin インスタンスを作成できるため、これは厳密には必要ありません。
  パラメーター:
  amqpAdmin - amqp 管理者。
- getRoutingKey
  protected StringSE getRoutingKey()
  クラスからコピーされた説明: AbstractAmqpChannel
  サブクラスは、このメソッドをオーバーライドしてルーティングキーを返す場合があります。デフォルトでは、ルーティングキー（空の文字列）はありません。
  オーバーライド:
  クラス AbstractAmqpChannel の getRoutingKey
  戻り値:
  ルーティングキー。
- onInit
  protected void onInit()
  クラスからコピーされた説明: IntegrationObjectSupport
  サブクラスは、初期化ロジック用にこれを実装できます。
  オーバーライド:
  クラス AbstractAmqpChannel の onInit
- doDeclares
  protected void doDeclares()
  次で指定:
  クラス AbstractAmqpChannel の doDeclares
- receive
  @Nullable public Message<?> receive()
  次で指定:
  インターフェース PollableChannel の receive
- receive
  @Nullable public Message<?> receive(long timeout)
  次で指定:
  インターフェース PollableChannel の receive
- doReceive
  @Nullable protected Message<?> doReceive(LongSE timeout)
- performReceive
  @Nullable protected ObjectSE performReceive(LongSE timeout)
- setInterceptors
  public void setInterceptors(ListSE<ChannelInterceptor> interceptors)
  クラスからコピーされた説明: AbstractMessageChannel
  チャネルインターセプターのリストを設定します。これにより、既存のインターセプターがすべてクリアされます。
  次で指定:
  インターフェース InterceptableChannel の setInterceptors
  オーバーライド:
  クラス AbstractMessageChannel の setInterceptors
  パラメーター:
  interceptors - インターセプターのリスト。
- addInterceptor
  public void addInterceptor(ChannelInterceptor interceptor)
  クラスからコピーされた説明: AbstractMessageChannel
  リストの最後にチャネルインターセプターを追加します。
  次で指定:
  インターフェース InterceptableChannel の addInterceptor
  オーバーライド:
  クラス AbstractMessageChannel の addInterceptor
  パラメーター:
  interceptor - インターセプター。
- addInterceptor
  public void addInterceptor(int index, ChannelInterceptor interceptor)
  クラスからコピーされた説明: AbstractMessageChannel
  リストの指定されたインデックスにチャネルインターセプターを追加します。
  次で指定:
  インターフェース InterceptableChannel の addInterceptor
  オーバーライド:
  クラス AbstractMessageChannel の addInterceptor
  パラメーター:
  index - インターセプターを追加するためのインデックス。
  interceptor - インターセプター。
- removeInterceptor
  public boolean removeInterceptor(ChannelInterceptor interceptor)
  次で指定:
  インターフェース InterceptableChannel の removeInterceptor
  オーバーライド:
  クラス AbstractMessageChannel の removeInterceptor
- removeInterceptor
  @Nullable public ChannelInterceptor removeInterceptor(int index)
  次で指定:
  インターフェース InterceptableChannel の removeInterceptor
  オーバーライド:
  クラス AbstractMessageChannel の removeInterceptor
- hasExecutorInterceptors
  public boolean hasExecutorInterceptors()
  次で指定:
  インターフェース ExecutorChannelInterceptorAware の hasExecutorInterceptors

クラス PollableAmqpChannel

ネストされたクラスのサマリー

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたネストクラス / インターフェース

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

インターフェース org.springframework.messaging.MessageChannel から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.amqp.channel.AbstractAmqpChannel から継承されたメソッド

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.amqp.rabbit.connection.ConnectionListener から継承されたメソッド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド

インターフェース org.springframework.messaging.support.InterceptableChannel から継承されたメソッド

インターフェース org.springframework.messaging.MessageChannel から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

コンストラクターの詳細

PollableAmqpChannel

PollableAmqpChannel

メソッドの詳細

setQueueName

setAmqpAdmin

getRoutingKey

onInit

doDeclares

receive

receive

doReceive

performReceive

setInterceptors

addInterceptor

addInterceptor

removeInterceptor

removeInterceptor

hasExecutorInterceptors