Package com.linkedin.alpini.router

Class ScatterGatherRequestHandler<H,P extends ResourcePath<K>,K,R>

java.lang.Object

com.linkedin.alpini.router.ScatterGatherRequestHandler<H,P,K,R>

Direct Known Subclasses:

ScatterGatherRequestHandlerImpl

public abstract class ScatterGatherRequestHandler<H,P extends ResourcePath<K>,K,R>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final RouterTimeoutProcessor	_timeoutProcessor
protected static final org.apache.logging.log4j.Logger	LOG
protected static final Runnable	NOP

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ScatterGatherRequestHandler(TimeoutProcessor timeoutProcessor)
protected	ScatterGatherRequestHandler(RouterTimeoutProcessor timeoutProcessor)

Method Summary

Modifier and Type	Method	Description
abstract ScatterGatherHelper<H,P,K,R,?,?,?>	getScatterGatherHelper()
protected abstract boolean	isTooLongFrameException(Throwable cause)
static <H, P extends ResourcePath<K>, K, R> ScatterGatherRequestHandler<H,P,K,R>	make(ScatterGatherHelper<H,P,K,R,?,?,?> scatterGatherHelper, TimeoutProcessor timeoutProcessor, Executor executor)
static <H, P extends ResourcePath<K>, K, R> ScatterGatherRequestHandler<H,P,K,R>	make(ScatterGatherHelper<H,P,K,R,?,?,?> scatterGatherHelper, RouterTimeoutProcessor timeoutProcessor, Executor executor)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.apache.logging.log4j.Logger LOG

NOP

protected static final Runnable NOP

_timeoutProcessor

@Nonnull
protected final RouterTimeoutProcessor _timeoutProcessor

Constructor Details

ScatterGatherRequestHandler

protected ScatterGatherRequestHandler(@Nonnull
 RouterTimeoutProcessor timeoutProcessor)

ScatterGatherRequestHandler

protected ScatterGatherRequestHandler(@Nonnull
 TimeoutProcessor timeoutProcessor)

Method Details

make

public static <H,
P extends ResourcePath<K>,
K,
R>
ScatterGatherRequestHandler<H,P,K,R> make(@Nonnull
 ScatterGatherHelper<H,P,K,R,?,?,?> scatterGatherHelper,
 @Nonnull
 TimeoutProcessor timeoutProcessor,
 @Nonnull
 Executor executor)

make

public static <H,
P extends ResourcePath<K>,
K,
R>
ScatterGatherRequestHandler<H,P,K,R> make(@Nonnull
 ScatterGatherHelper<H,P,K,R,?,?,?> scatterGatherHelper,
 @Nonnull
 RouterTimeoutProcessor timeoutProcessor,
 @Nonnull
 Executor executor)

getScatterGatherHelper

@Nonnull
public abstract ScatterGatherHelper<H,P,K,R,?,?,?> getScatterGatherHelper()

isTooLongFrameException

protected abstract boolean isTooLongFrameException(Throwable cause)