Antiope.SQS

Documentation

newtype QueueUrl

Constructors

QueueUrl Text

Instances

Eq QueueUrl

Defined in Antiope.SQS.Types

Methods

(==) :: QueueUrl -> QueueUrl -> Bool

(/=) :: QueueUrl -> QueueUrl -> Bool

Show QueueUrl

Defined in Antiope.SQS.Types

Methods

showsPrec :: Int -> QueueUrl -> ShowS

show :: QueueUrl -> String

showList :: [QueueUrl] -> ShowS

IsString QueueUrl

Defined in Antiope.SQS.Types

Methods

fromString :: String -> QueueUrl

Generic QueueUrl

Defined in Antiope.SQS.Types

Associated Types

type Rep QueueUrl :: Type -> Type

Methods

from :: QueueUrl -> Rep QueueUrl x

to :: Rep QueueUrl x -> QueueUrl

ToText QueueUrl

Defined in Antiope.SQS.Types

Methods

toText :: QueueUrl -> Text

FromText QueueUrl

Defined in Antiope.SQS.Types

Methods

parser :: Parser QueueUrl

type Rep QueueUrl

Defined in Antiope.SQS.Types

type Rep QueueUrl = D1 (MetaData "QueueUrl" "Antiope.SQS.Types" "antiope-sqs-7.0.6-HIH7kgJFbk7EwbOU7QNI8q" True) (C1 (MetaCons "QueueUrl" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data SQSError

Constructors

DeleteMessageBatchError

Instances

Eq SQSError

Defined in Antiope.SQS.Types

Methods

(==) :: SQSError -> SQSError -> Bool

(/=) :: SQSError -> SQSError -> Bool

Show SQSError

Defined in Antiope.SQS.Types

Methods

showsPrec :: Int -> SQSError -> ShowS

show :: SQSError -> String

showList :: [SQSError] -> ShowS

Generic SQSError

Defined in Antiope.SQS.Types

Associated Types

type Rep SQSError :: Type -> Type

Methods

from :: SQSError -> Rep SQSError x

to :: Rep SQSError x -> SQSError

type Rep SQSError

Defined in Antiope.SQS.Types

type Rep SQSError = D1 (MetaData "SQSError" "Antiope.SQS.Types" "antiope-sqs-7.0.6-HIH7kgJFbk7EwbOU7QNI8q" False) (C1 (MetaCons "DeleteMessageBatchError" PrefixI False) (U1 :: Type -> Type))

class HasReceiptHandle a

Minimal complete definition

getReceiptHandle

Instances

HasReceiptHandle Message

Defined in Antiope.SQS.Types

Methods

getReceiptHandle :: Message -> Maybe ReceiptHandle

HasReceiptHandle ReceiptHandle

Defined in Antiope.SQS.Types

Methods

getReceiptHandle :: ReceiptHandle -> Maybe ReceiptHandle

HasReceiptHandle (SqsMessage a)

Defined in Antiope.SQS.Messages

Methods

getReceiptHandle :: SqsMessage a -> Maybe ReceiptHandle

data ConsumerMode

Queue consuming mode

Constructors

Drain

Keep consuming the queue until there are no messages

Forever

Keep consuming the queue forever

Instances

Eq ConsumerMode

Defined in Antiope.SQS.Types

Methods

(==) :: ConsumerMode -> ConsumerMode -> Bool

(/=) :: ConsumerMode -> ConsumerMode -> Bool

Show ConsumerMode

Defined in Antiope.SQS.Types

Methods

showsPrec :: Int -> ConsumerMode -> ShowS

show :: ConsumerMode -> String

showList :: [ConsumerMode] -> ShowS

Generic ConsumerMode

Defined in Antiope.SQS.Types

Associated Types

type Rep ConsumerMode :: Type -> Type

Methods

from :: ConsumerMode -> Rep ConsumerMode x

to :: Rep ConsumerMode x -> ConsumerMode

type Rep ConsumerMode

Defined in Antiope.SQS.Types

type Rep ConsumerMode = D1 (MetaData "ConsumerMode" "Antiope.SQS.Types" "antiope-sqs-7.0.6-HIH7kgJFbk7EwbOU7QNI8q" False) (C1 (MetaCons "Drain" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Forever" PrefixI False) (U1 :: Type -> Type))

data ConsumerResult

Constructors

Ack

Nack

Instances

Eq ConsumerResult

Defined in Antiope.SQS.Types

Methods

(==) :: ConsumerResult -> ConsumerResult -> Bool

(/=) :: ConsumerResult -> ConsumerResult -> Bool

Show ConsumerResult

Defined in Antiope.SQS.Types

Methods

showsPrec :: Int -> ConsumerResult -> ShowS

show :: ConsumerResult -> String

showList :: [ConsumerResult] -> ShowS

Generic ConsumerResult

Defined in Antiope.SQS.Types

Associated Types

type Rep ConsumerResult :: Type -> Type

Methods

from :: ConsumerResult -> Rep ConsumerResult x

to :: Rep ConsumerResult x -> ConsumerResult

type Rep ConsumerResult

Defined in Antiope.SQS.Types

type Rep ConsumerResult = D1 (MetaData "ConsumerResult" "Antiope.SQS.Types" "antiope-sqs-7.0.6-HIH7kgJFbk7EwbOU7QNI8q" False) (C1 (MetaCons "Ack" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Nack" PrefixI False) (U1 :: Type -> Type))

readQueue :: MonadAWS m => QueueUrl -> m [Message]

Reads the specified SQS queue once returning a bath of messages

drainQueue :: MonadAWS m => QueueUrl -> m [Message]

Reads the specified SQS queue until it is empty and returns a list of messages

ackMessage :: (MonadAWS m, HasReceiptHandle msg) => QueueUrl -> msg -> m (Either SQSError ())

Acknowledges a single SQS message

ackMessages :: (MonadAWS m, HasReceiptHandle msg) => QueueUrl -> [msg] -> m (Either SQSError ())

Acknowledges a group of SQS messages

queueSource :: MonadAWS m => QueueUrl -> ConduitT () Message m ()

Reads from an SQS indefinitely, producing messages into a conduit

forAllMessages :: (MonadUnliftIO m, HasEnv env) => env -> QueueUrl -> ConsumerMode -> (Message -> m ConsumerResult) -> m ()

Re-exports

data Message

An Amazon SQS message.

See: message smart constructor.

Instances

Eq Message

Defined in Network.AWS.SQS.Types.Product

Methods

(==) :: Message -> Message -> Bool

(/=) :: Message -> Message -> Bool

Data Message

Defined in Network.AWS.SQS.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> Message -> c Message

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c Message

toConstr :: Message -> Constr

dataTypeOf :: Message -> DataType

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c Message)

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c Message)

gmapT :: (forall b. Data b => b -> b) -> Message -> Message

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> Message -> r

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> Message -> r

gmapQ :: (forall d. Data d => d -> u) -> Message -> [u]

gmapQi :: Int -> (forall d. Data d => d -> u) -> Message -> u

gmapM :: Monad m => (forall d. Data d => d -> m d) -> Message -> m Message

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> Message -> m Message

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> Message -> m Message

Read Message

Defined in Network.AWS.SQS.Types.Product

Methods

readsPrec :: Int -> ReadS Message

readList :: ReadS [Message]

readPrec :: ReadPrec Message

readListPrec :: ReadPrec [Message]

Show Message

Defined in Network.AWS.SQS.Types.Product

Methods

showsPrec :: Int -> Message -> ShowS

show :: Message -> String

showList :: [Message] -> ShowS

Generic Message

Defined in Network.AWS.SQS.Types.Product

Associated Types

type Rep Message :: Type -> Type

Methods

from :: Message -> Rep Message x

to :: Rep Message x -> Message

Hashable Message

Defined in Network.AWS.SQS.Types.Product

Methods

hashWithSalt :: Int -> Message -> Int

hash :: Message -> Int

FromXML Message

Defined in Network.AWS.SQS.Types.Product

Methods

parseXML :: [Node] -> Either String Message

NFData Message

Defined in Network.AWS.SQS.Types.Product

Methods

rnf :: Message -> ()

HasReceiptHandle Message

Defined in Antiope.SQS.Types

Methods

getReceiptHandle :: Message -> Maybe ReceiptHandle

type Rep Message

Defined in Network.AWS.SQS.Types.Product

type Rep Message = D1 (MetaData "Message" "Network.AWS.SQS.Types.Product" "amazonka-sqs-1.6.1-DjUKaBSRjB56DjcJ3dJAkK" False) (C1 (MetaCons "Message'" PrefixI True) ((S1 (MetaSel (Just "_mMessageAttributes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (Map Text MessageAttributeValue))) :*: (S1 (MetaSel (Just "_mMD5OfBody") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_mBody") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))) :*: ((S1 (MetaSel (Just "_mAttributes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (Map MessageAttribute Text))) :*: S1 (MetaSel (Just "_mReceiptHandle") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) :*: (S1 (MetaSel (Just "_mMessageId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_mMD5OfMessageAttributes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))))

mBody :: Lens' Message (Maybe Text)

The message's contents (not URL-encoded).

mMD5OfBody :: Lens' Message (Maybe Text)

An MD5 digest of the non-URL-encoded message body string.

mMessageId :: Lens' Message (Maybe Text)

A unique identifier for the message. A MessageId is considered unique across all AWS accounts for an extended period of time.

mReceiptHandle :: Lens' Message (Maybe Text)

An identifier associated with the act of receiving the message. A new receipt handle is returned every time you receive a message. When deleting a message, you provide the last received receipt handle to delete the message.

mAttributes :: Lens' Message (HashMap MessageAttribute Text)

SenderId , SentTimestamp , ApproximateReceiveCount , andor ApproximateFirstReceiveTimestamp . SentTimestamp and ApproximateFirstReceiveTimestamp are each returned as an integer representing the <http:en.wikipedia.orgwiki/Unix_time epoch time> in milliseconds.