<s> from kombu import Exchange , Queue <EOL> from st2common . transport import publishers <EOL> EXECUTION_XCHG = Exchange ( '<STR_LIT>' , type = '<STR_LIT>' ) <EOL> class ActionExecutionPublisher ( publishers . CUDPublisher ) : <EOL> def __init__ ( self , urls ) : <EOL> super ( ActionExecutionPublisher , self ) . __init__ ( urls , EXECUTION_XCHG ) <EOL> def get_queue ( name = None , routing_key = None , exclusive = False ) : <EOL> return Queue ( name , EXECUTION_XCHG , routing_key = routing_key , exclusive = exclusive ) </s>
