action/kafkaProduce.py [182:196]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        )

        logging.info("Created producer")

        # store the producer globally for subsequent invocations
        globals()["cached_producers"][connectionHash] = producer

        # return it
        return producer
    else:
        logging.info("Reusing existing producer")
        return globals()["cached_producers"][connectionHash]


def getConnectionHash(params):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



action/messageHubProduce.py [195:208]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        )

        logging.info("Created producer")

        # store the producer globally for subsequent invocations
        globals()["cached_producers"][connectionHash] = producer

        # return it
        return producer
    else:
        logging.info("Reusing existing producer")
        return globals()["cached_producers"][connectionHash]

def getConnectionHash(params):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -