mirror of https://github.com/apache/activemq.git
fix up master advisory, advisories are only fired after broker is fully started so the nowMaster advisory needs to ocurr after start rather than as part of persistence adapter start, resolves org.apache.activemq.broker.ft.QueueMasterSlaveTestSupport#testAdvisory failures
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1428397 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
157aaf9167
commit
69d8258308
|
@ -662,6 +662,7 @@ public class BrokerService implements Service {
|
||||||
getBroker().brokerServiceStarted();
|
getBroker().brokerServiceStarted();
|
||||||
checkSystemUsageLimits();
|
checkSystemUsageLimits();
|
||||||
startedLatch.countDown();
|
startedLatch.countDown();
|
||||||
|
getBroker().nowMasterBroker();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -89,9 +89,6 @@ public abstract class LockableServiceSupport extends ServiceSupport implements L
|
||||||
}
|
}
|
||||||
}, lockKeepAlivePeriod, lockKeepAlivePeriod, TimeUnit.MILLISECONDS);
|
}, lockKeepAlivePeriod, lockKeepAlivePeriod, TimeUnit.MILLISECONDS);
|
||||||
}
|
}
|
||||||
if (brokerService != null) {
|
|
||||||
brokerService.getBroker().nowMasterBroker();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue