public final class BrokerRunning
extends org.junit.rules.TestWatcher
@Rule
public static BrokerRunning brokerIsRunning = BrokerRunning.isRunning();
@Test
public void testSendAndReceive() throws Exception {
// ... test using RabbitTemplate etc.
}
ルールを静的として宣言すると、囲んでいるテストケース内のすべてのテストを 1 回だけチェックするだけで済みますが、非静的にすることによるオーバーヘッドはあまりありません。isRunningWithEmptyQueues(String...) を使用して、ルールの実行時にテストキューを宣言および / またはパージします。
@After メソッドから removeTestQueues(String...) を呼び出して、これらのキュー (およびオプションで他のキュー) を削除します。
CI サーバーなどでブローカーを強制的に使用可能にしたい場合は、環境変数を true に設定すると、テストはすぐに失敗します。
Assume, AssumptionViolatedException| 修飾子と型 | メソッドと説明 |
|---|---|
org.junit.runners.model.Statement | apply(org.junit.runners.model.Statement base, org.junit.runner.Description description) |
static void | clearEnvironmentVariableOverrides()setEnvironmentVariableOverrides(Map) で設定された環境変数オーバーライドをすべてクリアします。 |
void | deleteExchanges(StringSE... exchanges) ブローカーから任意の取引所を削除します。 |
void | deleteQueues(StringSE... queuesToDelete) ブローカーから任意のキューを削除します。 |
static boolean | fatal() |
StringSE | generateId() ルールの接続ファクトリで使用される接続の接続 ID を生成します。 |
StringSE | getAdminPassword() 管理者パスワードを返します。 |
StringSE | getAdminUri() 管理 uri を返します。 |
StringSE | getAdminUser() 管理者ユーザーを返します。 |
com.rabbitmq.client.ConnectionFactory | getConnectionFactory() このルールで使用される接続ファクトリを取得します。 |
StringSE | getHostName() ポートを返します。 |
StringSE | getPassword() パスワードを返します。 |
int | getPort() ポートを返します。 |
StringSE | getUser() ユーザーを返します。 |
static BrokerRunning | isBrokerAndManagementRunning() |
static BrokerRunning | isBrokerAndManagementRunningWithEmptyQueues(StringSE... queues) |
static BrokerRunning | isNotRunning() |
static BrokerRunning | isRunning() |
static BrokerRunning | isRunningWithEmptyQueues(StringSE... names) ブローカーが実行中であり、デフォルト交換に指定された名前の空のキューがあることを確認してください。 |
void | isUp() |
void | purgeTestQueues() 構成されたすべてのキューを削除して再宣言します。 |
void | removeTestQueues(StringSE... additionalQueues)isRunningWithEmptyQueues(String...) メソッドによって作成されたテストキューをすべて削除します。 |
void | setAdminPassword(StringSE password) 管理 REST API 接続のデフォルトの「ゲスト」のパスワードを設定します。 |
void | setAdminUri(StringSE adminUri)REST API の uri を設定します。 |
void | setAdminUser(StringSE user) 管理 REST API 接続のデフォルトの「ゲスト」のユーザーを設定します。 |
static void | setEnvironmentVariableOverrides(MapSE<StringSE, StringSE> environmentVariables) ホスト、ポートなどの環境変数のオーバーライドを設定します。 |
void | setHostName(StringSE hostName) |
void | setPassword(StringSE password)amqp 接続のデフォルト "guest" のパスワードを設定します。 |
void | setPort(int port) |
void | setUser(StringSE user)amqp 接続のデフォルト「ゲスト」のユーザーを設定します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic static void setEnvironmentVariableOverrides(MapSE<StringSE,StringSE> environmentVariables)
変数は、このメソッドが呼び出された後に作成されたルールインスタンスにのみ適用されます。オーバーライドは、clearEnvironmentVariableOverrides() が呼び出されるまで残ります。
environmentVariables - 変数。public static void clearEnvironmentVariableOverrides()
setEnvironmentVariableOverrides(Map) で設定された環境変数オーバーライドをすべてクリアします。public static BrokerRunning isRunningWithEmptyQueues(StringSE... names)
names - テストのために宣言するキュー。public static BrokerRunning isRunning()
public static BrokerRunning isNotRunning()
public static BrokerRunning isBrokerAndManagementRunning()
public static BrokerRunning isBrokerAndManagementRunningWithEmptyQueues(StringSE... queues)
queues - キュー。public void setPort(int port)
port - 設定するポート public void setHostName(StringSE hostName)
hostName - 設定する hostNamepublic void setUser(StringSE user)
user - ユーザー。public void setPassword(StringSE password)
password - パスワード。public void setAdminUri(StringSE adminUri)
adminUri - uri。public void setAdminUser(StringSE user)
user - ユーザー。public void setAdminPassword(StringSE password)
password - パスワード。public int getPort()
public StringSE getHostName()
public StringSE getUser()
public StringSE getPassword()
public StringSE getAdminUser()
public StringSE getAdminPassword()
public org.junit.runners.model.Statement apply(org.junit.runners.model.Statement base,
org.junit.runner.Description description)org.junit.rules.TestRule 内の apply org.junit.rules.TestWatcher の apply public void isUp()
public static boolean fatal()
public StringSE generateId()
public void removeTestQueues(StringSE... additionalQueues)
isRunningWithEmptyQueues(String...) メソッドによって作成されたテストキューをすべて削除します。additionalQueues - テストによって作成された可能性のある削除する追加のキュー。public void purgeTestQueues()
public void deleteQueues(StringSE... queuesToDelete)
queuesToDelete - 削除するキュー。public void deleteExchanges(StringSE... exchanges)
exchanges - 削除する取引所。public com.rabbitmq.client.ConnectionFactory getConnectionFactory()
public StringSE getAdminUri()