パッケージ org.springframework.integration.amqp.config

クラス AmqpChannelFactoryBean

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, Ngoc Nhan

  • コンストラクターの詳細

    • AmqpChannelFactoryBean

      public AmqpChannelFactoryBean()

    • AmqpChannelFactoryBean

      public AmqpChannelFactoryBean(boolean messageDriven)

  • 方法の詳細

    • setBeanName

      public void setBeanName(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(@Nullable AbstractAmqpChannel instance)
      オーバーライド:
      クラス AbstractFactoryBean<AbstractAmqpChannel> の destroyInstance