simplexmq-0.5.2: SimpleXMQ message broker
Safe HaskellNone
LanguageHaskell2010

Simplex.Messaging.Server.MsgStore

Documentation

data Message Source #

Constructors

Message 

Fields

class MonadMsgStore s q m | s -> q where Source #

Methods

getMsgQueue :: s -> RecipientId -> Natural -> m q Source #

delMsgQueue :: s -> RecipientId -> m () Source #

Instances

Instances details
MonadMsgStore STMMsgStore MsgQueue STM Source # 
Instance details

Defined in Simplex.Messaging.Server.MsgStore.STM

Methods

getMsgQueue :: STMMsgStore -> RecipientId -> Natural -> STM MsgQueue Source #

delMsgQueue :: STMMsgStore -> RecipientId -> STM () Source #

class MonadMsgQueue q m where Source #

Methods

isFull :: q -> m Bool Source #

writeMsg :: q -> Message -> m () Source #

tryPeekMsg :: q -> m (Maybe Message) Source #

peekMsg :: q -> m Message Source #

tryDelPeekMsg :: q -> m (Maybe Message) Source #

Instances

Instances details
MonadMsgQueue MsgQueue STM Source # 
Instance details

Defined in Simplex.Messaging.Server.MsgStore.STM

Methods

isFull :: MsgQueue -> STM Bool Source #

writeMsg :: MsgQueue -> Message -> STM () Source #

tryPeekMsg :: MsgQueue -> STM (Maybe Message) Source #

peekMsg :: MsgQueue -> STM Message Source #

tryDelPeekMsg :: MsgQueue -> STM (Maybe Message) Source #