BrokerRunning (Spring AMQP 2.1.14.RELEASE API)

java.lang.Object
- org.junit.rules.TestWatcher
- - org.springframework.amqp.rabbit.junit.BrokerRunning

All Implemented Interfaces:

org.junit.rules.TestRule
```
public final class BrokerRunning
extends org.junit.rules.TestWatcher
```
A rule that prevents integration tests from failing if the Rabbit broker application is not running or not accessible. If the Rabbit broker is not running in the background all the tests here will simply be skipped (by default) because of a violated assumption (showing as successful). Usage:
```
 @Rule
 public static BrokerRunning brokerIsRunning = BrokerRunning.isRunning();

 @Test
 public void testSendAndReceive() throws Exception {
        // ... test using RabbitTemplate etc.
 }
 
```
The rule can be declared as static so that it only has to check once for all tests in the enclosing test case, but there isn't a lot of overhead in making it non-static.
Use isRunningWithEmptyQueues(String...) to declare and/or purge test queue(s) when the rule is run.
Call removeTestQueues(String...) from an @After method to remove those queues (and optionally others).
If you wish to enforce the broker being available, for example, on a CI server, set the environment variable "RABBITMQ_SERVER_REQUIRED" to true and the tests will fail fast.
Since:

1.7

Author:

Dave Syer, Gary Russell

See Also:

Assume, AssumptionViolatedException

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`static class`	`BrokerRunning.BrokerNotAliveException` The `RuntimeException` thrown when broker is not available on the provided host port.

Field Summary

Fields
Modifier and Type	Field and Description
`static String`	`BROKER_ADMIN_PW`
`static String`	`BROKER_ADMIN_URI`
`static String`	`BROKER_ADMIN_USER`
`static String`	`BROKER_HOSTNAME`
`static String`	`BROKER_PORT`
`static String`	`BROKER_PW`
`static String`	`BROKER_REQUIRED`
`static String`	`BROKER_USER`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`org.junit.runners.model.Statement`	`apply(org.junit.runners.model.Statement base, org.junit.runner.Description description)`
`static void`	`clearEnvironmentVariableOverrides()` Clear any environment variable overrides set in `setEnvironmentVariableOverrides(Map)`.
`void`	`deleteExchanges(String... exchanges)` Delete arbitrary exchanges from the broker.
`void`	`deleteQueues(String... queues)` Delete arbitrary queues from the broker.
`static boolean`	`fatal()`
`String`	`generateId()` Generate the connection id for the connection used by the rule's connection factory.
`String`	`getAdminPassword()` Return the admin password.
`String`	`getAdminUri()` Return the admin uri.
`String`	`getAdminUser()` Return the admin user.
`com.rabbitmq.client.ConnectionFactory`	`getConnectionFactory()` Get the connection factory used by this rule.
`String`	`getHostName()` Return the port.
`String`	`getPassword()` Return the password.
`int`	`getPort()` Return the port.
`String`	`getUser()` Return the user.
`static BrokerRunning`	`isBrokerAndManagementRunning()`
`static BrokerRunning`	`isBrokerAndManagementRunningWithEmptyQueues(String... queues)`
`static BrokerRunning`	`isNotRunning()`
`static BrokerRunning`	`isRunning()`
`static BrokerRunning`	`isRunningWithEmptyQueues(String... names)` Ensure the broker is running and has a empty queue(s) with the specified name(s) in the default exchange.
`void`	`isUp()`
`void`	`removeTestQueues(String... additionalQueues)` Remove any test queues that were created by an `isRunningWithEmptyQueues(String...)` method.
`void`	`setAdminPassword(String password)` Set the password for the management REST API connection default "guest".
`void`	`setAdminUri(String adminUri)` Set the uri for the REST API.
`void`	`setAdminUser(String user)` Set the user for the management REST API connection default "guest".
`static void`	`setEnvironmentVariableOverrides(Map<String,String> environmentVariables)` Set environment variable overrides for host, port etc.
`void`	`setHostName(String hostName)`
`void`	`setPassword(String password)` Set the password for the amqp connection default "guest".
`void`	`setPort(int port)`
`void`	`setUser(String user)` Set the user for the amqp connection default "guest".

