Package de.iip_ecosphere.platform.services.environment.services

Class Receiver

java.lang.Object
de.iip_ecosphere.platform.services.environment.services.Receiver
public class Receiver extends Object
Basic abilities for a generic receiver, which may also operate outside the streaming environment.
Author:
Holger Eichelberger, SSE

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    Receiver.LoggingReceptionCallback<T>
    A generic logging reception callback.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private de.iip_ecosphere.platform.transport.connectors.TransportConnector
    connector
     
    static final boolean
    DEBUG
     
    private boolean
    running
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    Receiver()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected de.iip_ecosphere.platform.transport.connectors.TransportConnector
    getConnector()
    Returns the transport connector.
    protected void
    setConnector(de.iip_ecosphere.platform.transport.connectors.TransportConnector connector)
    Defines/changes the transport connector.
    void
    start()
    Starts the receiver.
    void
    stop()
    Stops the receiver.
    protected void
    subscribeTo(Receiver.LoggingReceptionCallback<?>... callbacks)
    Subscribes to the given logger callbacks/streams.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • DEBUG

      public static final boolean DEBUG
      See Also:

    • connector

      private de.iip_ecosphere.platform.transport.connectors.TransportConnector connector

    • running

      private boolean running

  • Constructor Details

    • Receiver

      public Receiver()

  • Method Details

    • setConnector

      protected void setConnector(de.iip_ecosphere.platform.transport.connectors.TransportConnector connector)
      Defines/changes the transport connector.
      Parameters:
      connector - the new connector

    • getConnector

      protected de.iip_ecosphere.platform.transport.connectors.TransportConnector getConnector()
      Returns the transport connector.
      Returns:
      the connector

    • subscribeTo

      protected void subscribeTo(Receiver.LoggingReceptionCallback<?>... callbacks)
      Subscribes to the given logger callbacks/streams.
      Parameters:
      callbacks - the callbacks/streams

    • start

      public void start()
      Starts the receiver.

    • stop

      public void stop()
      Stops the receiver.