Polishing

This commit is contained in:
Sam Brannen
2023-11-30 19:04:59 +01:00
parent 8ff687b68c
commit 6ea9fdbf77
36 changed files with 126 additions and 120 deletions

View File

@@ -225,7 +225,7 @@ public class MessageBrokerConfigurationTests {
assertThat(handlers.contains(context.getBean(UserDestinationMessageHandler.class))).isTrue();
assertThat(handlers.contains(context.getBean(SimpleBrokerMessageHandler.class))).isTrue();
assertThat((Object) channel.getExecutor()).isNull();
assertThat(channel.getExecutor()).isNull();
}
@Test
@@ -479,7 +479,7 @@ public class MessageBrokerConfigurationTests {
assertThat(registry.getClass()).isNotEqualTo(MultiServerUserRegistry.class);
UserDestinationMessageHandler handler = context.getBean(UserDestinationMessageHandler.class);
assertThat((Object) handler.getBroadcastDestination()).isNull();
assertThat(handler.getBroadcastDestination()).isNull();
Object nullBean = context.getBean("userRegistryMessageHandler");
assertThat(nullBean.equals(null)).isTrue();

View File

@@ -586,7 +586,7 @@ public class DefaultStompSessionTests {
receivedHeaders.set(receiptHeaders);
});
assertThat((Object) received.get()).isNull();
assertThat(received.get()).isNull();
StompHeaderAccessor accessor = StompHeaderAccessor.create(StompCommand.RECEIPT);
accessor.setReceiptId("my-receipt");
@@ -656,7 +656,7 @@ public class DefaultStompSessionTests {
Runnable scheduledTask = taskCaptor.getValue();
assertThat(scheduledTask).isNotNull();
assertThat((Object) notReceived.get()).isNull();
assertThat(notReceived.get()).isNull();
scheduledTask.run();
assertThat(notReceived.get()).isTrue();

View File

@@ -205,8 +205,8 @@ public class StompHeaderAccessorTests {
StompHeaderAccessor headerAccessor = StompHeaderAccessor.create(StompCommand.SEND);
MessageHeaders headers = headerAccessor.getMessageHeaders();
assertThat((Object) headers.getId()).isNull();
assertThat((Object) headers.getTimestamp()).isNull();
assertThat(headers.getId()).isNull();
assertThat(headers.getTimestamp()).isNull();
}
@Test

View File

@@ -265,7 +265,7 @@ public class MessageHeaderAccessorTests {
@Test
public void timestampDefaultBehavior() {
MessageHeaderAccessor accessor = new MessageHeaderAccessor();
assertThat((Object) accessor.getMessageHeaders().getTimestamp()).isNull();
assertThat(accessor.getMessageHeaders().getTimestamp()).isNull();
}
@Test
@@ -291,8 +291,8 @@ public class MessageHeaderAccessorTests {
accessor.setLeaveMutable(true);
MessageHeaders headers = accessor.getMessageHeaders();
assertThat((Object) headers.getId()).isNull();
assertThat((Object) headers.getTimestamp()).isNull();
assertThat(headers.getId()).isNull();
assertThat(headers.getTimestamp()).isNull();
final UUID id = new UUID(0L, 23L);
accessor.setIdGenerator(() -> id);