Methods inherited from class org.junit.rules.TestWatcher
failed, finished, skipped, skipped, starting, succeeded

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - BROKER_ADMIN_URI
```
public static final String BROKER_ADMIN_URI
```
    See Also:
    
    Constant Field Values
  - BROKER_HOSTNAME
```
public static final String BROKER_HOSTNAME
```
    See Also:
    
    Constant Field Values
  - BROKER_PORT
```
public static final String BROKER_PORT
```
    See Also:
    
    Constant Field Values
  - BROKER_USER
```
public static final String BROKER_USER
```
    See Also:
    
    Constant Field Values
  - BROKER_PW
```
public static final String BROKER_PW
```
    See Also:
    
    Constant Field Values
  - BROKER_ADMIN_USER
```
public static final String BROKER_ADMIN_USER
```
    See Also:
    
    Constant Field Values
  - BROKER_ADMIN_PW
```
public static final String BROKER_ADMIN_PW
```
    See Also:
    
    Constant Field Values
  - BROKER_REQUIRED
```
public static final String BROKER_REQUIRED
```
    See Also:
    
    Constant Field Values
- Method Detail
  - setEnvironmentVariableOverrides
```
public static void setEnvironmentVariableOverrides(Map<String,String> environmentVariables)
```
    Set environment variable overrides for host, port etc. Will override any real environment variables, if present.
    The variables will only apply to rule instances that are created after this method is called. The overrides will remain until
    
    Parameters:
    
    environmentVariables - the variables.
  - clearEnvironmentVariableOverrides
```
public static void clearEnvironmentVariableOverrides()
```
    Clear any environment variable overrides set in setEnvironmentVariableOverrides(Map).
  - isRunningWithEmptyQueues
```
public static BrokerRunning isRunningWithEmptyQueues(String... names)
```
    Ensure the broker is running and has a empty queue(s) with the specified name(s) in the default exchange.
    
    Parameters:
    
    names - the queues to declare for the test.
    
    Returns:
    
    a new rule that assumes an existing running broker
  - isRunning
```
public static BrokerRunning isRunning()
```
    Returns:
    
    a new rule that assumes an existing running broker
  - isNotRunning
```
public static BrokerRunning isNotRunning()
```
    Returns:
    
    a new rule that assumes there is no existing broker
  - isBrokerAndManagementRunning
```
public static BrokerRunning isBrokerAndManagementRunning()
```
    Returns:
    
    a new rule that assumes an existing broker with the management plugin
  - isBrokerAndManagementRunningWithEmptyQueues
```
public static BrokerRunning isBrokerAndManagementRunningWithEmptyQueues(String... queues)
```
    Parameters:
    
    queues - the queues.
    
    Returns:
    
    a new rule that assumes an existing broker with the management plugin with the provided queues declared (and emptied if needed)..
  - setPort
```
public void setPort(int port)
```
    Parameters:
    
    port - the port to set
  - setHostName
```
public void setHostName(String hostName)
```
    Parameters:
    
    hostName - the hostName to set
  - setUser
```
public void setUser(String user)
```
    Set the user for the amqp connection default "guest".
    
    Parameters:
    
    user - the user.
    
    Since:
    
    1.7.2
  - setPassword
```
public void setPassword(String password)
```
    Set the password for the amqp connection default "guest".
    
    Parameters:
    
    password - the password.
    
    Since:
    
    1.7.2
  - setAdminUri
```
public void setAdminUri(String adminUri)
```
    Set the uri for the REST API.
    
    Parameters:
    
    adminUri - the uri.
    
    Since:
    
    1.7.2
  - setAdminUser
