add TODO remove transport from _transports_by_topic -> Broker.process_unsubscribe
FIX Broker.process_unsubscribe removing transport
Broker.process_publish subscription_id
refactor optimize import