Skip to content

Commit 966c1af

Browse files
ned29emichaf
authored andcommitted
CHANGE: routingKey to bindingKey (#79)
* FIX: wrong merge * CHANGE: routing to binding
1 parent 18a351b commit 966c1af

File tree

4 files changed

+13
-16
lines changed

4 files changed

+13
-16
lines changed

src/main/java/com/ericsson/ei/rmqhandler/RmqHandler.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -101,8 +101,8 @@ public class RmqHandler {
101101

102102
@Getter
103103
@Setter
104-
@Value("${rabbitmq.routing.key}")
105-
private String routingKey;
104+
@Value("${rabbitmq.binding.key}")
105+
private String bindingKey;
106106

107107
@Getter
108108
@Setter
@@ -156,7 +156,7 @@ TopicExchange exchange() {
156156

157157
@Bean
158158
Binding binding(Queue queue, TopicExchange exchange) {
159-
return BindingBuilder.bind(queue).to(exchange).with(routingKey);
159+
return BindingBuilder.bind(queue).to(exchange).with(bindingKey);
160160
}
161161

162162
@Bean
@@ -191,7 +191,7 @@ public RabbitTemplate rabbitMqTemplate() {
191191
}
192192

193193
rabbitTemplate.setExchange(exchangeName);
194-
rabbitTemplate.setRoutingKey(routingKey);
194+
rabbitTemplate.setRoutingKey(bindingKey);
195195
rabbitTemplate.setQueue(getQueueName());
196196
rabbitTemplate.setConfirmCallback(new ConfirmCallback() {
197197
@Override

src/main/resources/application.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ rabbitmq.domainId: er001-eiffelxxx
2222
rabbitmq.componentName: eiffelintelligence
2323
rabbitmq.consumerName: messageConsumer
2424
rabbitmq.queue.durable:true
25-
rabbitmq.routing.key:#
25+
rabbitmq.binding.key:#
2626
rabbitmq.waitlist.queue.suffix:waitlist
2727

2828
mergeidmarker: %IdentifyRules%

src/main/resources/public/raml/info_instance-schema.raml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ information: |
3333
"waitlistSufix" : {
3434
"type":"string"
3535
},
36-
"routingKey" : {
36+
"bindingKey" : {
3737
"type":"string"
3838
},
3939
"consumerName" : {

src/test/java/com/ericsson/ei/rmqhandler/RmqHandlerTest.java

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -26,13 +26,9 @@
2626
import org.mockito.Mock;
2727
import org.mockito.MockitoAnnotations;
2828
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
29-
import org.springframework.beans.factory.annotation.Autowired;
3029
import org.springframework.boot.test.context.SpringBootTest;
3130
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
3231

33-
import com.ericsson.ei.handlers.EventHandler;
34-
import com.ericsson.ei.rmqhandler.RmqHandler;
35-
3632
@RunWith(SpringJUnit4ClassRunner.class)
3733
@SpringBootTest
3834
public class RmqHandlerTest {
@@ -43,15 +39,16 @@ public class RmqHandlerTest {
4339
private Integer port = 5672;
4440
private String domainId = "EN1";
4541
private String componentName = "eiffelintelligence";
46-
private String routingKey = "#";
42+
private String bindingKey = "#";
4743
private String consumerName = "messageConsumer";
4844

4945
@InjectMocks
50-
RmqHandler rmqHandler;
46+
private RmqHandler rmqHandler;
5147

52-
@Mock ConnectionFactory factory;
48+
@Mock
49+
private ConnectionFactory factory;
5350

54-
@Before public void setUp() throws Exception {
51+
@Before public void setUp() {
5552
MockitoAnnotations.initMocks(this);
5653
initProperties();
5754
}
@@ -64,7 +61,7 @@ public void initProperties()
6461
rmqHandler.setPort(port);
6562
rmqHandler.setDomainId(domainId);
6663
rmqHandler.setComponentName(componentName);
67-
rmqHandler.setRoutingKey(routingKey);
64+
rmqHandler.setBindingKey(bindingKey);
6865
rmqHandler.setConsumerName(consumerName);
6966
}
7067

@@ -100,7 +97,7 @@ public void getComponentNameTest() {
10097

10198
@Test
10299
public void getRoutingKeyTest() {
103-
assertTrue(rmqHandler.getRoutingKey().equals(routingKey));
100+
assertTrue(rmqHandler.getBindingKey().equals(bindingKey));
104101
}
105102

106103
@Test

0 commit comments

Comments
 (0)