com.bigdata.ha.pipeline

Class PipelineUpstreamChange

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

All Implemented Interfaces:

Serializable

public class PipelineUpstreamChange
extends AbstractPipelineChangeException

Exception thrown when the upstream 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
PipelineUpstreamChange()
PipelineUpstreamChange(String message)
PipelineUpstreamChange(String message, Throwable cause)
PipelineUpstreamChange(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

PipelineUpstreamChange

public PipelineUpstreamChange()

PipelineUpstreamChange

public PipelineUpstreamChange(String message)

PipelineUpstreamChange

public PipelineUpstreamChange(Throwable cause)

PipelineUpstreamChange

public PipelineUpstreamChange(String message,
                      Throwable cause)