Package org.ovirt.vdsm.jsonrpc.client.events

Class EventPublisher

  • All Implemented Interfaces:
    java.util.concurrent.Flow.Publisher<java.util.Map<java.lang.String,​java.lang.Object>>
    public class EventPublisher
extends java.lang.Object
implements java.util.concurrent.Flow.Publisher<java.util.Map<java.lang.String,​java.lang.Object>>
    Jsonrpc implementation of Flow.Publisher

    • Constructor Summary

      Constructors 
      Constructor Description
      EventPublisher​(java.util.concurrent.ExecutorService executorService, int eventTimeoutInHours)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cleanupOldEvents()  
      void close()  
      int countEvents​(JsonRpcEvent event)  
      void process​(JsonRpcEvent event)
      This method is used by @link ResponseWorker to submit an @link JsonRpcEvent for processing.
      void publish​(java.lang.String subscriptionId, java.util.Map<java.lang.String,​java.lang.Object> params)  
      void subscribe​(java.util.concurrent.Flow.Subscriber<? super java.util.Map<java.lang.String,​java.lang.Object>> subscriber)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • EventPublisher

        public EventPublisher​(java.util.concurrent.ExecutorService executorService,
                      int eventTimeoutInHours)

    • Method Detail

      • cleanupOldEvents

        public void cleanupOldEvents()

      • subscribe

        public void subscribe​(java.util.concurrent.Flow.Subscriber<? super java.util.Map<java.lang.String,​java.lang.Object>> subscriber)
        Specified by:
        subscribe in interface java.util.concurrent.Flow.Publisher<java.util.Map<java.lang.String,​java.lang.Object>>

      • publish

        public void publish​(java.lang.String subscriptionId,
                    java.util.Map<java.lang.String,​java.lang.Object> params)
             throws java.io.IOException
        Throws:
        java.io.IOException

      • process

        public void process​(JsonRpcEvent event)
        This method is used by @link ResponseWorker to submit an @link JsonRpcEvent for processing.
        Parameters:
        event - which is submitted for processing.

      • countEvents

        public int countEvents​(JsonRpcEvent event)

      • close

        public void close()