public class WanConsumerConfig extends Object implements IdentifiedDataSerializable, Versioned
NOTE: EE only
Modifier and Type | Field and Description |
---|---|
static boolean |
DEFAULT_PERSIST_WAN_REPLICATED_DATA |
Constructor and Description |
---|
WanConsumerConfig() |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
String |
getClassName()
Returns the fully qualified class name of the class implementing
WanReplicationConsumer.
|
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
Object |
getImplementation()
Returns the implementation implementing WanReplicationConsumer.
|
Map<String,Comparable> |
getProperties()
Returns the properties for the custom WAN consumer.
|
int |
hashCode() |
boolean |
isPersistWanReplicatedData() |
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
WanConsumerConfig |
setClassName(String className)
Sets the fully qualified class name of the class implementing
WanReplicationConsumer.
|
WanConsumerConfig |
setImplementation(Object implementation)
Sets the implementation for this WAN consumer.
|
WanConsumerConfig |
setPersistWanReplicatedData(boolean persistWanReplicatedData) |
WanConsumerConfig |
setProperties(Map<String,Comparable> properties)
Sets the properties for the custom WAN consumer.
|
String |
toString() |
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
public static final boolean DEFAULT_PERSIST_WAN_REPLICATED_DATA
public Map<String,Comparable> getProperties()
public WanConsumerConfig setProperties(Map<String,Comparable> properties)
properties
- the properties for the WAN consumerpublic String getClassName()
public WanConsumerConfig setClassName(String className)
null
in which case the implementation or
the default processing logic for incoming WAN events will be used.className
- fully qualified class namesetImplementation(Object)
public Object getImplementation()
public WanConsumerConfig setImplementation(Object implementation)
null
in which case the class name or
the default processing logic for incoming WAN events will be used.implementation
- the object implementing WanReplicationConsumersetClassName(String)
public boolean isPersistWanReplicatedData()
true
when persistence of replicated data into backing
store is enabled, otherwise returns false
. By default this
method returns false.public WanConsumerConfig setPersistWanReplicatedData(boolean persistWanReplicatedData)
persistWanReplicatedData
- set true
to enable
persistence of replicated data into backing store, otherwise set
false
to disable it. Default value is false.WanReplicationRef
objectpublic int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
public int getId()
IdentifiedDataSerializable
getId
in interface IdentifiedDataSerializable
public void writeData(ObjectDataOutput out) throws IOException
DataSerializable
writeData
in interface DataSerializable
out
- 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
DataSerializable
readData
in interface DataSerializable
in
- inputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
input stream has been closed.Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.