You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@ignite.apache.org by "Semyon Danilov (Jira)" <ji...@apache.org> on 2022/06/28 10:31:00 UTC

[jira] [Created] (IGNITE-17249) DefaultMessagingService incorrect message sending order

|  ![](cid:jira-generated-image-avatar-f57b4ee5-b54d-4668-96c7-5d2908c8fd61) |
[Semyon
Danilov](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=sdanilov)
**created** an issue  
---|---  
|  
---  
|  [Ignite](https://issues.apache.org/jira/browse/IGNITE) / [![Bug](cid:jira-
generated-image-
avatar-c53ee123-93f2-4700-80a8-e2e6d637225a)](https://issues.apache.org/jira/browse/IGNITE-17249)
[IGNITE-17249](https://issues.apache.org/jira/browse/IGNITE-17249)  
---  
[DefaultMessagingService incorrect message sending
order](https://issues.apache.org/jira/browse/IGNITE-17249)  
| Issue Type: |  ![Bug](cid:jira-generated-image-
avatar-c53ee123-93f2-4700-80a8-e2e6d637225a) Bug  
---|---  
Assignee: |  Unassigned  
Components: |  networking  
Created: |  28/Jun/22 10:30  
Labels: |  ignite-3  
Priority: |  ![Major](cid:jira-generated-image-static-major-
be780d7e-6243-4853-a98b-f945c468a340) Major  
Reporter: |  [Semyon
Danilov](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=sdanilov)  
|

The issue is in the  
`private CompletableFuture<Void> sendMessage0(NetworkMessage message, String
recipientConsistentId, InetSocketAddress addr)` method.

`connectionManager.channel(recipientConsistentId, addr)` returns a future and
we add a "listener" via `thenCompose` method. The thing is that it adds a
listener to the start of the queue, so when the channel is established the
latest listener will be executed first.  
  
---  
|  |  [ ![Add Comment](cid:jira-generated-image-static-comment-
icon-6d736a3f-5b76-4be1-a467-09b550f6bdc5)
](https://issues.apache.org/jira/browse/IGNITE-17249#add-comment "Add
Comment") |  [Add
Comment](https://issues.apache.org/jira/browse/IGNITE-17249#add-comment "Add
Comment")  
---|---  
  
|  This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9) |  |
![Atlassian logo](https://issues.apache.org/jira/images/mail/atlassian-email-
logo.png)  
---