クラス AmqpMessageSource
java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<ObjectSE>
org.springframework.integration.amqp.inbound.AmqpMessageSource
- 実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、MessageSource<ObjectSE>、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement
RabbitMQ のポーリング可能な
MessageSource。- 導入:
- 5.0.1
- 作成者:
- Gary Russell
ネストされたクラスのサマリー
ネストされたクラス修飾子と型クラス説明static classstatic classstatic classAmqpAckCallback を構築するための情報。インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールドのサマリー
クラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEコンストラクターの概要
コンストラクターコンストラクター説明AmqpMessageSource(ConnectionFactory connectionFactory, StringSE queue) AmqpMessageSource(ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, StringSE queue) メソッドのサマリー
修飾子と型メソッド説明protected AbstractIntegrationMessageBuilder<ObjectSE> サブクラスはこのメソッドを実装する必要があります。protected BatchingStrategyprotected AmqpHeaderMapperprotected MessageConverterprotected MessagePropertiesConverterprotected booleanprotected booleanvoidsetBatchingStrategy(BatchingStrategy batchingStrategy) メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。voidsetHeaderMapper(AmqpHeaderMapper headerMapper) カスタムAmqpHeaderMapperを設定して、デフォルトのDefaultAmqpHeaderMapper.inboundMapper()を置き換えます。voidsetMessageConverter(MessageConverter messageConverter) カスタムMessageConverterを設定して、デフォルトのSimpleMessageConverterを置き換えます。voidsetPropertiesConverter(MessagePropertiesConverter propertiesConverter) カスタムMessagePropertiesConverterを設定して、デフォルトのDefaultMessagePropertiesConverterを置き換えます。voidsetRawMessageHeader(boolean rawMessageHeader) true に設定すると、生の spring-amqp メッセージがキーAmqpMessageHeaderErrorMessageStrategy.AMQP_RAW_MESSAGEのヘッダーとして含まれ、呼び出し元がメッセージにアクセスしてエラーを処理できるようになります。voidsetTransacted(boolean transacted) ACK にトランザクションチャネルを使用するには、true に設定します。クラス org.springframework.integration.endpoint.AbstractMessageSource から継承されたメソッド
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeクラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたメソッド
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService, setSimpleEvaluationContextクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs, isObserved, registerObservationRegistryインターフェース org.springframework.integration.core.MessageSource から継承されたメソッド
getIntegrationPatternType
コンストラクターの詳細
AmqpMessageSource
AmqpMessageSource
public AmqpMessageSource(ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, StringSE queue)
メソッドの詳細
isTransacted
protected boolean isTransacted()setTransacted
public void setTransacted(boolean transacted) ACK にトランザクションチャネルを使用するには、true に設定します。- パラメーター:
transacted- 取引された場合は true。
getPropertiesConverter
setPropertiesConverter
カスタムMessagePropertiesConverterを設定して、デフォルトのDefaultMessagePropertiesConverterを置き換えます。- パラメーター:
propertiesConverter- コンバーター。
getHeaderMapper
setHeaderMapper
カスタムAmqpHeaderMapperを設定して、デフォルトのDefaultAmqpHeaderMapper.inboundMapper()を置き換えます。- パラメーター:
headerMapper- ヘッダーマッパー。
getMessageConverter
setMessageConverter
カスタムMessageConverterを設定して、デフォルトのSimpleMessageConverterを置き換えます。- パラメーター:
messageConverter- コンバーター。
isRawMessageHeader
protected boolean isRawMessageHeader()setRawMessageHeader
public void setRawMessageHeader(boolean rawMessageHeader) true に設定すると、生の spring-amqp メッセージがキーAmqpMessageHeaderErrorMessageStrategy.AMQP_RAW_MESSAGEのヘッダーとして含まれ、呼び出し元がメッセージにアクセスしてエラーを処理できるようになります。生のメッセージも共通ヘッダーIntegrationMessageHeaderAccessor.SOURCE_DATAに追加されます。- パラメーター:
rawMessageHeader- ヘッダーを含める場合は true。
getBatchingStrategy
setBatchingStrategy
メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。デフォルトはSimpleBatchingStrategyです。- パラメーター:
batchingStrategy- 戦略。- 導入:
- 5.2
getComponentType
doReceive
クラスからコピーされた説明:AbstractMessageSourceサブクラスはこのメソッドを実装する必要があります。通常、戻り値は T 型のpayloadですが、戻り値はペイロードが T 型のMessageインスタンスでもかまいません。追加のヘッダーの作成に使用されるAbstractIntegrationMessageBuilderにすることもできます。- 次で指定:
- クラス
AbstractMessageSource<ObjectSE>のdoReceive - 戻り値:
- 返された値。