Package ca.uqac.lif.cep.http

Class HttpSource

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.tmf.Sink
ca.uqac.lif.cep.http.HttpSource
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
public class HttpSource extends ca.uqac.lif.cep.tmf.Sink
HTTP server that pulls events from upstream when it receives a GET request.
Author:
Sylvain Hallé

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    protected class 
    HttpSource.ListenerCallback
     

    Nested classes/interfaces inherited from class ca.uqac.lif.cep.SynchronousProcessor

    ca.uqac.lif.cep.SynchronousProcessor.InputPushable, ca.uqac.lif.cep.SynchronousProcessor.OutputPullable

    Nested classes/interfaces inherited from class ca.uqac.lif.cep.Processor

    ca.uqac.lif.cep.Processor.InternalProcessorState

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected ca.uqac.lif.jerrydog.CallbackResponse.ContentType
    m_mimeType
    The MIME type to declare when sending an HTTP response
    protected int
    m_port
    The TCP port on which the gateway listens for requests
    protected ca.uqac.lif.cep.Pullable
    m_pullable
    A pullable to get events from
    protected ca.uqac.lif.jerrydog.Server
    m_server
    An internal instance of HTTP server
    protected String
    m_url
    The URL on which the gateway listens for requests

    Fields inherited from class ca.uqac.lif.cep.SynchronousProcessor

    m_inputPushables, m_outputPullables, m_tempQueue

    Fields inherited from class ca.uqac.lif.cep.Processor

    m_context, m_hasBeenNotifiedOfEndOfTrace, m_inputArity, m_inputPullables, m_inputQueues, m_notifiedEndOfTraceDownstream, m_outputArity, m_outputPushables, m_outputQueues, MAX_PULL_RETRIES, s_versionString

  • Constructor Summary

    Constructors
    Constructor
    Description
    HttpSource(String url, int port, ca.uqac.lif.jerrydog.CallbackResponse.ContentType type)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    compute(Object[] inputs, Queue<Object[]> outputs)
     
    ca.uqac.lif.cep.Processor
    duplicate(boolean with_state)
     
    void
    reset()
     
    void
    start()
     
    void
    stop()
     

    Methods inherited from class ca.uqac.lif.cep.tmf.Sink

    pull, pullHard

    Methods inherited from class ca.uqac.lif.cep.SynchronousProcessor

    getPullableOutput, getPushableInput

    Methods inherited from class ca.uqac.lif.cep.Processor

    allNotifiedEndOfTrace, allNull, copyInputQueue, copyOutputQueue, duplicate, duplicateInto, equals, getAt, getContext, getContext, getEmptyQueue, getId, getInputArity, getInputQueue, getInputType, getInputTypesFor, getOutputArity, getOutputQueue, getOutputType, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, onEndOfTrace, or, or, or, printState, readState, rightShift, setContext, setContext, setPullableInput, setPushableOutput, startAll, stopAll

    Methods inherited from class java.lang.Object

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

  • Field Details

    • m_port

      protected int m_port
      The TCP port on which the gateway listens for requests

    • m_server

      protected ca.uqac.lif.jerrydog.Server m_server
      An internal instance of HTTP server

    • m_url

      protected String m_url
      The URL on which the gateway listens for requests

    • m_mimeType

      protected ca.uqac.lif.jerrydog.CallbackResponse.ContentType m_mimeType
      The MIME type to declare when sending an HTTP response

    • m_pullable

      protected ca.uqac.lif.cep.Pullable m_pullable
      A pullable to get events from

  • Constructor Details

    • HttpSource

      public HttpSource(String url, int port, ca.uqac.lif.jerrydog.CallbackResponse.ContentType type)

  • Method Details

    • start

      public void start()
      Overrides:
      start in class ca.uqac.lif.cep.Processor

    • stop

      public void stop()
      Overrides:
      stop in class ca.uqac.lif.cep.Processor

    • reset

      public void reset()
      Overrides:
      reset in class ca.uqac.lif.cep.Processor

    • compute

      protected boolean compute(Object[] inputs, Queue<Object[]> outputs)
      Specified by:
      compute in class ca.uqac.lif.cep.SynchronousProcessor

    • duplicate

      public ca.uqac.lif.cep.Processor duplicate(boolean with_state)
      Specified by:
      duplicate in interface ca.uqac.lif.cep.Duplicable
      Specified by:
      duplicate in class ca.uqac.lif.cep.Processor