sqs_manager_base

messageflux.iodevices.sqs.sqs_manager_base

SQSManagerBase

SQSManagerBase(*, sqs_resource=None, **kwargs)

base class for sqs device managers

Parameters:

Name	Type	Description	Default
`sqs_resource`	`Optional[SQSServiceResource]`	the boto sqs service resource. Defaults to creating from env vars	`None`

create_queue(queue_name, **kwargs)

creates a queue

Parameters:

Name	Type	Description	Default
`queue_name`	`str`	the queue name to create	required

Returns:

Type	Description
`Queue`	the newly created queue

get_queue(queue_name)

gets the queue from cache