code: 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_formatf 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)
docs: Listen to sqs and fire message on event bus