Package pbx

Class PluginGrpc.PluginImplBase

  • All Implemented Interfaces:
    io.grpc.BindableService
    Enclosing class:
    PluginGrpc
    public abstract static class PluginGrpc.PluginImplBase
extends java.lang.Object
implements io.grpc.BindableService
     Plugin interface.

    • Constructor Detail

      • PluginImplBase

        public PluginImplBase()

    • Method Detail

      • fireHose

        public void fireHose​(Model.ClientReq request,
                     io.grpc.stub.StreamObserver<Model.ServerResp> responseObserver)
         This plugin method is called by Tinode server for every message received from the clients. The
 method returns a ServerCtrl message. Non-zero ServerCtrl.code indicates that no further
 processing is needed. The Tinode server will generate a {ctrl} message from the returned ServerCtrl
 and forward it to the client session.
 ServerCtrl.code equals to 0 instructs the server to continue with default processing of the client message.

      • find

        public void find​(Model.SearchQuery request,
                 io.grpc.stub.StreamObserver<Model.SearchFound> responseObserver)
         An alteranative user and topic discovery mechanism.
 A search request issued on a 'fnd' topic. This method is called to generate an alternative result set.

      • account

        public void account​(Model.AccountEvent request,
                    io.grpc.stub.StreamObserver<Model.Unused> responseObserver)
         Account created, updated or deleted

      • topic

        public void topic​(Model.TopicEvent request,
                  io.grpc.stub.StreamObserver<Model.Unused> responseObserver)
         Topic created, updated [or deleted -- not supported yet]

      • subscription

        public void subscription​(Model.SubscriptionEvent request,
                         io.grpc.stub.StreamObserver<Model.Unused> responseObserver)
         Subscription created, updated or deleted

      • message

        public void message​(Model.MessageEvent request,
                    io.grpc.stub.StreamObserver<Model.Unused> responseObserver)
         Message published or deleted

      • bindService

        public final io.grpc.ServerServiceDefinition bindService()
        Specified by:
        bindService in interface io.grpc.BindableService