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 java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected RouterTimeoutProcessor	_timeoutProcessor
protected static org.apache.logging.log4j.Logger	LOG
protected static java.lang.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(java.lang.Throwable cause)
static <H,P extends ResourcePath<K>,K,R> ScatterGatherRequestHandler<H,P,K,R>	make(ScatterGatherHelper<H,P,K,R,?,?,?> scatterGatherHelper, TimeoutProcessor timeoutProcessor, java.util.concurrent.Executor executor)
static <H,P extends ResourcePath<K>,K,R> ScatterGatherRequestHandler<H,P,K,R>	make(ScatterGatherHelper<H,P,K,R,?,?,?> scatterGatherHelper, RouterTimeoutProcessor timeoutProcessor, java.util.concurrent.Executor executor)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

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

NOP

protected static final java.lang.Runnable NOP

_timeoutProcessor

@Nonnull
protected final RouterTimeoutProcessor _timeoutProcessor

Constructor Detail

ScatterGatherRequestHandler

protected ScatterGatherRequestHandler(@Nonnull
                                      RouterTimeoutProcessor timeoutProcessor)

ScatterGatherRequestHandler

protected ScatterGatherRequestHandler(@Nonnull
                                      TimeoutProcessor timeoutProcessor)

Method Detail

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
                                                                                                                              java.util.concurrent.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
                                                                                                                              java.util.concurrent.Executor executor)

getScatterGatherHelper

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

isTooLongFrameException

protected abstract boolean isTooLongFrameException(java.lang.Throwable cause)