Ding Li
42 lines
1.5 KiB
Plaintext
42 lines
1.5 KiB
Plaintext
//+------------------------------------------------------------------+
|
|
//| RRWorker.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>
|
|
//+------------------------------------------------------------------+
|
|
//| Request-reply service in MQL (adapted from C++ version) |
|
|
//| Connects REP socket to tcp://localhost:5560 |
|
|
//| Expects "Hello" from client, replies with "World" |
|
|
//| |
|
|
//| Olivier Chamoux <olivier.chamoux@fr.thalesgroup.com> |
|
|
//+------------------------------------------------------------------+
|
|
void OnStart()
|
|
{
|
|
Context context;
|
|
|
|
Socket responder(context,ZMQ_REP);
|
|
responder.connect("tcp://localhost:5560");
|
|
|
|
while(!IsStopped())
|
|
{
|
|
// Wait for next request from client
|
|
ZmqMsg req;
|
|
responder.recv(req);
|
|
Print("Received request: ",req.getData());
|
|
|
|
// Do some 'work'
|
|
Sleep(1000);
|
|
|
|
ZmqMsg reply("World");
|
|
|
|
// Send reply back to client
|
|
responder.send(reply);
|
|
}
|
|
}
|
|
//+------------------------------------------------------------------+
|