Browse Source

Polishing.

Reformat code, add since tags. Refine test names.

See #4403
Original pull request: #4976
issue/4985
Mark Paluch 6 months ago
parent
commit
6a0d882867
No known key found for this signature in database
GPG Key ID: 55BC6374BAA9D973
  1. 7
      spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java
  2. 6
      spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainerUnitTests.java

7
spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java

@ -26,6 +26,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; @@ -26,6 +26,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jspecify.annotations.Nullable;
import org.springframework.core.task.SimpleAsyncTaskExecutor;
import org.springframework.dao.DataAccessResourceFailureException;
import org.springframework.data.mongodb.core.MongoTemplate;
@ -112,8 +113,12 @@ public class DefaultMessageListenerContainer implements MessageListenerContainer @@ -112,8 +113,12 @@ public class DefaultMessageListenerContainer implements MessageListenerContainer
/**
* Set whether to auto-start this container.
* <p>Default is {@code true}.
* <p>
* Default is {@code true}.
*
* @param autoStartup {@code true} to auto-start.
* @since 5.0
* @see org.springframework.context.SmartLifecycle#isAutoStartup()
*/
public void setAutoStartup(boolean autoStartup) {
this.autoStartup = autoStartup;

6
spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainerUnitTests.java

@ -82,13 +82,15 @@ class DefaultMessageListenerContainerUnitTests { @@ -82,13 +82,15 @@ class DefaultMessageListenerContainerUnitTests {
}
@Test // GH-4403
void shouldHaveAutoStartupEnabledByDefault() {
void shouldAutoStartup() {
assertThat(container.isAutoStartup()).isTrue();
}
@Test // GH-4403
void shouldAllowDisablingAutoStartup() {
void shouldDisableAutostartup() {
container.setAutoStartup(false);
assertThat(container.isAutoStartup()).isFalse();
}

Loading…
Cancel
Save