allow configuring the command bus
This commit is contained in:
parent
9731350ace
commit
5431b8bfc2
|
@ -39,6 +39,7 @@
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>
|
* along with this program. If not, see <http://www.gnu.org/licenses/>
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
|
|
||||||
namespace OC;
|
namespace OC;
|
||||||
|
|
||||||
use bantu\IniGetWrapper\IniGetWrapper;
|
use bantu\IniGetWrapper\IniGetWrapper;
|
||||||
|
@ -149,7 +150,6 @@ class Server extends ServerContainer implements IServerContainer {
|
||||||
$this->registerAlias(IActionFactory::class, ActionFactory::class);
|
$this->registerAlias(IActionFactory::class, ActionFactory::class);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
$this->registerService(\OCP\IPreview::class, function (Server $c) {
|
$this->registerService(\OCP\IPreview::class, function (Server $c) {
|
||||||
return new PreviewManager(
|
return new PreviewManager(
|
||||||
$c->getConfig(),
|
$c->getConfig(),
|
||||||
|
@ -694,8 +694,19 @@ class Server extends ServerContainer implements IServerContainer {
|
||||||
return new IniGetWrapper();
|
return new IniGetWrapper();
|
||||||
});
|
});
|
||||||
$this->registerService('AsyncCommandBus', function (Server $c) {
|
$this->registerService('AsyncCommandBus', function (Server $c) {
|
||||||
|
$busClass = $c->getConfig()->getSystemValue('commandbus');
|
||||||
|
if ($busClass) {
|
||||||
|
list($app, $class) = explode('::', $busClass, 2);
|
||||||
|
if ($c->getAppManager()->isInstalled($app)) {
|
||||||
|
\OC_App::loadApp($app);
|
||||||
|
return $c->query($class);
|
||||||
|
} else {
|
||||||
|
throw new ServiceUnavailableException("The app providing the command bus ($app) is not enabled");
|
||||||
|
}
|
||||||
|
} else {
|
||||||
$jobList = $c->getJobList();
|
$jobList = $c->getJobList();
|
||||||
return new CronBus($jobList);
|
return new CronBus($jobList);
|
||||||
|
}
|
||||||
});
|
});
|
||||||
$this->registerService('TrustedDomainHelper', function ($c) {
|
$this->registerService('TrustedDomainHelper', function ($c) {
|
||||||
return new TrustedDomainHelper($this->getConfig());
|
return new TrustedDomainHelper($this->getConfig());
|
||||||
|
|
Loading…
Reference in New Issue