MemoryStoreQueue

Show Deprecated
Not Creatable
Not Replicated

Summary

Methods

Methods

AddAsync

()
Yields

Parameters

value: Variant
Default Value: ""
expiration: number
Default Value: ""
priority: number
Default Value: 0

Returns

()

GetSizeAsync

Yields

Parameters

excludeInvisible: boolean
Default Value: false

Returns

ReadAsync

Yields

Parameters

count: number
Default Value: ""
allOrNothing: boolean
Default Value: false
waitTimeout: number
Default Value: -1

Returns

Code Samples

Using a MemoryStoreQueue

local MemoryStoreService = game:GetService("MemoryStoreService")
local DataStoreService = game:GetService("DataStoreService")
local queue = MemoryStoreService:GetQueue("PlayerQueue")
local dataStore = DataStoreService:GetDataStore("PlayerStore")
while true do
pcall(function()
-- wait for an item to process
local items, id = queue:ReadAsync(1, false, 30)
-- check if an item was retrieved
if #items > 0 then
-- mark the item as processed
dataStore:UpdateAsync(items[0], function(data)
data = data or {}
data.processed = 1
return data
end)
-- remove the item from the queue
queue:RemoveAsync(id)
end
end)
end

RemoveAsync

()
Yields

Parameters

id: string
Default Value: ""

Returns

()

Code Samples

Using a MemoryStoreQueue

local MemoryStoreService = game:GetService("MemoryStoreService")
local DataStoreService = game:GetService("DataStoreService")
local queue = MemoryStoreService:GetQueue("PlayerQueue")
local dataStore = DataStoreService:GetDataStore("PlayerStore")
while true do
pcall(function()
-- wait for an item to process
local items, id = queue:ReadAsync(1, false, 30)
-- check if an item was retrieved
if #items > 0 then
-- mark the item as processed
dataStore:UpdateAsync(items[0], function(data)
data = data or {}
data.processed = 1
return data
end)
-- remove the item from the queue
queue:RemoveAsync(id)
end
end)
end