Package org.apache.nifi.processors.standard.servlets

Class ListenHTTPServlet

java.lang.Object

jakarta.servlet.GenericServlet

jakarta.servlet.http.HttpServlet

org.apache.nifi.processors.standard.servlets.ListenHTTPServlet

All Implemented Interfaces:

jakarta.servlet.Servlet, jakarta.servlet.ServletConfig, Serializable

@Path("")
public class ListenHTTPServlet
extends jakarta.servlet.http.HttpServlet

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACCEPT_ENCODING_NAME
static final String	ACCEPT_ENCODING_VALUE
static final String	ACCEPT_HEADER_NAME
static final String	ACCEPT_HEADER_VALUE
private Pattern	authorizedIssuerPattern
private Pattern	authorizedPattern
private String	basePath
protected static final String	CONTENT_ENCODING_HEADER
static final String	DEFAULT_FOUND_ISSUER
static final String	DEFAULT_FOUND_SUBJECT
static final int	FILES_BEFORE_CHECKING_DESTINATION_SPACE
private final AtomicLong	filesReceived
static final String	FLOWFILE_CONFIRMATION_HEADER
private ConcurrentMap<String,ListenHTTP.FlowFileEntryTimeWrapper>	flowFileMap
static final String	GZIPPED_HEADER
private Pattern	headerPattern
static final String	LOCATION_HEADER_NAME
static final String	LOCATION_URI_INTENT_NAME
static final String	LOCATION_URI_INTENT_VALUE
private org.apache.nifi.logging.ComponentLog	logger
private int	multipartReadBufferSize
private long	multipartRequestMaxSize
private int	port
private org.apache.nifi.processor.ProcessContext	processContext
static final String	PROTOCOL_VERSION
static final String	PROTOCOL_VERSION_HEADER
private RecordReaderFactory	readerFactory
private int	returnCode
private static final long	serialVersionUID
private AtomicReference<org.apache.nifi.processor.ProcessSessionFactory>	sessionFactoryHolder
private final AtomicBoolean	spaceAvailable
private RecordSetWriterFactory	writerFactory

Fields inherited from class jakarta.servlet.http.HttpServlet

LEGACY_DO_HEAD

Constructor Summary

Constructors

Constructor	Description
ListenHTTPServlet()

Method Summary

Modifier and Type	Method	Description
private void	addMatchingRequestHeaders(jakarta.servlet.http.HttpServletRequest request, Map<String,String> attributes)
private void	deleteMultiPartFiles(jakarta.servlet.http.HttpServletRequest request)
void	doHead(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response)
void	doPost(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response)
private FlowFileUnpackager	getFlowFileUnpackager(String contentType)
private void	handleException(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response, org.apache.nifi.processor.ProcessSession session, String foundSubject, String foundIssuer, Throwable t)
private Set<org.apache.nifi.flowfile.FlowFile>	handleMultipartRequest(jakarta.servlet.http.HttpServletRequest request, org.apache.nifi.processor.ProcessSession session, String foundSubject, String foundIssuer)
private Set<org.apache.nifi.flowfile.FlowFile>	handleRequest(jakarta.servlet.http.HttpServletRequest request, org.apache.nifi.processor.ProcessSession session, String foundSubject, String foundIssuer, boolean destinationIsLegacyNiFi, String contentType, InputStream in)
void	init(jakarta.servlet.ServletConfig config)
private boolean	isRecordProcessing()
protected void	proceedFlow(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response, org.apache.nifi.processor.ProcessSession session, String foundSubject, String foundIssuer, boolean createHold, Set<org.apache.nifi.flowfile.FlowFile> flowFileSet)
private void	processRecord(InputStream in, org.apache.nifi.flowfile.FlowFile flowFile, OutputStream out)
private void	putAttribute(Map<String,String> map, String key, Object value)
private void	putAttribute(Map<String,String> map, String key, String value)
private org.apache.nifi.flowfile.FlowFile	savePartDetailsAsAttributes(org.apache.nifi.processor.ProcessSession session, jakarta.servlet.http.Part part, org.apache.nifi.flowfile.FlowFile flowFile, int sequenceNumber, int allPartsCount)
protected org.apache.nifi.flowfile.FlowFile	saveRequestDetailsAsAttributes(jakarta.servlet.http.HttpServletRequest request, org.apache.nifi.processor.ProcessSession session, String foundSubject, String foundIssuer, org.apache.nifi.flowfile.FlowFile flowFile)
void	setPort(int port)

