def start(queue, profile=None, tag='salt/engine/sqs', owner_acct_id=None):
    '''
    Listen to sqs and fire message on event bus
    '''
    if __opts__.get('__role') == 'master':
        fire_master = salt.utils.event.get_master_event(
            __opts__,
            __opts__['sock_dir'],
            listen=False).fire_event
    else:
        fire_master = __salt__['event.send']

    message_format = __opts__.get('sqs.message_format', None)

    sqs = _get_sqs_conn(profile)
    q = None
    while True:
        if not q:
            q = sqs.get_queue(queue, owner_acct_id=owner_acct_id)
            q.set_message_class(boto.sqs.message.RawMessage)

        _process_queue(q, queue, fire_master, tag=tag, owner_acct_id=owner_acct_id, message_format=message_format)
def start ( queue , profile = None , tag = 'salt/engine/sqs' , owner_acct_id = None ) : if __opts__ . get ( '__role' ) == 'master' : fire_master = salt . utils . event . get_master_event ( __opts__ , __opts__ [ 'sock_dir' ] , listen = False ) . fire_event else : fire_master = __salt__ [ 'event.send' ] message_format = __opts__ . get ( 'sqs.message_format' , None ) sqs = _get_sqs_conn ( profile ) q = None while True : if not q : q = sqs . get_queue ( queue , owner_acct_id = owner_acct_id ) q . set_message_class ( boto . sqs . message . RawMessage ) _process_queue ( q , queue , fire_master , tag = tag , owner_acct_id = owner_acct_id , message_format = message_format )
Listen to sqs and fire message on event bus