router – Router

Routes messages to workers (that are in named queues).

class router.Router(*args, **kwargs)

A simple router of messages

start(frontend_addr='tcp://127.0.0.1:47290', backend_addr='tcp://127.0.0.1:47291')

Begin listening for connections on the provided connection strings

Parameters:
  • frontend_addr – connection string to listen for requests
  • backend_addr – connection string to listen for workers