Re: Is there a QUEUE based messaging?

[akorensh]

You can use topic messaging, but vary the specific nodes receiving the
message:
see:
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/cluster/ClusterGroup.html

and: https://apacheignite.readme.io/docs/messaging#section--example-

set an attribute on the node you want to receive messages:
then use this:http://apache-ignite-users.70518.x6.nabble.com/images/more.png


        Ignite ignite = Ignition.ignite();

      // Cluster group over all nodes that have the user attribute "group"
set to the value "worker".
        ClusterGroup workerNodes = ignite.cluster.forAttribute("group",
"worker");

        IgniteMessaging rmtMsg = ignite.message(workerNodes);

     // Add listener for unordered messages on all remote nodes.
        rmtMsg.remoteListen("MyOrderedTopic", (nodeId, msg) -> {
        System.out.println("Received ordered message [msg=" + msg + ",
from=" + nodeId + ']');

        return true; // Return true to continue listening.
        });

     // Send ordered messages to remote nodes.
        for (int i = 0; i < 10; i++)
        rmtMsg.sendOrdered("MyOrderedTopic", Integer.toString(i),0);



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/