AmqpChannelFactoryBean (Spring Integration API)

java.lang.ObjectSE
- org.springframework.beans.factory.config.AbstractFactoryBean<AbstractAmqpChannel>
- - org.springframework.integration.amqp.config.AmqpChannelFactoryBean

実装されているすべてのインターフェース:
Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<AbstractAmqpChannel>, InitializingBean, Lifecycle, Phased, SmartLifecycle
```
public class AmqpChannelFactoryBean
extends AbstractFactoryBean<AbstractAmqpChannel>
implements SmartLifecycle, BeanNameAware
```
ポイントツーポイントの場合、"[beanName]" に等しいルーティングキーを使用してデフォルトの交換に送信し、同じキューを宣言し、メッセージ駆動の場合はリスナーを登録するか、そうでない場合は明示的にポーリングします。パブリッシュ / サブスクライブの場合、"si.fanout.[beanName]" という名前の FanoutExchange を宣言し、ルーティングキーなしで送信し、受信側で、その交換にバインドされる匿名キューを作成します。
導入:
2.1
作成者:
Mark Fisher, Gary Russell, Artem Bilan

フィールドのサマリー
- クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたフィールド
  logger
- インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
  DEFAULT_PHASE
- インターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
  OBJECT_TYPE_ATTRIBUTE

コンストラクターの概要
コンストラクター
コンストラクターと説明
AmqpChannelFactoryBean()
AmqpChannelFactoryBean(boolean messageDriven)

