From a08a72dd082e5e62f0d043c71ea7d9b6fb80b57e Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Mon, 7 Dec 2009 21:06:54 +0100 Subject: chat example added --- examples/chat/display.cpp | 50 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 50 insertions(+) create mode 100755 examples/chat/display.cpp (limited to 'examples/chat/display.cpp') diff --git a/examples/chat/display.cpp b/examples/chat/display.cpp new file mode 100755 index 0000000..d04e90b --- /dev/null +++ b/examples/chat/display.cpp @@ -0,0 +1,50 @@ +/* + Copyright (c) 2007-2009 FastMQ Inc. + + This file is part of 0MQ. + + 0MQ is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 3 of the License, or + (at your option) any later version. + + 0MQ is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program. If not, see . +*/ + +#include +#include +#include +#include + +int main (int argc, const char *argv []) +{ + // Check the command line syntax. + if (argc != 2) { + fprintf (stderr, "usage: display
\n"); + return 1; + } + + // Retrieve command line arguments + const char *address = argv [1]; + + // Initialise 0MQ infrastructure. + zmq::context_t ctx (1, 1); + zmq::socket_t s (ctx, ZMQ_SUB); + s.setsockopt (ZMQ_SUBSCRIBE, "*", 1); + s.connect (address); + + while (true) { + + // Get a message and print it to the console. + zmq::message_t msg; + s.recv (&msg); + fprintf (stdout, "%s", (char*) msg.data ()); + fflush (stdout); + } +} -- cgit v1.2.3