```
public void setAdminUser(String user)
```
    Set the user for the management REST API connection default "guest".
    
    Parameters:
    
    user - the user.
    
    Since:
    
    1.7.2
  - setAdminPassword
```
public void setAdminPassword(String password)
```
    Set the password for the management REST API connection default "guest".
    
    Parameters:
    
    password - the password.
    
    Since:
    
    1.7.2
  - getPort
```
public int getPort()
```
    Return the port.
    
    Returns:
    
    the port.
    
    Since:
    
    1.7.2
  - getHostName
```
public String getHostName()
```
    Return the port.
    
    Returns:
    
    the port.
    
    Since:
    
    1.7.2
  - getUser
```
public String getUser()
```
    Return the user.
    
    Returns:
    
    the user.
    
    Since:
    
    1.7.2
  - getPassword
```
public String getPassword()
```
    Return the password.
    
    Returns:
    
    the password.
    
    Since:
    
    1.7.2
  - getAdminUser
```
public String getAdminUser()
```
    Return the admin user.
    
    Returns:
    
    the user.
    
    Since:
    
    1.7.2
  - getAdminPassword
```
public String getAdminPassword()
```
    Return the admin password.
    
    Returns:
    
    the password.
    
    Since:
    
    1.7.2
  - apply
```
public org.junit.runners.model.Statement apply(org.junit.runners.model.Statement base,
                                               org.junit.runner.Description description)
```
    Specified by:
    
    apply in interface org.junit.rules.TestRule
    
    Overrides:
    
    apply in class org.junit.rules.TestWatcher
  - isUp
```
public void isUp()
          throws IOException,
                 TimeoutException,
                 URISyntaxException
```
    Throws:
    
    IOException
    
    TimeoutException
    
    URISyntaxException
  - fatal
```
public static boolean fatal()
```
  - generateId
```
public String generateId()
```
    Generate the connection id for the connection used by the rule's connection factory.
    
    Returns:
    
    the id.
  - removeTestQueues
```
public void removeTestQueues(String... additionalQueues)
```
    Remove any test queues that were created by an isRunningWithEmptyQueues(String...) method.
    
    Parameters:
    
    additionalQueues - additional queues to remove that might have been created by tests.
  - deleteQueues
```
public void deleteQueues(String... queues)
```
    Delete arbitrary queues from the broker.
    
    Parameters:
    
    queues - the queues to delete.
  - deleteExchanges
```
public void deleteExchanges(String... exchanges)
```
    Delete arbitrary exchanges from the broker.
    
    Parameters:
    
    exchanges - the exchanges to delete.
  - getConnectionFactory
```
public com.rabbitmq.client.ConnectionFactory getConnectionFactory()
```
    Get the connection factory used by this rule.
    
    Returns:
    
    the connection factory.
  - getAdminUri
```
public String getAdminUri()
```
    Return the admin uri.
    
    Returns:
    
    the uri.
    
    Since:
    
    1.7.2

Class BrokerRunning

Nested Class Summary

Field Summary

Method Summary

Methods inherited from class org.junit.rules.TestWatcher

Methods inherited from class java.lang.Object

Field Detail

BROKER_ADMIN_URI

BROKER_HOSTNAME

BROKER_PORT

BROKER_USER

BROKER_PW

BROKER_ADMIN_USER

BROKER_ADMIN_PW

BROKER_REQUIRED

Method Detail

setEnvironmentVariableOverrides

clearEnvironmentVariableOverrides

isRunningWithEmptyQueues

isRunning

isNotRunning

isBrokerAndManagementRunning

isBrokerAndManagementRunningWithEmptyQueues

setPort

setHostName

setUser

setPassword

setAdminUri

setAdminUser

setAdminPassword

getPort

getHostName

getUser

getPassword

getAdminUser

getAdminPassword

apply

isUp

fatal

generateId

removeTestQueues

deleteQueues

deleteExchanges

getConnectionFactory

getAdminUri