AmqpMessageSource (Spring Integration API)

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
```
public class AmqpMessageSource
extends AbstractMessageSource<ObjectSE>
```
RabbitMQ のポーリング可能な MessageSource。
導入:
5.0.1
作成者:
Gary Russell

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

ネストされたクラス
修飾子と型	クラスと説明
`static class`	`AmqpMessageSource.AmqpAckCallback`
`static class`	`AmqpMessageSource.AmqpAckCallbackFactory`
`static class`	`AmqpMessageSource.AmqpAckInfo` AmqpAckCallback を構築するための情報。

インターフェース 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, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, StringSE queue)`
`AmqpMessageSource(ConnectionFactory connectionFactory, StringSE queue)`

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected AbstractIntegrationMessageBuilder<ObjectSE>`	`doReceive()` サブクラスはこのメソッドを実装する必要があります。
`protected BatchingStrategy`	`getBatchingStrategy()`
`StringSE`	`getComponentType()`
`protected AmqpHeaderMapper`	`getHeaderMapper()`
`protected MessageConverter`	`getMessageConverter()`
`protected MessagePropertiesConverter`	`getPropertiesConverter()`
`protected boolean`	`isRawMessageHeader()`
`protected boolean`	`isTransacted()`
`void`	`setBatchingStrategy(BatchingStrategy batchingStrategy)` メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。
`void`	`setHeaderMapper(AmqpHeaderMapper headerMapper)` カスタム `AmqpHeaderMapper` を設定して、デフォルトの `DefaultAmqpHeaderMapper.inboundMapper()` を置き換えます。
`void`	`setMessageConverter(MessageConverter messageConverter)` カスタム `MessageConverter` を設定して、デフォルトの `SimpleMessageConverter` を置き換えます。
`void`	`setPropertiesConverter(MessagePropertiesConverter propertiesConverter)` カスタム `MessagePropertiesConverter` を設定して、デフォルトの `DefaultMessagePropertiesConverter` を置き換えます。
`void`	`setRawMessageHeader(boolean rawMessageHeader)` true に設定すると、生の spring-amqp メッセージがキー `AmqpMessageHeaderErrorMessageStrategy.AMQP_RAW_MESSAGE` のヘッダーとして含まれ、呼び出し元がメッセージにアクセスしてエラーを処理できるようになります。
`void`	`setTransacted(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

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE

インターフェース org.springframework.integration.core.MessageSource から継承されたメソッド
getIntegrationPatternType

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

- コンストラクターの詳細
  - AmqpMessageSource
```
public AmqpMessageSource(ConnectionFactory connectionFactory,
                         StringSE queue)
```
  - 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
```
protected MessagePropertiesConverter getPropertiesConverter()
```
  - setPropertiesConverter
```
public void setPropertiesConverter(MessagePropertiesConverter propertiesConverter)
```
    カスタム MessagePropertiesConverter を設定して、デフォルトの DefaultMessagePropertiesConverter を置き換えます。
    パラメーター:
    propertiesConverter - コンバーター。
  - getHeaderMapper
```
protected AmqpHeaderMapper getHeaderMapper()
```
  - setHeaderMapper
```
public void setHeaderMapper(AmqpHeaderMapper headerMapper)
```
    カスタム AmqpHeaderMapper を設定して、デフォルトの DefaultAmqpHeaderMapper.inboundMapper() を置き換えます。
    パラメーター:
    headerMapper - ヘッダーマッパー。
  - getMessageConverter
```
protected MessageConverter getMessageConverter()
```
  - setMessageConverter
```
public void setMessageConverter(MessageConverter messageConverter)
```
    カスタム 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
```
protected BatchingStrategy getBatchingStrategy()
```
  - setBatchingStrategy
```
public void setBatchingStrategy(BatchingStrategy batchingStrategy)
```
    メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。デフォルトは SimpleBatchingStrategy です。
    パラメーター:
    batchingStrategy - 戦略。
    導入:
    5.2
  - getComponentType
```
public StringSE getComponentType()
```
  - doReceive
```
protected AbstractIntegrationMessageBuilder<ObjectSE> doReceive()
```
    クラスからコピーされた説明: AbstractMessageSource
    サブクラスはこのメソッドを実装する必要があります。通常、戻り値は T 型の payload ですが、戻り値はペイロードが T 型の Message インスタンスでもかまいません。追加のヘッダーの作成に使用される AbstractIntegrationMessageBuilder にすることもできます。
    次で指定:
    クラス AbstractMessageSource<ObjectSE> の doReceive
    戻り値:
    返された値。

クラス AmqpMessageSource

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

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

フィールドのサマリー

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

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

コンストラクターの概要

メソッドのサマリー

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

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

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

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

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

コンストラクターの詳細

AmqpMessageSource

AmqpMessageSource

メソッドの詳細

isTransacted

setTransacted

getPropertiesConverter

setPropertiesConverter

getHeaderMapper

setHeaderMapper

getMessageConverter

setMessageConverter

isRawMessageHeader

setRawMessageHeader

getBatchingStrategy

setBatchingStrategy

getComponentType

doReceive