Methods inherited from class jakarta.servlet.http.HttpServlet

doDelete, doGet, doOptions, doPatch, doPut, doTrace, getLastModified, isSensitiveHeader, service, service

Methods inherited from class jakarta.servlet.GenericServlet

destroy, getInitParameter, getInitParameterNames, getServletConfig, getServletContext, getServletInfo, getServletName, init, log, log

Methods inherited from class java.lang.Object

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

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

FLOWFILE_CONFIRMATION_HEADER

public static final String FLOWFILE_CONFIRMATION_HEADER

See Also:

• Constant Field Values

LOCATION_HEADER_NAME

public static final String LOCATION_HEADER_NAME

See Also:

• Constant Field Values

DEFAULT_FOUND_SUBJECT

public static final String DEFAULT_FOUND_SUBJECT

See Also:

• Constant Field Values

DEFAULT_FOUND_ISSUER

public static final String DEFAULT_FOUND_ISSUER

See Also:

• Constant Field Values

LOCATION_URI_INTENT_NAME

public static final String LOCATION_URI_INTENT_NAME

See Also:

• Constant Field Values

LOCATION_URI_INTENT_VALUE

public static final String LOCATION_URI_INTENT_VALUE

See Also:

• Constant Field Values

FILES_BEFORE_CHECKING_DESTINATION_SPACE

public static final int FILES_BEFORE_CHECKING_DESTINATION_SPACE

See Also:

• Constant Field Values

ACCEPT_HEADER_NAME

public static final String ACCEPT_HEADER_NAME

See Also:

• Constant Field Values

ACCEPT_HEADER_VALUE

public static final String ACCEPT_HEADER_VALUE

ACCEPT_ENCODING_NAME

public static final String ACCEPT_ENCODING_NAME

See Also:

• Constant Field Values

ACCEPT_ENCODING_VALUE

public static final String ACCEPT_ENCODING_VALUE

See Also:

• Constant Field Values

GZIPPED_HEADER

public static final String GZIPPED_HEADER

See Also:

• Constant Field Values

PROTOCOL_VERSION_HEADER

public static final String PROTOCOL_VERSION_HEADER

See Also:

• Constant Field Values

PROTOCOL_VERSION

public static final String PROTOCOL_VERSION

See Also:

• Constant Field Values

CONTENT_ENCODING_HEADER

protected static final String CONTENT_ENCODING_HEADER

See Also:

• Constant Field Values

filesReceived

private final AtomicLong filesReceived

spaceAvailable

private final AtomicBoolean spaceAvailable

logger

private org.apache.nifi.logging.ComponentLog logger

sessionFactoryHolder

private AtomicReference<org.apache.nifi.processor.ProcessSessionFactory> sessionFactoryHolder

processContext

private volatile org.apache.nifi.processor.ProcessContext processContext

authorizedPattern

private Pattern authorizedPattern

authorizedIssuerPattern

private Pattern authorizedIssuerPattern

headerPattern

private Pattern headerPattern

flowFileMap

private ConcurrentMap<String,ListenHTTP.FlowFileEntryTimeWrapper> flowFileMap

basePath

private String basePath

returnCode

private int returnCode

multipartRequestMaxSize

private long multipartRequestMaxSize

multipartReadBufferSize

private int multipartReadBufferSize

port

private int port

readerFactory

private RecordReaderFactory readerFactory

writerFactory

private RecordSetWriterFactory writerFactory

Constructor Details

ListenHTTPServlet

