com.hazelcast.enterprise.wan.operation

Class AddWanConfigOperationFactory

java.lang.Object

com.hazelcast.enterprise.wan.operation.AddWanConfigOperationFactory

All Implemented Interfaces:

com.hazelcast.nio.serialization.DataSerializable, com.hazelcast.nio.serialization.IdentifiedDataSerializable, com.hazelcast.spi.OperationFactory

public class AddWanConfigOperationFactory
extends Object
implements com.hazelcast.spi.OperationFactory

Factory to create partition operations to add a new WAN replication config. The operations are run on partitions to achieve ordering with other partition operations (map and cache mutation) and to avoid a whole class of race conditions due to map and cache mutation filling WAN queues concurrently with new config and queues being added.

Constructor Summary

Constructors

Constructor and Description
AddWanConfigOperationFactory()
AddWanConfigOperationFactory(com.hazelcast.config.WanReplicationConfig wanConfig)

Method Summary

Modifier and Type	Method and Description
com.hazelcast.spi.Operation	createOperation()
int	getFactoryId()
int	getId()
void	readData(com.hazelcast.nio.ObjectDataInput in)
void	writeData(com.hazelcast.nio.ObjectDataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

AddWanConfigOperationFactory

public AddWanConfigOperationFactory()

AddWanConfigOperationFactory

public AddWanConfigOperationFactory(com.hazelcast.config.WanReplicationConfig wanConfig)

Method Detail

createOperation

public com.hazelcast.spi.Operation createOperation()

Specified by:

createOperation in interface com.hazelcast.spi.OperationFactory

getFactoryId

public int getFactoryId()

Specified by:

getFactoryId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getId

public int getId()

Specified by:

getId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

writeData

public void writeData(com.hazelcast.nio.ObjectDataOutput out)
               throws IOException

Specified by:

writeData in interface com.hazelcast.nio.serialization.DataSerializable

Throws:

IOException

readData

public void readData(com.hazelcast.nio.ObjectDataInput in)
              throws IOException

Specified by:

readData in interface com.hazelcast.nio.serialization.DataSerializable

Throws:

IOException