MessageRepository
Table of Contents
Methods
-
__construct()
: mixed
-
delete()
: void
-
getOneByQueue()
: MessageBox|null
-
getReadyMessagesOfQueue()
: MessageBoxCollection
-
getStaleMessages()
: MessageBoxCollection
-
save()
: void
-
updateStatus()
: void
__construct()
public
__construct(Entity $tableEntity) : mixed
Parameters
-
$tableEntity
: Entity
-
delete()
public
delete(MessageBox $message) : void
Parameters
-
$message
: MessageBox
-
-
throws
-
PersistenceException
getOneByQueue()
public
getOneByQueue(string $queueId) : MessageBox|null
Parameters
-
$queueId
: string
-
-
throws
-
ArgumentException
-
throws
-
ObjectPropertyException
-
throws
-
SystemException
Return values
MessageBox|null
getReadyMessagesOfQueue()
public
getReadyMessagesOfQueue(string $queueId[, int $limit = 50 ]) : MessageBoxCollection
Parameters
-
$queueId
: string
-
-
$limit
: int
= 50
-
-
throws
-
MappingException
-
throws
-
SystemException
Return values
MessageBoxCollection
getStaleMessages()
public
getStaleMessages() : MessageBoxCollection
-
throws
-
ArgumentException
-
throws
-
ObjectPropertyException
-
throws
-
SystemException
Return values
MessageBoxCollection
save()
public
save(MessageBox $messageBox) : void
Parameters
-
$messageBox
: MessageBox
-
-
throws
-
PersistenceException
updateStatus()
public
updateStatus(MessageBoxCollection $items, MessageStatus $status) : void
Parameters
-
$items
: MessageBoxCollection
-
-
$status
: MessageStatus
-
-
throws
-
PersistenceException