com.hazelcast.collection.impl.queue

Class LatencyTrackingQueueStore<T>

java.lang.Object

com.hazelcast.collection.impl.queue.LatencyTrackingQueueStore<T>

All Implemented Interfaces:

QueueStore<T>

public class LatencyTrackingQueueStore<T>
extends Object
implements QueueStore<T>

Constructor Summary

Constructors

Constructor and Description
LatencyTrackingQueueStore(QueueStore<T> delegate, StoreLatencyPlugin plugin, String queueName)

Method Summary

Modifier and Type	Method and Description
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.
T	load(Long key) Loads the value of a given key.
Map<Long,T>	loadAll(Collection<Long> keys) Loads the given keys.
Set<Long>	loadAllKeys() Loads all of the keys from the store.
void	store(Long key, T value) Stores the key-value pair.
void	storeAll(Map<Long,T> map) Stores multiple entries.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LatencyTrackingQueueStore

public LatencyTrackingQueueStore(QueueStore<T> delegate,
                                 StoreLatencyPlugin plugin,
                                 String queueName)

Method Detail

store

public void store(Long key,
                  T value)

Description copied from interface: QueueStore

Stores the key-value pair.

Specified by:

store in interface QueueStore<T>

Parameters:

key - key of the entry to store

value - value of the entry to store

storeAll

public void storeAll(Map<Long,T> map)

Description copied from interface: QueueStore

Stores multiple entries. Implementation of this method can optimize the store operation by storing all entries in one database connection for instance.

Specified by:

storeAll in interface QueueStore<T>

Parameters:

map - map of entries to store

delete

public void delete(Long key)

Description copied from interface: QueueStore

Deletes the entry with a given key from the store.

Specified by:

delete in interface QueueStore<T>

Parameters:

key - key to delete from the store.

deleteAll

public void deleteAll(Collection<Long> keys)

Description copied from interface: QueueStore

Deletes multiple entries from the store.

Specified by:

deleteAll in interface QueueStore<T>

Parameters:

keys - keys of the entries to delete.

load

public T load(Long key)

Description copied from interface: QueueStore

Loads the value of a given key.

Implementation can use any means of loading the given key; such as an O/R mapping tool, simple SQL, reading a file, etc.

Specified by:

load in interface QueueStore<T>

Parameters:

key - the key of the requested value

Returns:

value of the key

loadAll

public Map<Long,T> loadAll(Collection<Long> keys)

Description copied from interface: QueueStore

Loads the given keys. This is a batch load operation so that implementation can optimize the multiple loads.

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.

Specified by:

loadAll in interface QueueStore<T>

Parameters:

keys - keys of the value entries to load

Returns:

map of loaded key-value pairs. May return null if no values loaded.

loadAllKeys

public Set<Long> loadAllKeys()

Description copied from interface: QueueStore

Loads all of the keys from the store.

The items identified by the keys will be loaded in the iteration order of the returned Set

Specified by:

loadAllKeys in interface QueueStore<T>

Returns:

all the keys from the store. May return null if no keys loaded.