in zuul-core/src/main/java/com/netflix/netty/common/throttle/RejectionUtils.java [261:291]
public static void reject(
ChannelHandlerContext ctx,
RejectionType rejectionType,
StatusCategory nfStatus,
String reason,
HttpRequest request,
@Nullable Integer injectedLatencyMillis,
HttpResponseStatus rejectedCode,
String rejectedBody,
Map<String, String> rejectionHeaders) {
switch (rejectionType) {
case REJECT:
sendRejectionResponse(
ctx,
nfStatus,
reason,
request,
injectedLatencyMillis,
rejectedCode,
rejectedBody,
rejectionHeaders);
return;
case CLOSE:
rejectByClosingConnection(ctx, nfStatus, reason, request, injectedLatencyMillis);
return;
case ALLOW_THEN_CLOSE:
allowThenClose(ctx);
return;
}
throw new AssertionError("Bad rejection type: " + rejectionType);
}