def create_consumer(self, topic, proxy, fanout=False):
        consumer = Consumer(topic, proxy)
        self.consumers.append(consumer)
        if topic != CONSUMERS:
            CONSUMERS[topic] = []
        CONSUMERS[topic].append(consumer)
dataset/ETHPy150Open Havate/havate-openstack/proto-build/gui/horizon/Horizon_GUI/openstack_dashboard/openstack/common/rpc/impl_fake.py/Connection.create_consumer/operator `not in` -> `!=`