com.bigdata.ha.pipeline

Class PipelineDownstreamChange

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.AbstractPipelineChangeException

com.bigdata.ha.pipeline.PipelineDownstreamChange

All Implemented Interfaces:

Serializable

public class PipelineDownstreamChange
extends AbstractPipelineChangeException

Exception thrown when the downstream service is changed by a pipeline reconfiguration. This exception was introduced so retrySend() in QuorumPipelineImpl could differentiate between normal termination of a service (which will interrupt the HAReceiveService and thus propagate a CancellationException to the upstream service) and a pipeline change which requires retrySend() to retransmit the message and payload from the leader along the reconfigured write pipeline.

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PipelineDownstreamChange()
PipelineDownstreamChange(String message)
PipelineDownstreamChange(String message, Throwable cause)
PipelineDownstreamChange(Throwable cause)

Method Summary

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

PipelineDownstreamChange

public PipelineDownstreamChange()

PipelineDownstreamChange

public PipelineDownstreamChange(String message)

PipelineDownstreamChange

public PipelineDownstreamChange(Throwable cause)

PipelineDownstreamChange

public PipelineDownstreamChange(String message,
                        Throwable cause)