com.bigdata.ha.pipeline

Class PipelineImmediateDownstreamReplicationException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

com.bigdata.quorum.QuorumException

com.bigdata.ha.pipeline.AbstractPipelineException

com.bigdata.ha.pipeline.PipelineImmediateDownstreamReplicationException

All Implemented Interfaces:

Serializable

public class PipelineImmediateDownstreamReplicationException
extends AbstractPipelineException

Exception thrown when there is a problem with write replication from a service to its downstream service, including a problem with RMI to the downstream service or socket level write replication to the downstream service. This typed exception enables the leader is then able to take action intended to cure the pipeline by forcing the problem service from the quorum. The problem service can then attempt to re-enter the quorum.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PipelineImmediateDownstreamReplicationException(UUID serviceId, UUID[] priorAndNext, Throwable t)

Method Summary

Methods

Modifier and Type	Method and Description
UUID[]	getPriorAndNext() The prior and next service UUIDs for the service reporting the problem.
UUID	getProblemServiceId() Return the UUID of the downstream service - the problem is reported for the communication channel between the reporting service and this downstream service.
UUID	getReportingServiceId() Return the UUID of the service reporting the problem.

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

PipelineImmediateDownstreamReplicationException

public PipelineImmediateDownstreamReplicationException(UUID serviceId,
                                               UUID[] priorAndNext,
                                               Throwable t)

Parameters:

serviceId - The UUID of the service reporting a problem replicating writes to its downstream service.

priorAndNext - The prior and next service UUIDs for the service reporting the problem. The problem is with the communication to the "next" service.

t - The root cause exception.

Method Detail

getReportingServiceId

public UUID getReportingServiceId()

Return the UUID of the service reporting the problem. This is the service that attempted to replicate a payload to the downstream service and was unable to replicate the payload due to the reported root cause.

getPriorAndNext

public UUID[] getPriorAndNext()

The prior and next service UUIDs for the service reporting the problem. The problem is with the communication to the "next" service.

getProblemServiceId

public UUID getProblemServiceId()

Return the UUID of the downstream service - the problem is reported for the communication channel between the reporting service and this downstream service. The downstream service is the service that should be forced out of the quorum in order to "fix" the pipeline.