Package com.floragunn.searchguard.ssl.transport

Class SearchGuardSSLRequestHandler<T extends org.elasticsearch.transport.TransportRequest>

java.lang.Object

com.floragunn.searchguard.ssl.transport.SearchGuardSSLRequestHandler<T>

All Implemented Interfaces:

org.elasticsearch.transport.TransportRequestHandler<T>

Direct Known Subclasses:

SearchGuardRequestHandler

public class SearchGuardSSLRequestHandler<T extends org.elasticsearch.transport.TransportRequest>
extends Object
implements org.elasticsearch.transport.TransportRequestHandler<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
SearchGuardSSLRequestHandler(String action, org.elasticsearch.transport.TransportRequestHandler<T> actualHandler, org.elasticsearch.threadpool.ThreadPool threadPool, PrincipalExtractor principalExtractor, SslExceptionHandler errorHandler)

Method Summary

Modifier and Type	Method	Description
protected void	addAdditionalContextValues(String action, org.elasticsearch.transport.TransportRequest request, X509Certificate[] localCerts, X509Certificate[] peerCerts, String principal)
protected org.elasticsearch.common.util.concurrent.ThreadContext	getThreadContext()
void	messageReceived(T request, org.elasticsearch.transport.TransportChannel channel, org.elasticsearch.tasks.Task task)
protected void	messageReceivedDecorate(T request, org.elasticsearch.transport.TransportRequestHandler<T> actualHandler, org.elasticsearch.transport.TransportChannel transportChannel, org.elasticsearch.tasks.Task task)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.apache.logging.log4j.Logger log

Constructor Detail

SearchGuardSSLRequestHandler

public SearchGuardSSLRequestHandler(String action,
                                    org.elasticsearch.transport.TransportRequestHandler<T> actualHandler,
                                    org.elasticsearch.threadpool.ThreadPool threadPool,
                                    PrincipalExtractor principalExtractor,
                                    SslExceptionHandler errorHandler)

Method Detail

getThreadContext

protected org.elasticsearch.common.util.concurrent.ThreadContext getThreadContext()

messageReceived

public final void messageReceived(T request,
                                  org.elasticsearch.transport.TransportChannel channel,
                                  org.elasticsearch.tasks.Task task)
                           throws Exception

Specified by:

messageReceived in interface org.elasticsearch.transport.TransportRequestHandler<T extends org.elasticsearch.transport.TransportRequest>

Throws:

Exception

addAdditionalContextValues

protected void addAdditionalContextValues(String action,
                                          org.elasticsearch.transport.TransportRequest request,
                                          X509Certificate[] localCerts,
                                          X509Certificate[] peerCerts,
                                          String principal)
                                   throws Exception

Throws:

Exception

messageReceivedDecorate

protected void messageReceivedDecorate(T request,
                                       org.elasticsearch.transport.TransportRequestHandler<T> actualHandler,
                                       org.elasticsearch.transport.TransportChannel transportChannel,
                                       org.elasticsearch.tasks.Task task)
                                throws Exception

Throws:

Exception