Package com.adaptris.core.http.jetty

Class BasicJettyConsumer

    • Constructor Detail

      • BasicJettyConsumer

        public BasicJettyConsumer()

    • Method Detail

      • servletPath

        protected java.lang.String servletPath()

      • validMethods

        protected java.lang.String validMethods()

      • createMessage

        public abstract AdaptrisMessage createMessage​(javax.servlet.http.HttpServletRequest request,
                                              javax.servlet.http.HttpServletResponse response)
                                       throws java.io.IOException,
                                              javax.servlet.ServletException
        Create an AdaptrisMessage from the incoming servlet request and response.
        Parameters:
        request - the HttpServletRequest
        response - the HttpServletResponse
        Returns:
        an AdaptrisMessage instance.
        Throws:
        java.io.IOException
        javax.servlet.ServletException
        See Also:
        HttpServlet.service(javax.servlet.ServletRequest, javax.servlet.ServletResponse)

      • logHeaders

        protected void logHeaders​(javax.servlet.http.HttpServletRequest req)

      • stop

        public void stop()
        Description copied from interface: ComponentLifecycle
        Stop the component

        A stopped component is not expected to be ready to process messages. In the case of AdaptrisMessageConsumer, calling stop will pause message delivery. Throwing a RuntimeException may cause unintended consequences

        See Also:
        ComponentLifecycle.stop()

      • close

        public void close()
        Description copied from interface: ComponentLifecycle
        Closes the component.

        A closed component should release any connections it uses, etc. and clean up completely. Throwing a RuntimeException may cause unintended consequences

        See Also:
        ComponentLifecycle.close()

      • setTimeoutAction

        public void setTimeoutAction​(TimeoutAction action)
        Set the behaviour that should occur when the workflow takes too long to finish.

        This setting only has an impact if the consumer is the entry point for a PoolingWorkflow instance. In the event that the wait time is exceeded, then the behaviour specified here is done.

        Parameters:
        action - the action; default is a 202 after 10 minutes.

      • getAdditionalDebug

        public java.lang.Boolean getAdditionalDebug()

      • setAdditionalDebug

        public void setAdditionalDebug​(java.lang.Boolean additionalDebug)

      • getWarnAfter

        public TimeInterval getWarnAfter()
        Returns:
        the warnAfter

      • setWarnAfter

        public void setWarnAfter​(TimeInterval t)
        Log a warning after this interval.
        Parameters:
        t - the warnAfter to set, default is to never warn.

      • getSendProcessingInterval

        public TimeInterval getSendProcessingInterval()
        Returns:
        the sendExpectEvery

      • setSendProcessingInterval

        public void setSendProcessingInterval​(TimeInterval t)
        If required send a 102 upon this interval.
        Parameters:
        t - the sendExpectEvery to set, default is 20 seconds.

      • consumeLocationKey

        public java.lang.String consumeLocationKey()
        Provides the metadata key '"jettyURI"' that contains the URI which triggered the consumer.
        Returns:
        the metadata key;
        Since:
        3.9.0

      • getPath

        public java.lang.String getPath()
        The path we register against jetty for this consumer

      • setPath

        public void setPath​(java.lang.String path)
        The path we register against jetty for this consumer

      • getMethods

        public java.lang.String getMethods()
        Comma separated string of valid methods.

      • setMethods

        public void setMethods​(java.lang.String methods)
        Comma separated string of valid methods.