Ding Li
55 lines
1.9 KiB
Plaintext
55 lines
1.9 KiB
Plaintext
//+------------------------------------------------------------------+
|
|
//| MSPoller.mq4 |
|
|
//| Copyright 2017, Li Ding |
|
|
//| dingmaotu@126.com |
|
|
//+------------------------------------------------------------------+
|
|
#property copyright "Copyright 2017, Li Ding"
|
|
#property link "dingmaotu@126.com"
|
|
#property version "1.00"
|
|
#property strict
|
|
#include <Zmq/Zmq.mqh>
|
|
//+------------------------------------------------------------------+
|
|
//| Reading from multiple sockets in MQL (adapted from C++ version) |
|
|
//| This version uses zmq_poll() |
|
|
//| |
|
|
//| Olivier Chamoux <olivier.chamoux@fr.thalesgroup.com> |
|
|
//+------------------------------------------------------------------+
|
|
void OnStart()
|
|
{
|
|
//---
|
|
Context context;
|
|
|
|
// Connect to task ventilator
|
|
Socket receiver(context,ZMQ_PULL);
|
|
receiver.connect("tcp://localhost:5557");
|
|
|
|
// Connect to weather server
|
|
Socket subscriber(context,ZMQ_SUB);
|
|
subscriber.connect("tcp://localhost:5556");
|
|
subscriber.subscribe("10001 ");
|
|
|
|
// Initialize poll set
|
|
PollItem items[2];
|
|
receiver.fillPollItem(items[0],ZMQ_POLLIN);
|
|
subscriber.fillPollItem(items[1],ZMQ_POLLIN);
|
|
// Process messages from both sockets
|
|
while(!IsStopped())
|
|
{
|
|
ZmqMsg message;
|
|
//--- MQL Note: To handle Script exit properly, we set a timeout of 500 ms instead of infinite wait
|
|
Socket::poll(items,500);
|
|
|
|
if(items[0].hasInput())
|
|
{
|
|
receiver.recv(message);
|
|
// Process task
|
|
}
|
|
if(items[1].hasInput())
|
|
{
|
|
subscriber.recv(message);
|
|
// Process weather update
|
|
}
|
|
}
|
|
}
|
|
//+------------------------------------------------------------------+
|