Browse Source

Polishing

pull/26673/head
Juergen Hoeller 5 years ago
parent
commit
7b6cac2c93
  1. 7
      spring-jms/src/main/java/org/springframework/jms/listener/DefaultMessageListenerContainer.java
  2. 6
      spring-jms/src/test/java/org/springframework/jms/config/JmsNamespaceHandlerTests.java
  3. 5
      spring-jms/src/test/java/org/springframework/jms/listener/SimpleMessageListenerContainerTests.java
  4. 6
      spring-messaging/src/test/java/org/springframework/messaging/simp/stomp/ReactorNettyTcpStompClientTests.java
  5. 10
      spring-messaging/src/test/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandlerIntegrationTests.java

7
spring-jms/src/main/java/org/springframework/jms/listener/DefaultMessageListenerContainer.java

@ -1008,11 +1008,8 @@ public class DefaultMessageListenerContainer extends AbstractPollingMessageListe @@ -1008,11 +1008,8 @@ public class DefaultMessageListenerContainer extends AbstractPollingMessageListe
}
}
if (!applyBackOffTime(execution)) {
StringBuilder msg = new StringBuilder();
msg.append("Stopping container for destination '")
.append(getDestinationDescription())
.append("': back-off policy does not allow ").append("for further attempts.");
logger.error(msg.toString());
logger.error("Stopping container for destination '" + getDestinationDescription() +
"': back-off policy does not allow for further attempts.");
stop();
}
}

6
spring-jms/src/test/java/org/springframework/jms/config/JmsNamespaceHandlerTests.java

@ -1,5 +1,5 @@ @@ -1,5 +1,5 @@
/*
* Copyright 2002-2020 the original author or authors.
* Copyright 2002-2021 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -69,12 +69,12 @@ public class JmsNamespaceHandlerTests { @@ -69,12 +69,12 @@ public class JmsNamespaceHandlerTests {
@BeforeEach
public void setUp() throws Exception {
public void setup() {
this.context = new ToolingTestApplicationContext("jmsNamespaceHandlerTests.xml", getClass());
}
@AfterEach
public void tearDown() throws Exception {
public void shutdown() {
this.context.close();
}

5
spring-jms/src/test/java/org/springframework/jms/listener/SimpleMessageListenerContainerTests.java

@ -1,5 +1,5 @@ @@ -1,5 +1,5 @@
/*
* Copyright 2002-2020 the original author or authors.
* Copyright 2002-2021 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -75,8 +75,7 @@ public class SimpleMessageListenerContainerTests { @@ -75,8 +75,7 @@ public class SimpleMessageListenerContainerTests {
@Test
public void testSessionTransactedModeReallyDoesDefaultToFalse() {
assertThat(this.container.isPubSubNoLocal()).as("The [pubSubLocal] property of SimpleMessageListenerContainer " +
"must default to false. Change this test (and the " +
"attendant Javadoc) if you have changed the default.").isFalse();
"must default to false. Change this test (and the attendant javadoc) if you have changed the default.").isFalse();
}
@Test

6
spring-messaging/src/test/java/org/springframework/messaging/simp/stomp/ReactorNettyTcpStompClientTests.java

@ -1,5 +1,5 @@ @@ -1,5 +1,5 @@
/*
* Copyright 2002-2019 the original author or authors.
* Copyright 2002-2021 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -58,7 +58,7 @@ public class ReactorNettyTcpStompClientTests { @@ -58,7 +58,7 @@ public class ReactorNettyTcpStompClientTests {
@BeforeEach
public void setUp(TestInfo testInfo) throws Exception {
public void setup(TestInfo testInfo) throws Exception {
logger.debug("Setting up before '" + testInfo.getTestMethod().get().getName() + "'");
int port = SocketUtils.findAvailableTcpPort(61613);
@ -81,7 +81,7 @@ public class ReactorNettyTcpStompClientTests { @@ -81,7 +81,7 @@ public class ReactorNettyTcpStompClientTests {
}
@AfterEach
public void tearDown() throws Exception {
public void shutdown() throws Exception {
try {
this.client.shutdown();
}

10
spring-messaging/src/test/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandlerIntegrationTests.java

@ -1,5 +1,5 @@ @@ -1,5 +1,5 @@
/*
* Copyright 2002-2020 the original author or authors.
* Copyright 2002-2021 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -75,7 +75,7 @@ public class StompBrokerRelayMessageHandlerIntegrationTests { @@ -75,7 +75,7 @@ public class StompBrokerRelayMessageHandlerIntegrationTests {
@BeforeEach
public void setUp(TestInfo testInfo) throws Exception {
public void setup(TestInfo testInfo) throws Exception {
logger.debug("Setting up before '" + testInfo.getTestMethod().get().getName() + "'");
this.port = SocketUtils.findAvailableTcpPort(61613);
@ -83,11 +83,11 @@ public class StompBrokerRelayMessageHandlerIntegrationTests { @@ -83,11 +83,11 @@ public class StompBrokerRelayMessageHandlerIntegrationTests {
this.responseHandler = new TestMessageHandler();
this.responseChannel.subscribe(this.responseHandler);
this.eventPublisher = new TestEventPublisher();
startActiveMqBroker();
startActiveMQBroker();
createAndStartRelay();
}
private void startActiveMqBroker() throws Exception {
private void startActiveMQBroker() throws Exception {
this.activeMQBroker = new BrokerService();
this.activeMQBroker.addConnector("stomp://localhost:" + this.port);
this.activeMQBroker.setStartAsync(false);
@ -217,7 +217,7 @@ public class StompBrokerRelayMessageHandlerIntegrationTests { @@ -217,7 +217,7 @@ public class StompBrokerRelayMessageHandlerIntegrationTests {
this.eventPublisher.expectBrokerAvailabilityEvent(false);
startActiveMqBroker();
startActiveMQBroker();
this.eventPublisher.expectBrokerAvailabilityEvent(true);
}

Loading…
Cancel
Save