Be Connected

Regardless of wherever you are producing & consuming the data

Regardless of messaging protocols, APIs type & exchange patterns



Be Real-Time

Regardless of the amount of data being continuously generated

Regardless of consuming a part among large streaming data



Be Extensible

Regardless of traditional architecture patterns or modern patterns

Regardless of sudden hike of data producers or consumers





LEORIX real-time message broker


Highly scalable Leorix multi-protocol message broker enabling best in class event-driven microservices, to reach the performance matching with the microservices of Spotify & Twitter.

Leorix brings more values to the customers for easily add / remove / move services, easy horizontal scalability, service decoupling, easy disaster recovery and more.





LEORIX real-time message broker
LEORIX data streaming network

LEORIX data streaming network


You can deploy Leorix on geographically distributed data centers that can be public cloud or on-prem server. And create your own fastest data streaming network to stream data in real-time beyond the borders.

And you can monitor and control from a single pane of glass. Leorix distribution algorithms will always maintaining the fastest network among servers and ensure low latency for end-to-end data delivery


LEORIX pub-sub

Publish

Ingest High throughput data

Multiple communication protocols

Subscribe

  • Data available for usage in real-time with required communication protocol
  • Can be get a particular field from generated data
  • 100% of the data persisted in streaming storage. So it can be used at anytime
var mqtt = require('mqtt')
var client  = mqtt.connect('mqtt://platform.leorix.io/demo')

client.on('connect', function () {

   client.publish('T/Temperature/Device_124', '45')

});
                                    
                                    
                                    

MqttClient mqttClient = new MqttClient("tcp://platform.leorix.io/demo", "DemoPublisher");
mqttClient.connect();


String zTemperature = "86";
MqttMessage message = new MqttMessage(zTemperature.getBytes());
message.setQos(0);

mqttClient.publish("T/Temperature/Device_124", message);
mqttClient.disconnectForcibly();`
                                

const std::string TOPIC { "T/Temperature/Device_124" };
const std::string PAYLOAD1 { "56" };

mqtt::client cli("tcp://platform.leorix.io/demo");

mqtt::connect_options connOpts;
connOpts.set_keep_alive_interval(20);
connOpts.set_clean_session(true);
auto msg = mqtt::make_message(TOPIC, PAYLOAD1);
msg->set_qos(QOS);

client.connect(connOpts);
cli.publish(msg);
cli.disconnect();
                                

MqttClient client = new MqttClient(IPAddress.Parse("tcp://platform.leorix.io/demo"));
string clientId = Guid.NewGuid().ToString();
client.Connect(clientId);

string strValue = "86";

// publish a message on "/home/temperature" topic with QoS 2
client.Publish("T/Temperature/Device_124",
                Encoding.UTF8.GetBytes(strValue),
                MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE);

                                


var mqtt = require('mqtt')
var client  = mqtt.connect('mqtt://platform.leorix.io/demo')

client.on('connect', function () {
                  client.subscribe('T/Temperature/*')
});

client.on('message', function (topic, message) {
                  console.log(message)
});
                                    

MqttClient mqttClient = new MqttClient(host, "DemoSubscriber");
mqttClient.connect();

// Callback - Anonymous inner-class for receiving messages
mqttClient.setCallback(new MqttCallback() {

     public void messageArrived(String topic, MqttMessage message) throws Exception {
            System.out.println("Receving the message : "+message.toString());
     }
});
mqttClient.subscribe("T/Temperature/*");

                                    

const std::string TOPIC { "T/Temperature/*" };
mqtt::client cli("tcp://platform.leorix.io/demo");

mqtt::connect_options connOpts;
connOpts.set_keep_alive_interval(20);
connOpts.set_clean_session(true);

cli.subscribe(TOPIC);

while (true) {
      auto msg = cli.consume_message();
           if (!msg) {
           break;
      }
      cout << msg->get_topic() << ": " << msg->to_string() << endl;
}

cli.disconnect();
                                

MqttClient client = new MqttClient(IPAddress.Parse("tcp://platform.leorix.io/demo"));
client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;

string clientId = Guid.NewGuid().ToString();
client.Connect(clientId);

// subscribe to the topic "/home/temperature" with QoS 2
client.Subscribe(new string[] { "T/Temperature/*" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });

static void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e){
      // handle received message
}
                                


Global Presence of LEORIX

Leorix platform is readily available on 45 locations in public clouds, Amazon Web Service, Google Cloud Platform, and Digital Ocean Cloud. Leorix is absolutely free to use in selected locations.

Click on a location to find out the details

You can launch Leorix in a maximum of 5 clicks and stream your data beyond continents without worrying about bandwidth, number of instances, and latency.


Locations marked as yellow colour dots. Click a mark on the map to check the details.

You have selected
Leorix Cloud version in Digital Ocen Cloud
Singapore, Singapore
Asia South East
Free Subscription is Available
Free From: Januray 2020
Try Leorix for Free






Try Leorix

LEORIX on cloud


Leorix advance message broker is available on public cloud in AWS, GCP, Digital Ocean, and it is free to use

You can simply subscribe for leorix and connect your data sources in any protocols. And subscribe the messages from anywhere in the globe.


Try Leorix for free

LEORIX in docker


Leorix advance message broker is available on docker version for download and install on your private clouds and on-premise environment.

You can download and build your own real-time data streaming network for connect devices and application for publish and subscribe your messages.

Contact Sales