this.ebQueue = String.format("%s.%s.%s",
Bridge.class.getSimpleName().toLowerCase(),
SinkBridgeEndpoint.class.getSimpleName().toLowerCase(),
UUID.randomUUID().toString());
LOG.info("Event Bus queue : {}", this.ebQueue);
<BUG>this.deliveryTag = 0;
}</BUG>
@Override
public void open() {
}

this.ebQueue = String.format("%s.%s.%s",
Bridge.class.getSimpleName().toLowerCase(),
SinkBridgeEndpoint.class.getSimpleName().toLowerCase(),
UUID.randomUUID().toString());
LOG.info("Event Bus queue : {}", this.ebQueue);
this.deliveryTag = 0;
this.barrier = new CyclicBarrier(2);
}
@Override
public void open() {
}
