public final class ReplicationManager
extends com.streamscape.sef.dispatcher.AbstractReplicationManager
Title: Dataspace Framework
Description: Replication Manager implementation
Copyright: Copyright (c) 2012
Company: StreamScape Technologies
Modifier and Type | Class and Description |
---|---|
static class |
ReplicationManager.AttachToSourceMonitorAction |
static class |
ReplicationManager.CheckSourceReplicasAction |
static class |
ReplicationManager.CleanupReplicationQueue |
static class |
ReplicationManager.SendReplicaStateChangeAction |
static class |
ReplicationManager.SendSourceUpdatedForPairedReplicasAction |
static interface |
ReplicationManager.TargetsSourceMonitorAction |
Constructor and Description |
---|
ReplicationManager(com.streamscape.ds.AbstractDataspace dataspace) |
Modifier and Type | Method and Description |
---|---|
void |
close(com.streamscape.ds.session.Session session) |
ImmutableEventDatagram |
onRequest(ImmutableEventDatagram event)
Processes the specified event and returns a reply.
|
void |
open(com.streamscape.ds.session.Session session) |
ReplicationResponse |
sendReplicationManagementRequest(ReplicationRequest request,
ReplicationEntityName to) |
ReplicationResponse |
sendReplicationManagementRequest(ReplicationRequest request,
ReplicationEntityName to,
long timeout) |
static ReplicationResponse |
sendReplicationManagementRequestGlobal(ReplicationRequest request,
ReplicationEntityName to) |
static ReplicationResponse |
sendReplicationManagementRequestGlobal(ReplicationRequest request,
ReplicationEntityName to,
long timeout) |
public ReplicationManager(com.streamscape.ds.AbstractDataspace dataspace)
public void open(com.streamscape.ds.session.Session session)
open
in class com.streamscape.sef.dispatcher.AbstractReplicationManager
public void close(com.streamscape.ds.session.Session session)
close
in class com.streamscape.sef.dispatcher.AbstractReplicationManager
public ImmutableEventDatagram onRequest(ImmutableEventDatagram event) throws FabricRequestException
FabricRequestListener
event
- the event to be processed.FabricRequestException
- if some error occurs during processing.public ReplicationResponse sendReplicationManagementRequest(ReplicationRequest request, ReplicationEntityName to)
public ReplicationResponse sendReplicationManagementRequest(ReplicationRequest request, ReplicationEntityName to, long timeout)
sendReplicationManagementRequest
in class com.streamscape.sef.dispatcher.AbstractReplicationManager
public static ReplicationResponse sendReplicationManagementRequestGlobal(ReplicationRequest request, ReplicationEntityName to) throws ReplicationException
ReplicationException
public static ReplicationResponse sendReplicationManagementRequestGlobal(ReplicationRequest request, ReplicationEntityName to, long timeout) throws ReplicationException
ReplicationException
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.