public interface WanReplicationPublisher
HazelcastInstanceAware
if it needs a reference to the instance on which it is being run.Modifier and Type | Method and Description |
---|---|
void |
doPrepublicationChecks()
Performs pre-publication checks (e.g.
|
void |
init(WanReplicationConfig wanReplicationConfig,
AbstractWanPublisherConfig publisherConfig)
Initializes the publisher.
|
void |
publishReplicationEvent(WanReplicationEvent eventObject)
Publish the
eventObject WAN replication event. |
void |
publishReplicationEventBackup(WanReplicationEvent eventObject)
Publish the
eventObject WAN replication event backup. |
default void |
reset()
Resets the publisher (e.g.
|
void |
shutdown()
Closes the publisher and its internal connections and shuts down other internal states.
|
void init(WanReplicationConfig wanReplicationConfig, AbstractWanPublisherConfig publisherConfig)
wanReplicationConfig
- WanReplicationConfig
instancepublisherConfig
- AbstractWanPublisherConfig
instancevoid shutdown()
default void reset()
void doPrepublicationChecks()
publishReplicationEvent(WanReplicationEvent)
and publishReplicationEventBackup(WanReplicationEvent)
.void publishReplicationEvent(WanReplicationEvent eventObject)
eventObject
WAN replication event.eventObject
- the replication eventvoid publishReplicationEventBackup(WanReplicationEvent eventObject)
eventObject
WAN replication event backup.eventObject
- the replication backup eventCopyright © 2019 Hazelcast, Inc.. All rights reserved.