Skip to content

Commit af47957

Browse files
author
Vali (Vasile Baluta)
committed
another fix to flow test
Change-Id: I22c0dd66f5ca94006d175d92480f6ae5a389182f
1 parent 9e022ee commit af47957

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/test/java/com/ericsson/ei/flowtests/FlowTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -209,13 +209,13 @@ private ArrayList<String> getEventNamesToSend() {
209209
}
210210

211211
private void createExchange(final String exchangeName, final String queueName) {
212-
final CachingConnectionFactory cf = new CachingConnectionFactory(AMQPBrokerManager.PORT);
213-
final RabbitAdmin admin = new RabbitAdmin(cf);
212+
final CachingConnectionFactory ccf = new CachingConnectionFactory(cf);
213+
final RabbitAdmin admin = new RabbitAdmin(ccf);
214214
final Queue queue = new Queue(queueName, false);
215215
admin.declareQueue(queue);
216216
final TopicExchange exchange = new TopicExchange(exchangeName);
217217
admin.declareExchange(exchange);
218218
admin.declareBinding(BindingBuilder.bind(queue).to(exchange).with("#"));
219-
cf.destroy();
219+
ccf.destroy();
220220
}
221221
}

0 commit comments

Comments
 (0)