public ListenHTTPServlet()

Method Details

init

public void init(jakarta.servlet.ServletConfig config)
          throws jakarta.servlet.ServletException

Specified by:

init in interface jakarta.servlet.Servlet

Overrides:

init in class jakarta.servlet.http.HttpServlet

Throws:

jakarta.servlet.ServletException

setPort

public void setPort(int port)

doHead

public void doHead(jakarta.servlet.http.HttpServletRequest request,
 jakarta.servlet.http.HttpServletResponse response)
            throws jakarta.servlet.ServletException,
IOException

Overrides:

doHead in class jakarta.servlet.http.HttpServlet

Throws:

jakarta.servlet.ServletException

IOException

doPost

public void doPost(jakarta.servlet.http.HttpServletRequest request,
 jakarta.servlet.http.HttpServletResponse response)
            throws jakarta.servlet.ServletException,
IOException

Overrides:

doPost in class jakarta.servlet.http.HttpServlet

Throws:

jakarta.servlet.ServletException

IOException

deleteMultiPartFiles

private void deleteMultiPartFiles(jakarta.servlet.http.HttpServletRequest request)

handleException

private void handleException(jakarta.servlet.http.HttpServletRequest request,
 jakarta.servlet.http.HttpServletResponse response,
 org.apache.nifi.processor.ProcessSession session,
 String foundSubject,
 String foundIssuer,
 Throwable t)
                      throws IOException

Throws:

IOException

handleMultipartRequest

private Set<org.apache.nifi.flowfile.FlowFile> handleMultipartRequest(jakarta.servlet.http.HttpServletRequest request,
 org.apache.nifi.processor.ProcessSession session,
 String foundSubject,
 String foundIssuer)
                                                               throws IOException,
IllegalStateException,
jakarta.servlet.ServletException

Throws:

IOException

IllegalStateException

jakarta.servlet.ServletException

savePartDetailsAsAttributes

private org.apache.nifi.flowfile.FlowFile savePartDetailsAsAttributes(org.apache.nifi.processor.ProcessSession session,
 jakarta.servlet.http.Part part,
 org.apache.nifi.flowfile.FlowFile flowFile,
 int sequenceNumber,
 int allPartsCount)

handleRequest

private Set<org.apache.nifi.flowfile.FlowFile> handleRequest(jakarta.servlet.http.HttpServletRequest request,
 org.apache.nifi.processor.ProcessSession session,
 String foundSubject,
 String foundIssuer,
 boolean destinationIsLegacyNiFi,
 String contentType,
 InputStream in)
                                                      throws IOException

Throws:

IOException

proceedFlow

protected void proceedFlow(jakarta.servlet.http.HttpServletRequest request,
 jakarta.servlet.http.HttpServletResponse response,
 org.apache.nifi.processor.ProcessSession session,
 String foundSubject,
 String foundIssuer,
 boolean createHold,
 Set<org.apache.nifi.flowfile.FlowFile> flowFileSet)
                    throws IOException

Throws:

IOException

saveRequestDetailsAsAttributes

protected org.apache.nifi.flowfile.FlowFile saveRequestDetailsAsAttributes(jakarta.servlet.http.HttpServletRequest request,
 org.apache.nifi.processor.ProcessSession session,
 String foundSubject,
 String foundIssuer,
 org.apache.nifi.flowfile.FlowFile flowFile)

processRecord

private void processRecord(InputStream in,
 org.apache.nifi.flowfile.FlowFile flowFile,
 OutputStream out)

getFlowFileUnpackager

private FlowFileUnpackager getFlowFileUnpackager(String contentType)

addMatchingRequestHeaders

private void addMatchingRequestHeaders(jakarta.servlet.http.HttpServletRequest request,
 Map<String,String> attributes)

putAttribute

private void putAttribute(Map<String,String> map,
 String key,
 Object value)

putAttribute

private void putAttribute(Map<String,String> map,
 String key,
 String value)

isRecordProcessing

private boolean isRecordProcessing()