public class WanPublisherConfig extends Object implements IdentifiedDataSerializable
DiscoveryConfig
,
AwsConfig
Constructor and Description |
---|
WanPublisherConfig() |
Modifier and Type | Method and Description |
---|---|
AwsConfig |
getAwsConfig() |
String |
getClassName() |
DiscoveryConfig |
getDiscoveryConfig()
Returns the currently defined
DiscoveryConfig |
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
String |
getGroupName()
Return the group name of this publisher.
|
int |
getId()
Returns type identifier for this class.
|
Object |
getImplementation() |
Map<String,Comparable> |
getProperties() |
int |
getQueueCapacity()
Get the capacity of the queue for WAN replication events.
|
WANQueueFullBehavior |
getQueueFullBehavior() |
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
WanPublisherConfig |
setAwsConfig(AwsConfig awsConfig) |
WanPublisherConfig |
setClassName(String className)
Set the name of the class implementing the WanReplicationEndpoint.
|
WanPublisherConfig |
setDiscoveryConfig(DiscoveryConfig discoveryConfig)
Sets a custom defined
DiscoveryConfig |
WanPublisherConfig |
setGroupName(String groupName)
Set the group name of this publisher.
|
WanPublisherConfig |
setImplementation(Object implementation)
Set the implementation of the WanReplicationEndpoint.
|
WanPublisherConfig |
setProperties(Map<String,Comparable> properties) |
WanPublisherConfig |
setQueueCapacity(int queueCapacity)
Set the capacity of the queue for WAN replication events.
|
WanPublisherConfig |
setQueueFullBehavior(WANQueueFullBehavior queueFullBehavior) |
String |
toString() |
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
public String getGroupName()
WanReplicationConfig
and for authentication on the target endpoint.public WanPublisherConfig setGroupName(String groupName)
WanReplicationConfig
and for authentication on the target endpoint.groupName
- the publisher group namepublic int getQueueCapacity()
getQueueFullBehavior()
.
The default queue size for replication queues is .public WanPublisherConfig setQueueCapacity(int queueCapacity)
getQueueFullBehavior()
.
The default queue size for replication queues is .queueCapacity
- the queue capacitypublic WANQueueFullBehavior getQueueFullBehavior()
public WanPublisherConfig setQueueFullBehavior(WANQueueFullBehavior queueFullBehavior)
public Map<String,Comparable> getProperties()
public WanPublisherConfig setProperties(Map<String,Comparable> properties)
public String getClassName()
public WanPublisherConfig setClassName(String className)
WanReplicationEndpoint
.className
- the name of the class implementation for the WAN replicationpublic Object getImplementation()
public WanPublisherConfig setImplementation(Object implementation)
WanReplicationEndpoint
.implementation
- the implementation for the WAN replicationpublic AwsConfig getAwsConfig()
public WanPublisherConfig setAwsConfig(AwsConfig awsConfig)
awsConfig
- the AwsConfig join configuration to setIllegalArgumentException
- if awsConfig is nullpublic DiscoveryConfig getDiscoveryConfig()
DiscoveryConfig
public WanPublisherConfig setDiscoveryConfig(DiscoveryConfig discoveryConfig)
DiscoveryConfig
discoveryConfig
- configuration to setIllegalArgumentException
- if discoveryProvidersConfig is nullpublic 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 © 2018 Hazelcast, Inc.. All rights reserved.