You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Vyacheslav Koptilin (Jira)" <ji...@apache.org> on 2023/04/21 08:25:00 UTC

[jira] [Commented] (IGNITE-16679) Redesing local events in order to them contain a synchronous and asychronous parts

    [ https://issues.apache.org/jira/browse/IGNITE-16679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714864#comment-17714864 ] 

Vyacheslav Koptilin commented on IGNITE-16679:
----------------------------------------------

LGTM

> Redesing local events in order to them contain a synchronous and asychronous parts
> ----------------------------------------------------------------------------------
>
>                 Key: IGNITE-16679
>                 URL: https://issues.apache.org/jira/browse/IGNITE-16679
>             Project: Ignite
>          Issue Type: Bug
>            Reporter: Vladislav Pyatkov
>            Assignee: Vladislav Pyatkov
>            Priority: Blocker
>              Labels: ignite-3
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> For coordinated work, components required to execute some logic before an event completed (when the event producer have no result) and after (when the producer already complete the event and behavior of the component changed) it.
> In this task, need to change the interface of the listener:
> {code:java}
> /**
>  * Notifies the listener about an event.
>  *
>  * @param parameters Parameters provide a properties of the event. This attribute cannot be {@code null}.
>  * @param exception  Exception which is happened during the event produced or {@code null}.
>  * @return A future which will complete when the listener handles the message. 
>  * If the future returns {@code true} that the listener will be never invoked more, if it is {@code false} the listener will stay listen next event.
>  */
> CompletableFuture<Boolean> notify(@NotNull P parameters, @Nullable Throwable exception);
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)