def create_consumer(self, topic, proxy, fanout=False):
        raise NotImplementedError()
unbind to all global events
dataset/ETHPy150Open Havate/havate-openstack/proto-build/gui/horizon/Horizon_GUI/openstack_dashboard/openstack/common/rpc/common.py/Connection.create_consumer--crossover with--dataset/ETHPy150Open benoitc/gaffer/gaffer/httpclient/websocket.py/GafferSocket.unbind_all