Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- # Message
- spring.activemq.broker-url=tcp://127.0.0.1:5672
- spring.activemq.user=test
- spring.activemq.password=test
- {handshake_error,starting,0,
- {amqp_error,access_refused,
- "PLAIN login refused: user 'guest' - invalid credentials",
- 'connection.start_ok'}}
- spring.rabbitmq.host = 127.0.0.1
- spring.rabbitmq.port = 5672
- spring.rabbitmq.username = guest
- spring.rabbitmq.password = guest
- spring:
- rabbitmq:
- user: guest
- password: guest
- host: rabbitmq
- port: 5672
- virtual-host: someVirtualHost
- rabbitmq:
- host: 'hostname'
- vhost: 'vhostname'
- user: 'userName'
- password: 'passwd'
- port: 5672
- @Configuration
- public class RabbitConfig {
- @Value("${rabbitmq.host}")
- private String host;
- @Value("${rabbitmq.vhost}")
- private String vhost;
- @Value("${rabbitmq.user}")
- private String user;
- @Value("${rabbitmq.password}")
- private String password;
- @Value("${rabbitmq.port}")
- private int port;
- @Bean
- public ConnectionFactory connectionFactory() {
- CachingConnectionFactory factory = new CachingConnectionFactory();
- System.out.println("rmqhost is " + host);
- factory.setHost(host);
- factory.setVirtualHost(vhost);
- factory.setUsername(user);
- factory.setPassword(password);
- factory.setPort(port);
- return factory;
- }
- @Bean
- public RabbitAdmin rabbitAdmin() {
- return new RabbitAdmin(connectionFactory());
- }
- }
Add Comment
Please, Sign In to add comment