public class QueueStoreConfig extends Object implements IdentifiedDataSerializable
QueueStore.| Modifier and Type | Field and Description | 
|---|---|
static int | 
DEFAULT_BULK_LOAD
The default size of batches in which the queue will be loaded from the
 queue store. 
 | 
static int | 
DEFAULT_MEMORY_LIMIT
The default number of queue item values to keep in memory. 
 | 
static String | 
STORE_BINARY
Binary: By default, Hazelcast stores the queue items in serialized form in memory. 
 | 
static String | 
STORE_BULK_LOAD
Bulk Load: When the queue is initialized, items are loaded from QueueStore in bulks. 
 | 
static String | 
STORE_MEMORY_LIMIT
Memory Limit: This is the number of items after which Hazelcast will store items only to
 datastore. 
 | 
| Constructor and Description | 
|---|
QueueStoreConfig()  | 
QueueStoreConfig(QueueStoreConfig config)  | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
equals(Object o)  | 
int | 
getClassId()
Returns type identifier for this class. 
 | 
String | 
getClassName()
Returns the class name of the queue store implementation to be used when
 instantiating the queue store. 
 | 
String | 
getFactoryClassName()
Returns the factory class name which will be used to instantiate the queue
 store. 
 | 
int | 
getFactoryId()
Returns DataSerializableFactory factory ID for this class. 
 | 
QueueStoreFactory | 
getFactoryImplementation()
Returns the queue store factory implementation which will be used to
 instantiate the queue store. 
 | 
Properties | 
getProperties()
Returns the properties to be used when instantiating the queue store. 
 | 
String | 
getProperty(String name)
Returns the property with the given  
name which is used when
 instantiating and interacting with the queue store. | 
QueueStore | 
getStoreImplementation()
Returns the implementation of the queue store which will be used to store
 queue items. 
 | 
int | 
hashCode()  | 
boolean | 
isEnabled()
Returns  
true if the queue store is enabled, false
 otherwise. | 
void | 
readData(ObjectDataInput in)
Reads fields from the input stream 
 | 
QueueStoreConfig | 
setClassName(String className)
Sets the class name of the queue store implementation to be used when
 instantiating the queue store. 
 | 
QueueStoreConfig | 
setEnabled(boolean enabled)
Enables or disables the queue store. 
 | 
QueueStoreConfig | 
setFactoryClassName(String factoryClassName)
Sets the factory class name which will be used to instantiate the queue
 store. 
 | 
QueueStoreConfig | 
setFactoryImplementation(QueueStoreFactory factoryImplementation)
Sets the queue store factory implementation which will be used to
 instantiate the queue store. 
 | 
QueueStoreConfig | 
setProperties(Properties properties)
Sets the properties to be used when instantiating the queue store. 
 | 
QueueStoreConfig | 
setProperty(String name,
           String value)
Sets a property to be used when instantiating the queue store. 
 | 
QueueStoreConfig | 
setStoreImplementation(QueueStore storeImplementation)
Sets the implementation of the queue store which will be used to store
 queue items. 
 | 
String | 
toString()  | 
void | 
writeData(ObjectDataOutput out)
Writes object fields to output stream 
 | 
public static final int DEFAULT_MEMORY_LIMIT
public static final int DEFAULT_BULK_LOAD
public static final String STORE_BINARY
public static final String STORE_MEMORY_LIMIT
public static final String STORE_BULK_LOAD
public QueueStoreConfig()
public QueueStoreConfig(QueueStoreConfig config)
@Nullable public QueueStore getStoreImplementation()
public QueueStoreConfig setStoreImplementation(@Nonnull QueueStore storeImplementation)
storeImplementation - the implementation to store queue itemsNullPointerException - if the provided implementation is nullpublic boolean isEnabled()
true if the queue store is enabled, false
 otherwise.public QueueStoreConfig setEnabled(boolean enabled)
enabled - true to enable the queue store, false to disable it@Nullable public String getClassName()
public QueueStoreConfig setClassName(@Nonnull String className)
QueueStore interface.className - the queue store class namepublic Properties getProperties()
STORE_MEMORY_LIMIT,
 STORE_BINARY and
 STORE_BULK_LOAD).public QueueStoreConfig setProperties(Properties properties)
STORE_MEMORY_LIMIT,
 STORE_BINARY and
 STORE_BULK_LOAD).properties - the properties to be used when instantiating the queue storepublic String getProperty(String name)
name which is used when
 instantiating and interacting with the queue store.name - the property namepublic QueueStoreConfig setProperty(String name, String value)
STORE_MEMORY_LIMIT,
 STORE_BINARY and
 STORE_BULK_LOAD).name - the property namevalue - the property value@Nullable public String getFactoryClassName()
QueueStoreFactory interface.public QueueStoreConfig setFactoryClassName(@Nonnull String factoryClassName)
QueueStoreFactory interface.factoryClassName - the queue store factory class name@Nullable public QueueStoreFactory getFactoryImplementation()
QueueStoreFactory interface.public QueueStoreConfig setFactoryImplementation(@Nonnull QueueStoreFactory factoryImplementation)
QueueStoreFactory interface.factoryImplementation - the queue store factory implementationpublic int getFactoryId()
IdentifiedDataSerializablegetFactoryId in interface IdentifiedDataSerializablepublic int getClassId()
IdentifiedDataSerializablegetClassId in interface IdentifiedDataSerializablepublic void writeData(ObjectDataOutput out) throws IOException
DataSerializablewriteData in interface DataSerializableout - outputIOException - if an I/O error occurs. In particular,
                     an IOException may be thrown if the
                     output stream has been closed.public void readData(ObjectDataInput in) throws IOException
DataSerializablereadData in interface DataSerializablein - inputIOException - if an I/O error occurs. In particular,
                     an IOException may be thrown if the
                     input stream has been closed.Copyright © 2023 Hazelcast, Inc.. All rights reserved.