Package io.vertx.reactivex.servicediscovery.spi

Class ServicePublisher

  • public class ServicePublisher
extends Object
    The publisher is used by the importer to publish or unpublish records.

    NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean equals​(Object o)  
      io.vertx.servicediscovery.spi.ServicePublisher getDelegate()  
      int hashCode()  
      static ServicePublisher newInstance​(io.vertx.servicediscovery.spi.ServicePublisher arg)  
      void publish​(io.vertx.servicediscovery.Record record)
      Publishes a record.
      void publish​(io.vertx.servicediscovery.Record record, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.servicediscovery.Record>> resultHandler)
      Publishes a record.
      io.reactivex.Single<io.vertx.servicediscovery.Record> rxPublish​(io.vertx.servicediscovery.Record record)
      Publishes a record.
      io.reactivex.Completable rxUnpublish​(String id)
      Un-publishes a record.
      io.reactivex.Single<io.vertx.servicediscovery.Record> rxUpdate​(io.vertx.servicediscovery.Record record)
      Updates an existing record.
      String toString()  
      void unpublish​(String id)
      Un-publishes a record.
      void unpublish​(String id, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
      Un-publishes a record.
      void update​(io.vertx.servicediscovery.Record record)
      Updates an existing record.
      void update​(io.vertx.servicediscovery.Record record, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.servicediscovery.Record>> resultHandler)
      Updates an existing record.

    • Constructor Detail

      • ServicePublisher

        public ServicePublisher​(io.vertx.servicediscovery.spi.ServicePublisher delegate)

      • ServicePublisher

        public ServicePublisher​(Object delegate)

    • Method Detail

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object

      • getDelegate

        public io.vertx.servicediscovery.spi.ServicePublisher getDelegate()

      • publish

        public void publish​(io.vertx.servicediscovery.Record record,
                    io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.servicediscovery.Record>> resultHandler)
        Publishes a record.
        Parameters:
        record - the record
        resultHandler - handler called when the operation has completed (successfully or not). In case of success, the passed record has a registration id required to modify and un-register the service.

      • publish

        public void publish​(io.vertx.servicediscovery.Record record)
        Publishes a record.
        Parameters:
        record - the record

      • rxPublish

        public io.reactivex.Single<io.vertx.servicediscovery.Record> rxPublish​(io.vertx.servicediscovery.Record record)
        Publishes a record.
        Parameters:
        record - the record
        Returns:

      • unpublish

        public void unpublish​(String id,
                      io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
        Un-publishes a record.
        Parameters:
        id - the registration id
        resultHandler - handler called when the operation has completed (successfully or not).

      • unpublish

        public void unpublish​(String id)
        Un-publishes a record.
        Parameters:
        id - the registration id

      • rxUnpublish

        public io.reactivex.Completable rxUnpublish​(String id)
        Un-publishes a record.
        Parameters:
        id - the registration id
        Returns:

      • update

        public void update​(io.vertx.servicediscovery.Record record,
                   io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.servicediscovery.Record>> resultHandler)
        Updates an existing record.
        Parameters:
        record - the record
        resultHandler - handler called when the operation has completed (successfully or not). In case of success, the passed record has a registration id required to modify and un-register the service.

      • update

        public void update​(io.vertx.servicediscovery.Record record)
        Updates an existing record.
        Parameters:
        record - the record

      • rxUpdate

        public io.reactivex.Single<io.vertx.servicediscovery.Record> rxUpdate​(io.vertx.servicediscovery.Record record)
        Updates an existing record.
        Parameters:
        record - the record
        Returns:

      • newInstance

        public static ServicePublisher newInstance​(io.vertx.servicediscovery.spi.ServicePublisher arg)