root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions 6 Packages Projects Releases Wiki Activity

Fix test issue with Set iteration order

This commit is contained in:
Rossen Stoyanchev 2014-10-29 17:20:22 -04:00
parent c7a93a80d4
commit 38ef6dec50
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
spring-websocket/src/test/java/org/springframework/web/socket/config/annotation/WebSocketMessageBrokerConfigurationSupportTests.java
View File

@ -22,7 +22,6 @@ import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Iterator;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
@ -117,21 +116,21 @@ public class WebSocketMessageBrokerConfigurationSupportTests {
assertEquals(ImmutableMessageChannelInterceptor.class, interceptors.get(interceptors.size()-1).getClass()); assertEquals(ImmutableMessageChannelInterceptor.class, interceptors.get(interceptors.size()-1).getClass());
assertEquals(1, handlers.size()); assertEquals(1, handlers.size());
assertTrue(handlers.iterator().next() instanceof SubProtocolWebSocketHandler); assertTrue(handlers.contains(config.getBean(SubProtocolWebSocketHandler.class)));
} }
@Test @Test
public void brokerChannel() { public void brokerChannel() {
ApplicationContext config = createConfig(TestChannelConfig.class, TestConfigurer.class); ApplicationContext config = createConfig(TestChannelConfig.class, TestConfigurer.class);
TestChannel channel = config.getBean("brokerChannel", TestChannel.class); TestChannel channel = config.getBean("brokerChannel", TestChannel.class);
Iterator<MessageHandler> handlers = channel.getSubscribers().iterator(); Set<MessageHandler> handlers = channel.getSubscribers();
List<ChannelInterceptor> interceptors = channel.getInterceptors(); List<ChannelInterceptor> interceptors = channel.getInterceptors();
assertEquals(ImmutableMessageChannelInterceptor.class, interceptors.get(interceptors.size()-1).getClass()); assertEquals(ImmutableMessageChannelInterceptor.class, interceptors.get(interceptors.size()-1).getClass());
assertEquals(SimpleBrokerMessageHandler.class, handlers.next().getClass()); assertEquals(2, handlers.size());
assertEquals(UserDestinationMessageHandler.class, handlers.next().getClass()); assertTrue(handlers.contains(config.getBean(SimpleBrokerMessageHandler.class)));
assertFalse(handlers.hasNext()); assertTrue(handlers.contains(config.getBean(UserDestinationMessageHandler.class)));
} }
@Test @Test
@ -212,6 +211,7 @@ public class WebSocketMessageBrokerConfigurationSupportTests {
@MessageMapping("/foo") @MessageMapping("/foo")
@SendTo("/bar") @SendTo("/bar")
@SuppressWarnings("unused")
public String handleMessage() { public String handleMessage() {
return "bar"; return "bar";
} }