public abstract class AbstractReplicationEntity
extends java.lang.Object
Title: Dataspace Framework
Description: Replication Trigger implementation
Copyright: Copyright (c) 2012
Company: StreamScape Technologies
Constructor and Description |
---|
AbstractReplicationEntity(DataspaceStore store,
java.lang.String schemaName) |
AbstractReplicationEntity(DataspaceStore store,
java.lang.String schemaName,
Collection collection) |
Modifier and Type | Method and Description |
---|---|
void |
addTrigger(com.streamscape.ds.trigger.ReplicationEventTrigger trigger) |
void |
enqueueMonitorAction(ReplicationManager.TargetsSourceMonitorAction action) |
Collection |
getCollection() |
com.streamscape.ds.AbstractDataspace |
getDataspace() |
abstract java.lang.String |
getName() |
abstract NameManager.ObjectName |
getObjectName() |
com.streamscape.ds.trigger.ReplicationEventTrigger |
getTrigger(java.lang.String name)
Returns a trigger by specified name.
|
java.util.List |
listFailTriggerNames() |
java.util.List |
listRollbackTriggerNames() |
java.util.List |
listSuccessTriggerNames() |
void |
onReplicationFail(com.streamscape.ds.session.Session session,
ReplicationData replicationData,
java.lang.Throwable exception) |
void |
onReplicationFail(com.streamscape.ds.session.Session session,
ReplicationDataTransaction transaction,
java.lang.Throwable exception) |
void |
onReplicationRollback(com.streamscape.ds.session.Session session,
ReplicationDataTransaction transaction,
java.lang.Throwable exception) |
void |
onReplicationSuccess(com.streamscape.ds.session.Session session,
ReplicationDataTransaction transaction) |
abstract boolean |
raiseReplicationException(java.lang.Throwable exception,
boolean withExpiration) |
void |
removeTrigger(com.streamscape.ds.trigger.ReplicationEventTrigger trigger) |
public AbstractReplicationEntity(DataspaceStore store, java.lang.String schemaName)
public AbstractReplicationEntity(DataspaceStore store, java.lang.String schemaName, Collection collection)
public abstract java.lang.String getName()
public void onReplicationSuccess(com.streamscape.ds.session.Session session, ReplicationDataTransaction transaction)
public void onReplicationFail(com.streamscape.ds.session.Session session, ReplicationDataTransaction transaction, java.lang.Throwable exception)
public void onReplicationFail(com.streamscape.ds.session.Session session, ReplicationData replicationData, java.lang.Throwable exception)
public void onReplicationRollback(com.streamscape.ds.session.Session session, ReplicationDataTransaction transaction, java.lang.Throwable exception)
public void addTrigger(com.streamscape.ds.trigger.ReplicationEventTrigger trigger)
public com.streamscape.ds.trigger.ReplicationEventTrigger getTrigger(java.lang.String name)
public void removeTrigger(com.streamscape.ds.trigger.ReplicationEventTrigger trigger)
public java.util.List listSuccessTriggerNames()
public java.util.List listFailTriggerNames()
public java.util.List listRollbackTriggerNames()
public Collection getCollection()
public abstract NameManager.ObjectName getObjectName()
public com.streamscape.ds.AbstractDataspace getDataspace()
public void enqueueMonitorAction(ReplicationManager.TargetsSourceMonitorAction action)
public abstract boolean raiseReplicationException(java.lang.Throwable exception, boolean withExpiration)
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.