GridGain Distributed Messaging

Exchange Data Via Publish-Subscribe and Direct Point-to-Point Communication

GridGain provides a high-performance cluster-wide Distributed Messaging feature. The GridGain Distributed Messaging feature allows you to exchange data via publish-subscribe and direct point-to-point communication models.

Features:

  • Support for Topic-Based Publish-Subscribe Model
  • Support for Direct Point-to-Point Communication
  • Pluggable Communication Transport Layer
  • Support for Message Ordering
  • Cluster-Aware Message Listener Auto-Deployment
Examples:

Ignite ignite = Ignition.ignite();
 
IgniteMessaging rmtMsg = ignite.message(ignite.cluster().forRemotes());
 
// 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));

Ignite ignite = Ignition.ignite();
 
IgniteMessaging rmtMsg = ignite.message(ignite.cluster().forRemotes());
 
// Add listener for unordered messages on all remote nodes.
rmtMsg.remoteListen("MyUnOrderedTopic", (nodeId, msg) -> {
    System.out.println("Received unordered message [msg=" + msg + ", from=" + nodeId + ']');
 
    return true; // Return true to continue listening.
});
 
// Send unordered messages to remote nodes.
for (int i = 0; i < 10; i++)
    rmtMsg.send("MyUnOrderedTopic", Integer.toString(i));

Learn More