Skip to content

Commit

Permalink
add request/reply example
Browse files Browse the repository at this point in the history
  • Loading branch information
plobsing committed Mar 30, 2011
1 parent ec10b69 commit 16a99e4
Show file tree
Hide file tree
Showing 2 changed files with 34 additions and 0 deletions.
18 changes: 18 additions & 0 deletions examples/req-rep/client.winxed
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
$include_const 'ZeroMQ/Constants.pasm';

function main[main](var argv) {
load_bytecode('ZeroMQ.pbc');

var ctx = new ZeroMQ.Context();
var sock = ctx.socket(ZMQ_REQ);
sock.connect("tcp://127.0.0.1:2468");

for (int i = 0; i < 10; i++) {
var req = new ZeroMQ.Message(string(i));
sock.send(req);

var rep = new ZeroMQ.Message();
sock.recv(rep);
say(string(rep));
}
}
16 changes: 16 additions & 0 deletions examples/req-rep/server.winxed
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
$include_const 'ZeroMQ/Constants.pasm';

function main[main](var argv) {
load_bytecode('ZeroMQ.pbc');

var ctx = new ZeroMQ.Context();
var sock = ctx.socket(ZMQ_REP);
sock.bind("tcp://127.0.0.1:2468");

for (;;) {
var msg = new ZeroMQ.Message();
sock.recv(msg);
msg = new ZeroMQ.Message(string(msg) + " confirmed");
sock.send(msg);
}
}

0 comments on commit 16a99e4

Please sign in to comment.