diff --git a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/AbstractStockAppRabbitConfiguration.java b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/AbstractStockAppRabbitConfiguration.java index a42e06d..defe475 100644 --- a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/AbstractStockAppRabbitConfiguration.java +++ b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/AbstractStockAppRabbitConfiguration.java @@ -23,6 +23,7 @@ import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.amqp.support.converter.JsonMessageConverter; import org.springframework.amqp.support.converter.MessageConverter; +import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -52,6 +53,9 @@ public abstract class AbstractStockAppRabbitConfiguration extends AbstractRabbit */ protected static String STOCK_REQUEST_ROUTING_KEY = STOCK_REQUEST_QUEUE_NAME; + @Value("${amqp.port:5672}") + private int port = 5672; + protected abstract void configureRabbitTemplate(RabbitTemplate template); @@ -61,6 +65,7 @@ public abstract class AbstractStockAppRabbitConfiguration extends AbstractRabbit CachingConnectionFactory connectionFactory = new CachingConnectionFactory("localhost"); connectionFactory.setUsername("guest"); connectionFactory.setPassword("guest"); + connectionFactory.setPort(port); return connectionFactory; } diff --git a/stocks/src/main/resources/client-messaging.xml b/stocks/src/main/resources/client-messaging.xml index 6c942a6..effad33 100644 --- a/stocks/src/main/resources/client-messaging.xml +++ b/stocks/src/main/resources/client-messaging.xml @@ -1,23 +1,17 @@ - + - - - - - - - - - - - + + + diff --git a/stocks/src/main/resources/server-bootstrap-config.xml b/stocks/src/main/resources/server-bootstrap-config.xml index 129730d..6f263f7 100644 --- a/stocks/src/main/resources/server-bootstrap-config.xml +++ b/stocks/src/main/resources/server-bootstrap-config.xml @@ -7,6 +7,8 @@ http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> + + diff --git a/stocks/src/main/resources/server-messaging.xml b/stocks/src/main/resources/server-messaging.xml index ec76190..680462b 100644 --- a/stocks/src/main/resources/server-messaging.xml +++ b/stocks/src/main/resources/server-messaging.xml @@ -1,22 +1,16 @@ - + - - - - - - - - - - - + + + diff --git a/stocks/src/main/resources/servlet-config.xml b/stocks/src/main/resources/servlet-config.xml index 056804a..78c6a80 100644 --- a/stocks/src/main/resources/servlet-config.xml +++ b/stocks/src/main/resources/servlet-config.xml @@ -1,19 +1,18 @@ - - + - + @@ -35,26 +34,23 @@ - + - - - + + + - + - +