<s> from kombu import Exchange , Queue <EOL> from st2common . transport import publishers <EOL> LIVEACTION_XCHG = Exchange ( '<STR_LIT>' , type = '<STR_LIT>' ) <EOL> LIVEACTION_STATUS_MGMT_XCHG = Exchange ( '<STR_LIT>' , type = '<STR_LIT>' ) <EOL> class LiveActionPublisher ( publishers . CUDPublisher , publishers . StatePublisherMixin ) : <EOL> def __init__ ( self , urls ) : <EOL> publishers . CUDPublisher . __init__ ( self , urls , LIVEACTION_XCHG ) <EOL> publishers . StatePublisherMixin . __init__ ( self , urls , LIVEACTION_STATUS_MGMT_XCHG ) <EOL> def get_queue ( name , routing_key ) : <EOL> return Queue ( name , LIVEACTION_XCHG , routing_key = routing_key ) <EOL> def get_status_management_queue ( name , routing_key ) : <EOL> return Queue ( name , LIVEACTION_STATUS_MGMT_XCHG , routing_key = routing_key ) </s>
