クラス RabbitListenerTestHarness
- java.lang.ObjectSE
-
- org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
-
- org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
- 実装されたすべてのインターフェース:
Aware
、BeanClassLoaderAware
、BeanFactoryAware
、BeanPostProcessor
、SmartInitializingSingleton
、EnvironmentAware
、Ordered
public class RabbitListenerTestHarness extends RabbitListenerAnnotationBeanPostProcessor
BeanPostProcessor 拡張RabbitListenerAnnotationBeanPostProcessor
。リスナー Bean を CGLIB プロキシでラップし、引数と結果 (存在する場合) をキャプチャーしてブロッキングキューに入れるようアドバイスします。テストケースは、テストハーネスをテストケースに自動接続することで結果にアクセスできます。- 導入:
- 1.6
- 作成者:
- Gary Russell, Artem Bilan, Miguel Gross Valle
ネストされたクラスのサマリー
ネストされたクラス 修飾子と型 クラス 説明 static class
RabbitListenerTestHarness.InvocationData
フィールドサマリー
クラス org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor から継承されたフィールド
DEFAULT_RABBIT_LISTENER_CONTAINER_FACTORY_BEAN_NAME, RABBIT_EMPTY_STRING_ARGUMENTS_PROPERTY
インターフェース org.springframework.core.Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
コンストラクターのサマリー
コンストラクター コンストラクター 説明 RabbitListenerTestHarness(AnnotationMetadata importMetadata)
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 <T> T
getDelegate(StringSE id)
実際のリスナーオブジェクトを取得します (スパイではありません)。<T> LambdaAnswer<T>
getLambdaAnswerFor(StringSE id, boolean callRealMethod, LambdaAnswer.ValueToReturn<T> callback)
リスナーを呼び出すように適切に構成されたLambdaAnswer
を返します。LatchCountDownAndCallRealMethodAnswer
getLatchAnswerFor(StringSE id, int count)
リスナーを呼び出すように適切に構成されたLatchCountDownAndCallRealMethodAnswer
を返します。RabbitListenerTestHarness.InvocationData
getNextInvocationDataFor(StringSE id, long wait, TimeUnitSE unit)
<T> T
getSpy(StringSE id)
protected CollectionSE<Declarable>
processListener(MethodRabbitListenerEndpoint endpoint, RabbitListener rabbitListener, ObjectSE bean, ObjectSE target, StringSE beanName)
クラス org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor から継承されたメソッド
afterSingletonsInstantiated, assertBeanFactory, getOrder, noBeanFoundMessage, postProcessAfterInitialization, postProcessBeforeInitialization, processAmqpListener, resolveExpressionAsString, setBeanClassLoader, setBeanFactory, setCharset, setContainerFactoryBeanName, setEndpointRegistry, setEnvironment, setMessageHandlerMethodFactory
コンストラクターの詳細
RabbitListenerTestHarness
public RabbitListenerTestHarness(AnnotationMetadata importMetadata)
メソッドの詳細
processListener
protected CollectionSE<Declarable> processListener(MethodRabbitListenerEndpoint endpoint, RabbitListener rabbitListener, ObjectSE bean, ObjectSE target, StringSE beanName)
- オーバーライド:
- クラス
RabbitListenerAnnotationBeanPostProcessor
のprocessListener
getLatchAnswerFor
public LatchCountDownAndCallRealMethodAnswer getLatchAnswerFor(StringSE id, int count)
リスナーを呼び出すように適切に構成されたLatchCountDownAndCallRealMethodAnswer
を返します。- パラメーター:
id
- リスナー ID。count
- カウント。- 戻り値:
- 答え。
- 導入:
- 2.1.16
getLambdaAnswerFor
public <T> LambdaAnswer<T> getLambdaAnswerFor(StringSE id, boolean callRealMethod, LambdaAnswer.ValueToReturn<T> callback)
リスナーを呼び出すように適切に構成されたLambdaAnswer
を返します。- 型パラメーター:
T
- 戻り値の型。- パラメーター:
id
- リスナー ID。callRealMethod
- 実際のメソッドを呼び出す場合は true。callback
- コールバック。- 戻り値:
- 答え。
- 導入:
- 2.1.16
getNextInvocationDataFor
public RabbitListenerTestHarness.InvocationData getNextInvocationDataFor(StringSE id, long wait, TimeUnitSE unit) throws InterruptedExceptionSE
getSpy
public <T> T getSpy(StringSE id)
getDelegate
public <T> T getDelegate(StringSE id)
実際のリスナーオブジェクトを取得します (スパイではありません)。- 型パラメーター:
T
- 型。- パラメーター:
id
- ID。- 戻り値:
- リスナー。
- 導入:
- 2.1.16