lonnymq
Preparing search index...
Queue
Class Queue<T>
Type Parameters
T
=
DatabaseClient
Index
Constructors
constructor
Properties
message
schema
Methods
channel
dequeue
install
decode
Constructors
constructor
new
Queue
<
T
=
DatabaseClient
>
(
params
:
QueueParams
<
T
>
)
:
Queue
<
T
>
Type Parameters
T
=
DatabaseClient
Parameters
params
:
QueueParams
<
T
>
Returns
Queue
<
T
>
Properties
Readonly
message
message
:
QueueMessageModule
<
T
>
Readonly
schema
schema
:
string
Methods
channel
channel
(
channelId
:
string
)
:
QueueChannelModule
<
T
>
Parameters
channelId
:
string
Returns
QueueChannelModule
<
T
>
dequeue
dequeue
(
params
:
{
databaseClient
:
T
;
lockMs
:
number
}
,
)
:
Promise
<
QueueMessageDequeueResult
<
T
>
>
Parameters
params
:
{
databaseClient
:
T
;
lockMs
:
number
}
Returns
Promise
<
QueueMessageDequeueResult
<
T
>
>
install
install
(
params
?:
{
eventChannel
?:
string
}
)
:
string
[]
Parameters
params
:
{
eventChannel
?:
string
}
= {}
Returns
string
[]
Static
decode
decode
(
payload
:
string
)
:
QueueEvent
Parameters
payload
:
string
Returns
QueueEvent
Settings
Member Visibility
Protected
Inherited
External
Theme
OS
Light
Dark
On This Page
Constructors
constructor
Properties
message
schema
Methods
channel
dequeue
install
decode
lonnymq
Loading...