'Retrieve and handle messages from SQS.
Uses long polling and returns :class:`~vine.promises.promise`.'

def _get_from_sqs(self, queue, count=1, connection=None, callback=None):

    connection = (connection if (connection is not None) else queue.connection)
    return connection.receive_message(queue, number_messages=count, wait_time_seconds=self.wait_time_seconds, callback=callback)
