Upgrade to reactor-tcp 1.0 and jetty plugin 9.0.6

Author: rstoyanchev

pom.xml

@@ -61,7 +61,7 @@
 		<dependency>
 			<groupId>org.projectreactor</groupId>
 			<artifactId>reactor-tcp</artifactId>
-			<version>1.0.0.BUILD-SNAPSHOT</version>
+			<version>1.0.0.RELEASE</version>
 		</dependency>
 
 		<dependency>
@@ -184,7 +184,7 @@
 			<plugin>
 				<groupId>org.eclipse.jetty</groupId>
 				<artifactId>jetty-maven-plugin</artifactId>
-				<version>9.0.4.v20130625</version>
+				<version>9.0.6.v20130930</version>
 				<configuration>
 					<webApp>
 						<contextPath>/${project.artifactId}</contextPath>

src/main/java/org/springframework/samples/portfolio/config/WebSocketConfig.java

@@ -22,8 +22,8 @@ public void registerStompEndpoints(StompEndpointRegistry registry) {
 
 	@Override
 	public void configureMessageBroker(MessageBrokerConfigurer configurer) {
-		configurer.enableSimpleBroker("/queue/", "/topic/");
-//		configurer.enableStompBrokerRelay("/queue/", "/topic/");
+//		configurer.enableSimpleBroker("/queue/", "/topic/");
+		configurer.enableStompBrokerRelay("/queue/", "/topic/");
 		configurer.setApplicationDestinationPrefixes("/app");
 	}
 

src/main/java/org/springframework/samples/portfolio/service/TradeService.java

@@ -73,7 +73,7 @@ public void sendTradeNotifications() {
 
 		for (TradeResult result : this.tradeResults) {
 			if (System.currentTimeMillis() >= (result.timestamp + 1500)) {
-				logger.debug("Position update: " + result.position);
+				logger.debug("Sending position update: " + result.position);
 				this.messagingTemplate.convertAndSendToUser(result.user, "/queue/position-updates", result.position);
 				this.tradeResults.remove(result);
 			}

src/main/resources/log4j.xml

@@ -18,10 +18,6 @@
 		<level value="debug" />
 	</logger>
 
-	<logger name="org.springframework.messaging.simp.stomp">
-		<level value="debug" />
-	</logger>
-
 	<logger name="org.springframework.web">
 		<level value="debug" />
 	</logger>