Commit e7780971 authored by I Patini's avatar I Patini
Browse files

Merge branch 'ems/bcep-reinit-fix' into 'ems/morphemic-rc2.0'

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

See merge request !98
parents 87b2447e dfbe8e33
Pipeline #16162 passed with stages
in 12 minutes and 22 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())) {
......
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