Class DataRingProducer

java.lang.Object
org.jlab.coda.xmsg.core.xMsg
org.jlab.io.ring.DataRingProducer
All Implemented Interfaces:
AutoCloseable
public class DataRingProducer extends org.jlab.coda.xmsg.core.xMsg
Author:
gavalian

  • Field Summary Link icon

    Fields inherited from class org.jlab.coda.xmsg.core.xMsg Link icon

    myId, myName

  • Constructor Summary Link icon

    Constructors
    Constructor
    Description
    DataRingProducer()
     

  • Method Summary Link icon

    Modifier and Type
    Method
    Description
    void
    addEvent(HipoDataEvent event)
     
    void
    addEvioEvent(EvioDataEvent event)
     
    static void
    main(String[] args)
     
    void
    setDelay(int delay)
    sets the sleep timer after each event has been published.
    void
    shutdown()
     
    void
    start()
    Start publisher service. establishes connection
    void
    updateList()
     

    Methods inherited from class org.jlab.coda.xmsg.core.xMsg Link icon

    cacheConnection, cacheConnection, close, deregister, deregister, deregister, destroy, destroy, destroyConnection, discover, discover, discover, getConnection, getConnection, getDefaultProxyAddress, getDefaultRegistrarAddress, getName, getPoolSize, publish, publish, publish, register, register, register, subscribe, subscribe, subscribe, subscribe, syncPublish, syncPublish, syncPublish, terminateCallbacks, unsubscribe, unsubscribeAll

    Methods inherited from class java.lang.Object Link icon

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

  • Constructor Details Link icon

    • DataRingProducer Link icon

      public DataRingProducer()

  • Method Details Link icon

    • setDelay Link icon

      public void setDelay(int delay)
      sets the sleep timer after each event has been published.
      Parameters:
      delay -

    • updateList Link icon

      public void updateList()

    • start Link icon

      public void start()
      Start publisher service. establishes connection

    • addEvioEvent Link icon

      public void addEvioEvent(EvioDataEvent event)

    • shutdown Link icon

      public void shutdown()

    • addEvent Link icon

      public void addEvent(HipoDataEvent event)

    • main Link icon

      public static void main(String[] args)