Class AbstractMediator

    • Method Detail

      • setInvoker

        public void setInvoker​(Invoker invoker)
      • setDecorators

        public void setDecorators​(javax.enterprise.inject.Instance<PublisherDecorator> decorators)
      • setWorkerPoolRegistry

        public void setWorkerPoolRegistry​(WorkerPoolRegistry workerPoolRegistry)
      • run

        public void run()
      • connectToUpstream

        public void connectToUpstream​(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher)
      • initialize

        public void initialize​(Object bean)
      • invoke

        protected <T> T invoke​(Object... args)
      • invokeBlocking

        protected <T> io.smallrye.mutiny.Uni<T> invokeBlocking​(Object... args)
      • getStream

        public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> getStream()
      • getMethodAsString

        public String getMethodAsString()
      • getComputedSubscriber

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<Message<?>,​Void> getComputedSubscriber()
      • isConnected

        public abstract boolean isConnected()
      • decorate

        public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> decorate​(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> input)