diff --git a/helloworld/pom.xml b/helloworld/pom.xml index b8988b7..a6775e9 100644 --- a/helloworld/pom.xml +++ b/helloworld/pom.xml @@ -5,7 +5,7 @@ 4.0.0 org.springframework.samples.spring spring-rabbit-helloworld - 1.4.5.RELEASE + 1.5.0.RELEASE jar Spring AMQP Hello World http://www.spring.io @@ -16,8 +16,8 @@ true - 4.1.6.RELEASE - 1.4.5.RELEASE + 4.2.1.RELEASE + 1.5.0.RELEASE UTF-8 diff --git a/log4j/pom.xml b/log4j/pom.xml index 9122a8c..b2d27c9 100644 --- a/log4j/pom.xml +++ b/log4j/pom.xml @@ -5,7 +5,7 @@ 4.0.0 org.springframework.samples.spring spring-rabbit-log4j - 1.4.5.RELEASE + 1.5.0.RELEASE war Spring AMQP log4j http://www.spring.io @@ -16,8 +16,8 @@ true - 4.1.6.RELEASE - 1.4.5.RELEASE + 4.2.1.RELEASE + 1.5.0.RELEASE UTF-8 diff --git a/pom.xml b/pom.xml index ba11c32..bb0e2e1 100644 --- a/pom.xml +++ b/pom.xml @@ -4,7 +4,7 @@ org.springframework.amqp spring-amqp-samples Spring AMQP Samples - 1.4.5.RELEASE + 1.5.0.RELEASE pom helloworld diff --git a/stocks/pom.xml b/stocks/pom.xml index 0042241..c6dfc62 100644 --- a/stocks/pom.xml +++ b/stocks/pom.xml @@ -4,7 +4,7 @@ 4.0.0 org.springframework.samples.spring spring-rabbit-stocks - 1.4.5.RELEASE + 1.5.0.RELEASE war Spring Rabbit Stocks http://www.spring.io @@ -15,8 +15,8 @@ true - 4.1.6.RELEASE - 1.4.5.RELEASE + 4.2.1.RELEASE + 1.5.0.RELEASE UTF-8 diff --git a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitMarketDataGateway.java b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitMarketDataGateway.java index 9656e13..cbfd049 100644 --- a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitMarketDataGateway.java +++ b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitMarketDataGateway.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2010 the original author or authors. + * Copyright 2002-2015 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. @@ -23,20 +23,21 @@ import java.util.Random; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport; + +import org.springframework.amqp.rabbit.core.RabbitGatewaySupport; import org.springframework.amqp.rabbit.stocks.domain.Quote; import org.springframework.amqp.rabbit.stocks.domain.Stock; import org.springframework.amqp.rabbit.stocks.domain.StockExchange; /** * Rabbit implementation of the {@link MarketDataGateway} for sending Market data. - * + * * @author Mark Pollack * @author Mark Fisher */ public class RabbitMarketDataGateway extends RabbitGatewaySupport implements MarketDataGateway { - private static Log logger = LogFactory.getLog(RabbitMarketDataGateway.class); + private static Log logger = LogFactory.getLog(RabbitMarketDataGateway.class); private static final Random random = new Random(); @@ -71,7 +72,7 @@ public class RabbitMarketDataGateway extends RabbitGatewaySupport implements Mar private Quote generateFakeQuote() { MockStock stock = this.stocks.get(random.nextInt(this.stocks.size())); - String price = stock.randomPrice(); + String price = stock.randomPrice(); return new Quote(stock, price); } diff --git a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java index 852ecd0..e2208bf 100644 --- a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java +++ b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2010 the original author or authors. + * Copyright 2002-2015 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. @@ -22,22 +22,23 @@ import java.util.UUID; import org.springframework.amqp.AmqpException; import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessagePostProcessor; -import org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport; +import org.springframework.amqp.rabbit.core.RabbitGatewaySupport; import org.springframework.amqp.rabbit.stocks.domain.TradeRequest; /** * Rabbit implementation of {@link StockServiceGateway} to send trade requests to an external process. - * + * * @author Mark Pollack + * @author Gary Russell */ public class RabbitStockServiceGateway extends RabbitGatewaySupport implements StockServiceGateway { private String defaultReplyTo; - + public void setDefaultReplyTo(String defaultReplyTo) { this.defaultReplyTo = defaultReplyTo; } - + public void send(TradeRequest tradeRequest) { getRabbitTemplate().convertAndSend(tradeRequest, new MessagePostProcessor() { public Message postProcessMessage(Message message) throws AmqpException {