com.hazelcast.wan

Interface WanReplicationPublisher

All Known Subinterfaces:

WanReplicationEndpoint

public interface WanReplicationPublisher

This interface offers the implementation of different kinds of replication techniques like TCP, UDP or maybe even an JMS based service

Method Summary

Modifier and Type	Method and Description
void	checkWanReplicationQueues() Check the capacity of the WAN replication queues.
void	publishReplicationEvent(String serviceName, ReplicationEventObject eventObject) Publish the eventObject WAN replication event.
void	publishReplicationEvent(WanReplicationEvent wanReplicationEvent)
void	publishReplicationEventBackup(String serviceName, ReplicationEventObject eventObject) Publish the eventObject WAN replication event backup.

Method Detail

publishReplicationEvent

void publishReplicationEvent(String serviceName,
                             ReplicationEventObject eventObject)

Publish the eventObject WAN replication event. The event may be dropped if queue capacity has been reached.

Parameters:

serviceName - the service publishing the event

eventObject - the replication event

publishReplicationEventBackup

void publishReplicationEventBackup(String serviceName,
                                   ReplicationEventObject eventObject)

Publish the eventObject WAN replication event backup. The event may be dropped if queue capacity has been reached.

Parameters:

serviceName - the service publishing the event

eventObject - the replication backup event

publishReplicationEvent

void publishReplicationEvent(WanReplicationEvent wanReplicationEvent)

checkWanReplicationQueues

void checkWanReplicationQueues()

Check the capacity of the WAN replication queues.

Throws:

WANReplicationQueueFullException - if queue capacity has been reached and WanPublisherConfig.getQueueFullBehavior() is set to WANQueueFullBehavior.THROW_EXCEPTION