This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 3.0.
Source code for kombu.async.aws.sqs.message
# -*- coding: utf-8 -*-
"""Amazon SQS message implementation."""
from __future__ import absolute_import, unicode_literals
from .ext import (
RawMessage, Message, MHMessage, EncodedMHMessage, JSONMessage,
)
__all__ = [
'BaseAsyncMessage', 'AsyncRawMessage', 'AsyncMessage',
'AsyncMHMessage', 'AsyncEncodedMHMessage', 'AsyncJSONMessage',
]
[docs]class BaseAsyncMessage(object):
"""Base class for messages received on async client."""
[docs] def delete(self, callback=None):
if self.queue:
return self.queue.delete_message(self, callback)
[docs] def change_visibility(self, visibility_timeout, callback=None):
if self.queue:
return self.queue.connection.change_message_visibility(
self.queue, self.receipt_handle, visibility_timeout, callback,
)
[docs]class AsyncMHMessage(BaseAsyncMessage, MHMessage):
"""MHM Message (uhm, look that up later)."""