Using weakrefs for mapping
Allow for custom queues to be passed to subscribe