Package org.jlab.io.ring

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

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

    myId, myName

  • Constructor Summary

    Constructors
    Constructor
    Description
    DataRingProducer()
     

  • Method Summary

    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

    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

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

  • Constructor Details

    • DataRingProducer

      public DataRingProducer()

  • Method Details

    • setDelay

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

    • updateList

      public void updateList()

    • start

      public void start()
      Start publisher service. establishes connection

    • addEvioEvent

      public void addEvioEvent(EvioDataEvent event)

    • shutdown

      public void shutdown()

    • addEvent

      public void addEvent(HipoDataEvent event)

    • main

      public static void main(String[] args)