Commit 950f90d7 authored by I Patini's avatar I Patini
Browse files

Merge branch 'ems/morphemic-rc2.0' into 'morphemic-rc2.0'

EMS: Broker CEP: Bugfix in BrokerCepConsumer. Added clearing added...

See merge request !99
parents 8e0bf0b3 e7780971
Pipeline #16164 failed with stages
in 29 minutes and 33 seconds
......@@ -60,6 +60,9 @@ public class BrokerCepConsumer implements MessageListener, InitializingBean {
// close previous session and connection
closeConnection();
// clear added destinations list
addedDestinations.clear();
// If an alternative Broker URL is provided for consumer, it will be used
ConnectionFactory connectionFactory;
if (StringUtils.isNotBlank(properties.getBrokerUrlForConsumer())) {
......
......@@ -86,7 +86,7 @@ public class BrokerCepService {
}
for (ObjectName t : topics) {
String name = t.getCanonicalName();
bv.removeQueue(name);
bv.removeTopic(name);
log.info("BrokerCepService.clearState(): Topic removed: {}", name);
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment