org.springframework.cloud.stream.binder.test.junit.rabbit

Class RabbitTestSupport

java.lang.Object

org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport<org.springframework.amqp.rabbit.connection.CachingConnectionFactory>

org.springframework.cloud.stream.binder.test.junit.rabbit.RabbitTestSupport

All Implemented Interfaces:

org.junit.jupiter.api.extension.BeforeEachCallback, org.junit.jupiter.api.extension.Extension

public class RabbitTestSupport
extends AbstractExternalResourceTestSupport<org.springframework.amqp.rabbit.connection.CachingConnectionFactory>

JUnit Rule that detects the fact that RabbitMQ is available on localhost.

Author:

Mark Fisher, Gary Russell, Eric Bottard

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RabbitTestSupport.RabbitProxy Test class to allow testing deferred entity declarations when RabbitMQ is down.

Field Summary

Fields inherited from class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport

logger, resource, SCS_EXTERNAL_SERVERS_REQUIRED

Constructor Summary

Constructors

Constructor and Description
RabbitTestSupport()
RabbitTestSupport(boolean management)
RabbitTestSupport(boolean management, int amqpPort, int managementPort)

Method Summary

Modifier and Type	Method and Description
protected void	cleanupResource()
protected void	obtainResource()

Methods inherited from class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport

apply, beforeEach, getResource

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RabbitTestSupport

public RabbitTestSupport()

RabbitTestSupport

public RabbitTestSupport(boolean management)

RabbitTestSupport

public RabbitTestSupport(boolean management,
                         int amqpPort,
                         int managementPort)

Method Detail

obtainResource

protected void obtainResource()
                       throws Exception

Specified by:

obtainResource in class AbstractExternalResourceTestSupport<org.springframework.amqp.rabbit.connection.CachingConnectionFactory>

Throws:

Exception

cleanupResource

protected void cleanupResource()
                        throws Exception

Specified by:

cleanupResource in class AbstractExternalResourceTestSupport<org.springframework.amqp.rabbit.connection.CachingConnectionFactory>

Throws:

Exception