class NotifierEventDispatcher<T extends Template> extends NotifierProxy<T> {

    private final EventBus eventBus;

    public NotifierEventDispatcher(EventBus eventBus, Notifier<T> target) {
        super(target);
        this.eventBus = eventBus;
    }

    @Override
    protected Mono<Void> onEvent(NotifierEvent event) {<FILL_FUNCTION_BODY>}


}

        // /notify/{notifierId}/success

        return eventBus
            .publish(String.join("/", "/notify", event.getNotifierId(), event.isSuccess() ? "success" : "error"), event.toSerializable())
            .then();
    
<methods>public non-sealed void <init>() ,public Mono<java.lang.Void> close() ,public java.lang.String getNotifierId() ,public org.jetlinks.community.notify.Provider getProvider() ,public org.jetlinks.community.notify.NotifyType getType() ,public boolean isWrapperFor(Class<?>) ,public Mono<java.lang.Void> send(java.lang.String, org.jetlinks.core.Values) ,public Mono<java.lang.Void> send(T, org.jetlinks.core.Values) ,public R unwrap(Class<R>) <variables>private final non-sealed Notifier<T> target