コンストラクター
コンストラクターと説明
`AmqpChannelFactoryBean()`
`AmqpChannelFactoryBean(boolean messageDriven)`

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected AbstractAmqpChannel`	`createInstance()`
`protected void`	`destroyInstance(AbstractAmqpChannel instance)`
`ClassSE<?>`	`getObjectType()`
`int`	`getPhase()`
`boolean`	`isAutoStartup()`
`boolean`	`isRunning()`
`void`	`setAcknowledgeMode(AcknowledgeMode acknowledgeMode)`
`void`	`setAdviceChain(Advice[] adviceChain)`
`void`	`setAmqpAdmin(AmqpAdmin amqpAdmin)` これは、PollableAmqpChannel のキューを暗黙的に宣言するときに使用する AmqpAdmin へのオプションの参照です。
`void`	`setAutoStartup(boolean autoStartup)`
`void`	`setBatchSize(IntegerSE batchSize)`
`void`	`setBeanName(StringSE name)`
`void`	`setChannelTransacted(boolean channelTransacted)`
`void`	`setConcurrentConsumers(int concurrentConsumers)`
`void`	`setConnectionFactory(ConnectionFactory connectionFactory)`
`void`	`setConsumersPerQueue(IntegerSE consumersPerQueue)`
`void`	`setDefaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)`
`void`	`setEncoding(StringSE encoding)`
`void`	`setErrorHandler(ErrorHandler errorHandler)`
`void`	`setExchange(FanoutExchange exchange)` 使用する FanoutExchange を設定します。
`void`	`setExposeListenerChannel(boolean exposeListenerChannel)`
`void`	`setExtractPayload(BooleanSE extractPayload)`
`void`	`setHeadersLast(boolean headersLast)`
`void`	`setInboundHeaderMapper(AmqpHeaderMapper inboundMapper)`
`void`	`setInterceptors(ListSE<ChannelInterceptor> interceptors)`
`void`	`setMaxSubscribers(int maxSubscribers)`
`void`	`setMessageConverter(MessageConverter messageConverter)`
`void`	`setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)`
`void`	`setMissingQueuesFatal(BooleanSE missingQueuesFatal)`
`void`	`setOutboundHeaderMapper(AmqpHeaderMapper outboundMapper)`
`void`	`setPhase(int phase)`
`void`	`setPrefetchCount(int prefetchCount)`
`void`	`setPubSub(boolean pubSub)`
`void`	`setQueueName(StringSE queueName)` 使用するキュー名を設定します。
`void`	`setReceiveTimeout(long receiveTimeout)`
`void`	`setRecoveryInterval(long recoveryInterval)`
`void`	`setShutdownTimeout(long shutdownTimeout)`
`void`	`setTaskExecutor(ExecutorSE taskExecutor)`
`void`	`setTemplateChannelTransacted(boolean channelTransacted)`
`void`	`setTransactionAttribute(TransactionAttribute transactionAttribute)`
`void`	`setTransactionManager(PlatformTransactionManager transactionManager)`
`void`	`start()`
`void`	`stop()`
`void`	`stop(RunnableSE callback)`

クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたメソッド
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

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

コンストラクターの詳細

AmqpChannelFactoryBean
```
public AmqpChannelFactoryBean()
```

AmqpChannelFactoryBean

public AmqpChannelFactoryBean(boolean messageDriven)

メソッドの詳細

setBeanName

public void setBeanName(@Nullable
                        StringSE name)

次で指定:: インターフェース BeanNameAware の setBeanName

setInterceptors

public void setInterceptors(ListSE<ChannelInterceptor> interceptors)

setAmqpAdmin
```
public void setAmqpAdmin(AmqpAdmin amqpAdmin)
```
これは、PollableAmqpChannel のキューを暗黙的に宣言するときに使用する AmqpAdmin へのオプションの参照です。メッセージ駆動型（サブスクライブ可能）チャネルでは、基になるリスナーコンテナーの ConnectionFactory を使用して RabbitAdmin インスタンスを作成できるため、これは必要ありません。
パラメーター:
amqpAdmin - amqp 管理者。

setExchange
```
public void setExchange(FanoutExchange exchange)
```
使用する FanoutExchange を設定します。これはパブリッシュ / サブスクライブチャネルにのみ関連し、提供されていない場合でも、FanoutExchange が暗黙的に作成されます。
パラメーター:
exchange - ファンアウト交換。

setQueueName
```
public void setQueueName(StringSE queueName)
```
使用するキュー名を設定します。これはポイントツーポイントチャネルにのみ関連し、提供されていない場合でも、キューは暗黙的に作成されます。
パラメーター:
queueName - キュー名。

setEncoding

public void setEncoding(StringSE encoding)

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

setTemplateChannelTransacted

public void setTemplateChannelTransacted(boolean channelTransacted)

setChannelTransacted

public void setChannelTransacted(boolean channelTransacted)

setConnectionFactory

public void setConnectionFactory(ConnectionFactory connectionFactory)

setMessagePropertiesConverter

public void setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)

setAcknowledgeMode

public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)

setAdviceChain

public void setAdviceChain(Advice[] adviceChain)

setAutoStartup

public void setAutoStartup(boolean autoStartup)

setConcurrentConsumers

public void setConcurrentConsumers(int concurrentConsumers)

setConsumersPerQueue

public void setConsumersPerQueue(IntegerSE consumersPerQueue)

setErrorHandler

public void setErrorHandler(ErrorHandler errorHandler)

setExposeListenerChannel

public void setExposeListenerChannel(boolean exposeListenerChannel)

setPhase
```
public void setPhase(int phase)
```

setPrefetchCount

public void setPrefetchCount(int prefetchCount)

setPubSub

public void setPubSub(boolean pubSub)

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

setRecoveryInterval

public void setRecoveryInterval(long recoveryInterval)

setShutdownTimeout

public void setShutdownTimeout(long shutdownTimeout)

setTaskExecutor

public void setTaskExecutor(ExecutorSE taskExecutor)

setTransactionAttribute

public void setTransactionAttribute(TransactionAttribute transactionAttribute)

setTransactionManager

public void setTransactionManager(PlatformTransactionManager transactionManager)

setBatchSize

public void setBatchSize(IntegerSE batchSize)

setMaxSubscribers

public void setMaxSubscribers(int maxSubscribers)

setMissingQueuesFatal

public void setMissingQueuesFatal(BooleanSE missingQueuesFatal)

setDefaultDeliveryMode

public void setDefaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)

setExtractPayload

public void setExtractPayload(BooleanSE extractPayload)

setOutboundHeaderMapper

public void setOutboundHeaderMapper(AmqpHeaderMapper outboundMapper)

setInboundHeaderMapper

public void setInboundHeaderMapper(AmqpHeaderMapper inboundMapper)

setHeadersLast

public void setHeadersLast(boolean headersLast)

getObjectType
```
public ClassSE<?> getObjectType()
```
次で指定:
インターフェース FactoryBean<AbstractAmqpChannel> の getObjectType
次で指定:
クラス AbstractFactoryBean<AbstractAmqpChannel> の getObjectType

createInstance
```
protected AbstractAmqpChannel createInstance()
```
次で指定:
クラス AbstractFactoryBean<AbstractAmqpChannel> の createInstance

isAutoStartup
```
public boolean isAutoStartup()
```
次で指定:
インターフェース SmartLifecycle の isAutoStartup

getPhase
```
public int getPhase()
```
次で指定:
インターフェース Phased の getPhase
次で指定:
インターフェース SmartLifecycle の getPhase

isRunning
```
public boolean isRunning()
```
次で指定:
インターフェース Lifecycle の isRunning

start
```
public void start()
```
次で指定:
インターフェース Lifecycle の start

stop
```
public void stop()
```
次で指定:
インターフェース Lifecycle の stop

stop
```
public void stop(RunnableSE callback)
```
次で指定:
インターフェース SmartLifecycle の stop

destroyInstance
```
protected void destroyInstance(AbstractAmqpChannel instance)
```
オーバーライド:
クラス AbstractFactoryBean<AbstractAmqpChannel> の destroyInstance

クラス AmqpChannelFactoryBean

フィールドのサマリー

クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたフィールド

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

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

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたメソッド

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

コンストラクターの詳細

AmqpChannelFactoryBean

AmqpChannelFactoryBean

メソッドの詳細

setBeanName

setInterceptors

setAmqpAdmin

setExchange

setQueueName

setEncoding

setMessageConverter

setTemplateChannelTransacted

setChannelTransacted

setConnectionFactory

setMessagePropertiesConverter

setAcknowledgeMode

setAdviceChain

setAutoStartup

setConcurrentConsumers

setConsumersPerQueue

setErrorHandler

setExposeListenerChannel

setPhase

setPrefetchCount

setPubSub

setReceiveTimeout

setRecoveryInterval

setShutdownTimeout

setTaskExecutor

setTransactionAttribute

setTransactionManager

setBatchSize

setMaxSubscribers

setMissingQueuesFatal

setDefaultDeliveryMode

setExtractPayload

setOutboundHeaderMapper

setInboundHeaderMapper

setHeadersLast

getObjectType

createInstance

isAutoStartup

getPhase

isRunning

start

stop

stop

destroyInstance