クラス BatchingRabbitTemplate
- java.lang.ObjectSE
-
- org.springframework.amqp.rabbit.connection.RabbitAccessor
-
- org.springframework.amqp.rabbit.core.RabbitTemplate
-
- org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
- 実装されたすべてのインターフェース:
AmqpTemplate、MessageListener、PublisherCallbackChannel.Listener、RabbitOperations、ChannelAwareMessageListener、ListenerContainerAware、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、Lifecycle
public class BatchingRabbitTemplate extends RabbitTemplate
個々のメッセージをより大きなメッセージにまとめることを許可するRabbitTemplate。すべてのsend()メソッド (send(String, String, org.springframework.amqp.core.Message, org.springframework.amqp.rabbit.connection.CorrelationData)を除く) がバッチ処理に適しています。実験用 - API は変更される場合があります。
- 導入:
- 1.4.1
- 作成者:
- Gary Russell
ネストされたクラスのサマリー
クラス org.springframework.amqp.rabbit.core.RabbitTemplate から継承されたネストクラス / インターフェース
RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback, RabbitTemplate.ReturnsCallback, RabbitTemplate.TemplateConsumer
インターフェース org.springframework.amqp.rabbit.core.RabbitOperations から継承されたネストクラス / インターフェース
RabbitOperations.OperationsCallback<T>
フィールドサマリー
クラス org.springframework.amqp.rabbit.connection.RabbitAccessor から継承されたフィールド
logger
コンストラクターのサマリー
コンストラクター コンストラクター 説明 BatchingRabbitTemplate(BatchingStrategy batchingStrategy, TaskScheduler scheduler)指定されたパラメーターを使用してインスタンスを作成します。BatchingRabbitTemplate(ConnectionFactory connectionFactory, BatchingStrategy batchingStrategy, TaskScheduler scheduler)指定されたパラメーターを使用してインスタンスを作成します。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 voiddoStart()追加の開始アクションを実行します。voiddoStop()追加の停止アクションを実行します。voidflush()部分的に進行中のバッチをフラッシュします。booleanisRunning()voidsend(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData)特定のルーティングキーを使用して、特定の交換にメッセージを送信します。クラス org.springframework.amqp.rabbit.core.RabbitTemplate から継承されたメソッド
addAfterReceivePostProcessors, addBeforePublishPostProcessors, addListener, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertMessageIfNecessary, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveRaw, correlationConvertAndSend, destroy, determineConfirmsReturnsCapability, doReceiveNoWait, doSend, doSendAndReceive, doSendAndReceiveWithFixed, doSendAndReceiveWithTemporary, execute, expectedQueueNames, getAfterReceivePostProcessors, getDefaultReceiveQueue, getEncoding, getExchange, getMessageConverter, getMessagePropertiesConverter, getRoutingKey, getUnconfirmed, getUnconfirmedCount, getUUID, handleConfirm, handleReturn, handleReturn, initDefaultStrategies, invoke, isChannelLocallyTransacted, isConfirmListener, isMandatoryFor, isReturnListener, isUsePublisherConnection, nullSafeExchange, nullSafeRoutingKey, onMessage, onMessage, receive, receive, receive, receive, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, removeAfterReceivePostProcessor, removeBeforePublishPostProcessor, replyTimedOut, revoke, send, send, send, send, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendToRabbit, setAfterReceivePostProcessors, setBeanFactory, setBeanName, setBeforePublishPostProcessors, setConfirmCallback, setConnectionFactory, setCorrelationDataPostProcessor, setCorrelationKey, setDefaultReceiveQueue, setEncoding, setExchange, setMandatory, setMandatoryExpression, setMandatoryExpressionString, setMessageConverter, setMessagePropertiesConverter, setNoLocalReplyConsumer, setReceiveConnectionFactorySelectorExpression, setReceiveTimeout, setRecoveryCallback, setReplyAddress, setReplyErrorHandler, setReplyTimeout, setRetryTemplate, setReturnCallback, setReturnsCallback, setRoutingKey, setSendConnectionFactorySelectorExpression, setTaskExecutor, setUseChannelForCorrelation, setUseDirectReplyToContainer, setUsePublisherConnection, setUserCorrelationId, setUserIdExpression, setUserIdExpressionString, setUseTemporaryReplyQueues, start, stop, useDirectReplyTo, waitForConfirms, waitForConfirmsOrDie
クラス org.springframework.amqp.rabbit.connection.RabbitAccessor から継承されたメソッド
afterPropertiesSet, convertRabbitAccessException, createConnection, getChannel, getConnection, getConnectionFactory, getTransactionalResourceHolder, isChannelTransacted, setChannelTransacted
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener から継承されたメソッド
onMessageBatch
インターフェース org.springframework.amqp.core.MessageListener から継承されたメソッド
containerAckMode, isAsyncReplies, onMessageBatch
インターフェース org.springframework.amqp.rabbit.core.RabbitOperations から継承されたメソッド
convertSendAndReceiveAsType, getConnectionFactory, invoke
コンストラクターの詳細
BatchingRabbitTemplate
public BatchingRabbitTemplate(BatchingStrategy batchingStrategy, TaskScheduler scheduler)
指定されたパラメーターを使用してインスタンスを作成します。- パラメーター:
batchingStrategy- バッチ戦略。scheduler- スケジューラー。
BatchingRabbitTemplate
public BatchingRabbitTemplate(ConnectionFactory connectionFactory, BatchingStrategy batchingStrategy, TaskScheduler scheduler)
指定されたパラメーターを使用してインスタンスを作成します。- パラメーター:
connectionFactory- 接続ファクトリ。batchingStrategy- バッチ戦略。scheduler- スケジューラー。- 導入:
- 2.2
メソッドの詳細
send
public void send(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) throws AmqpException
インターフェースからコピーされた説明:RabbitOperations特定のルーティングキーを使用して、特定の交換にメッセージを送信します。- 次で指定:
- インターフェース
RabbitOperationsのsend - オーバーライド:
- クラス
RabbitTemplateのsend - パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージcorrelationData- パブリッシャーの確認を関連付けるためのデータ。- 例外:
AmqpException- 問題がある場合
flush
public void flush()
部分的に進行中のバッチをフラッシュします。
doStart
public void doStart()
クラスからコピーされた説明:RabbitTemplate追加の開始アクションを実行します。- オーバーライド:
- クラス
RabbitTemplateのdoStart
doStop
public void doStop()
クラスからコピーされた説明:RabbitTemplate追加の停止アクションを実行します。- オーバーライド:
- クラス
RabbitTemplateのdoStop
isRunning
public boolean isRunning()
- 次で指定:
- インターフェース
LifecycleのisRunning - 次で指定:
- インターフェース
RabbitOperationsのisRunning - オーバーライド:
- クラス
RabbitTemplateのisRunning