public final class QueueStoreWrapper extends Object implements QueueStore<Data>
Modifier and Type | Method and Description |
---|---|
static QueueStoreWrapper |
create(String name,
QueueStoreConfig storeConfig,
SerializationService serializationService,
ClassLoader classLoader)
Factory method that creates a
QueueStoreWrapper |
void |
delete(Long key)
Deletes the entry with a given key from the store.
|
void |
deleteAll(Collection<Long> keys)
Deletes multiple entries from the store.
|
int |
getBulkLoad() |
int |
getMemoryLimit() |
boolean |
isBinary() |
boolean |
isEnabled() |
Data |
load(Long key)
Loads the value of a given key.
|
Map<Long,Data> |
loadAll(Collection<Long> keys)
Loads the given keys.
|
Set<Long> |
loadAllKeys()
Loads all of the keys from the store.
|
void |
store(Long key,
Data value)
Stores the key-value pair.
|
void |
storeAll(Map<Long,Data> map)
Stores multiple entries.
|
public static QueueStoreWrapper create(String name, QueueStoreConfig storeConfig, SerializationService serializationService, ClassLoader classLoader)
QueueStoreWrapper
name
- queue namestoreConfig
- store config of queueserializationService
- serialization service.QueueStoreWrapper
public void store(Long key, Data value)
QueueStore
store
in interface QueueStore<Data>
key
- key of the entry to storevalue
- value of the entry to storepublic void storeAll(Map<Long,Data> map)
QueueStore
storeAll
in interface QueueStore<Data>
map
- map of entries to storepublic void delete(Long key)
QueueStore
delete
in interface QueueStore<Data>
key
- key to delete from the store.public void deleteAll(Collection<Long> keys)
QueueStore
deleteAll
in interface QueueStore<Data>
keys
- keys of the entries to delete.public Data load(Long key)
QueueStore
Implementation can use any means of loading the given key; such as an O/R mapping tool, simple SQL, reading a file, etc.
load
in interface QueueStore<Data>
key
- the key of the requested valuepublic Map<Long,Data> loadAll(Collection<Long> keys)
QueueStore
Set the bulk-load property to configure batch loading. When the queue is initialized, items are loaded from QueueStore in bulks. Bulk load is the size of these bulks. The default value of bulk-load is 250.
loadAll
in interface QueueStore<Data>
keys
- keys of the value entries to loadpublic Set<Long> loadAllKeys()
QueueStore
The items identified by the keys will be loaded in the iteration order of the returned Set
loadAllKeys
in interface QueueStore<Data>
public boolean isEnabled()
public boolean isBinary()
public int getMemoryLimit()
public int getBulkLoad()
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.