dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #12394 from artem-barysh-dev/fix-rabbitmq-node

Browse Source 
Removed default host value for RabbitMQ node
This commit is contained in:
Viacheslav Klimov 2025-01-21 15:37:40 +02:00 committed by GitHub
commit ae3f113ec4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/rabbitmq/TbRabbitMqNodeConfiguration.java
View File

@ -44,7 +44,6 @@ public class TbRabbitMqNodeConfiguration implements NodeConfiguration<TbRabbitMq
configuration.setExchangeNamePattern(""); configuration.setExchangeNamePattern("");
configuration.setRoutingKeyPattern(""); configuration.setRoutingKeyPattern("");
configuration.setMessageProperties(null); configuration.setMessageProperties(null);
configuration.setHost(ConnectionFactory.DEFAULT_HOST);
configuration.setPort(ConnectionFactory.DEFAULT_AMQP_PORT); configuration.setPort(ConnectionFactory.DEFAULT_AMQP_PORT);
configuration.setVirtualHost(ConnectionFactory.DEFAULT_VHOST); configuration.setVirtualHost(ConnectionFactory.DEFAULT_VHOST);
configuration.setUsername(ConnectionFactory.DEFAULT_USER); configuration.setUsername(ConnectionFactory.DEFAULT_USER);

2
rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/rabbitmq/TbRabbitMqNodeTest.java
View File

@ -103,7 +103,7 @@ public class TbRabbitMqNodeTest {
assertThat(config.getExchangeNamePattern()).isEqualTo(""); assertThat(config.getExchangeNamePattern()).isEqualTo("");
assertThat(config.getRoutingKeyPattern()).isEqualTo(""); assertThat(config.getRoutingKeyPattern()).isEqualTo("");
assertThat(config.getMessageProperties()).isNull(); assertThat(config.getMessageProperties()).isNull();
assertThat(config.getHost()).isEqualTo(ConnectionFactory.DEFAULT_HOST); assertThat(config.getHost()).isNull();
assertThat(config.getPort()).isEqualTo(ConnectionFactory.DEFAULT_AMQP_PORT); assertThat(config.getPort()).isEqualTo(ConnectionFactory.DEFAULT_AMQP_PORT);
assertThat(config.getVirtualHost()).isEqualTo(ConnectionFactory.DEFAULT_VHOST); assertThat(config.getVirtualHost()).isEqualTo(ConnectionFactory.DEFAULT_VHOST);
assertThat(config.getUsername()).isEqualTo(ConnectionFactory.DEFAULT_USER); assertThat(config.getUsername()).isEqualTo(ConnectionFactory.DEFAULT_USER);