Saggi Mizrahi has uploaded a new change for review. Change subject: Allow JsonRpcBindings to initialize an AMQP transport ......................................................................
Allow JsonRpcBindings to initialize an AMQP transport Change-Id: Ia493d9b360d6b39538c276b5eadbe2557f3d0d7c Signed-off-by: Saggi Mizrahi <[email protected]> --- M vdsm_api/BindingJsonRpc.py 1 file changed, 15 insertions(+), 0 deletions(-) git pull ssh://gerrit.ovirt.org:29418/vdsm refs/changes/51/10251/1 diff --git a/vdsm_api/BindingJsonRpc.py b/vdsm_api/BindingJsonRpc.py index c32fce3..49f45df 100644 --- a/vdsm_api/BindingJsonRpc.py +++ b/vdsm_api/BindingJsonRpc.py @@ -21,6 +21,11 @@ from jsonrpc import JsonRpcServer from jsonrpc.tcpReactor import TCPReactor +ProtonReactor = None +try: + from jsonrpc.protonReactor import ProtonReactor +except ImportError: + pass class BindingJsonRpc(object): @@ -33,6 +38,11 @@ for backendType, cfg in backendConfig: if backendType == "tcp": reactors.append(self._createTcpReactor(cfg)) + elif backendType == "amqp": + if ProtonReactor is None: + continue + + reactors.append(self._createProtonReactor(cfg)) self._reactors = reactors @@ -41,6 +51,11 @@ port = cfg.get("port", 4044) return TCPReactor((address, port), self.server) + def _createProtonReactor(self, cfg): + address = cfg.get("host", "0.0.0.0") + port = cfg.get("port", 5672) + return TCPReactor((address, port), self.server) + def start(self): for reactor in self._reactors: reactorName = reactor.__class__.__name__ -- To view, visit http://gerrit.ovirt.org/10251 To unsubscribe, visit http://gerrit.ovirt.org/settings Gerrit-MessageType: newchange Gerrit-Change-Id: Ia493d9b360d6b39538c276b5eadbe2557f3d0d7c Gerrit-PatchSet: 1 Gerrit-Project: vdsm Gerrit-Branch: master Gerrit-Owner: Saggi Mizrahi <[email protected]> _______________________________________________ vdsm-patches mailing list [email protected] https://lists.fedorahosted.org/mailman/listinfo/vdsm-patches
