|
|
|
@ -1,5 +1,5 @@ |
|
|
|
/* |
|
|
|
/* |
|
|
|
* Copyright 2002-2022 the original author or authors. |
|
|
|
* Copyright 2002-2023 the original author or authors. |
|
|
|
* |
|
|
|
* |
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
|
|
* you may not use this file except in compliance with the License. |
|
|
|
* you may not use this file except in compliance with the License. |
|
|
|
@ -272,7 +272,7 @@ public abstract class AbstractStompBrokerRelayIntegrationTests { |
|
|
|
|
|
|
|
|
|
|
|
public void expectBrokerAvailabilityEvent(boolean isBrokerAvailable) throws InterruptedException { |
|
|
|
public void expectBrokerAvailabilityEvent(boolean isBrokerAvailable) throws InterruptedException { |
|
|
|
BrokerAvailabilityEvent event = this.eventQueue.poll(20000, TimeUnit.MILLISECONDS); |
|
|
|
BrokerAvailabilityEvent event = this.eventQueue.poll(20000, TimeUnit.MILLISECONDS); |
|
|
|
assertThat(event).as("Times out waiting for BrokerAvailabilityEvent[" + isBrokerAvailable + "]").isNotNull(); |
|
|
|
assertThat(event).as("Timed out waiting for BrokerAvailabilityEvent[" + isBrokerAvailable + "]").isNotNull(); |
|
|
|
assertThat(event.isBrokerAvailable()).isEqualTo(isBrokerAvailable); |
|
|
|
assertThat(event.isBrokerAvailable()).isEqualTo(isBrokerAvailable); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|