Skip to content
This repository was archived by the owner on Dec 5, 2023. It is now read-only.

Commit 3dbc92a

Browse files
Merge pull request #18 from microservices-demo/rabbitmq-host-optional
Make the rabbitmq host configurable
2 parents f0b9803 + 8fa69f0 commit 3dbc92a

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

src/main/java/works/weave/socks/shipping/configuration/RabbitMqConfiguration.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,16 +7,22 @@
77
import org.springframework.amqp.rabbit.core.RabbitTemplate;
88
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
99
import org.springframework.amqp.support.converter.MessageConverter;
10+
import org.springframework.beans.factory.annotation.Value;
1011
import org.springframework.context.annotation.Bean;
1112
import org.springframework.context.annotation.Configuration;
1213

14+
1315
@Configuration
1416
public class RabbitMqConfiguration {
17+
1518
final static String queueName = "shipping-task";
1619

20+
@Value("${spring.rabbitmq.host}")
21+
private String host;
22+
1723
@Bean
1824
public ConnectionFactory connectionFactory() {
19-
CachingConnectionFactory connectionFactory = new CachingConnectionFactory("rabbitmq");
25+
CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host);
2026
connectionFactory.setCloseTimeout(5000);
2127
connectionFactory.setConnectionTimeout(5000);
2228
connectionFactory.setUsername("guest");

src/main/resources/application.properties

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
server.port=${port:8080}
2+
spring.rabbitmq.host=rabbitmq
23
endpoints.health.enabled=false
34
spring.zipkin.baseUrl=http://${zipkin:zipkin}:9411/
45
spring.sleuth.sampler.percentage=1.0

0 commit comments

Comments
 (0)