1 -module(counter).
 2 -export([run/0, counter/1]).
 3 
 4 run() ->
 5     S = spawn(counter, counter, [0]),
 6     send_msgs(S, 100000),
 7     S.
 8 
 9 counter(Sum) ->
10     receive
11         value -> io:fwrite("Value is ~w~n", [Sum]);
12         {inc, Amount} -> counter(Sum+Amount)
13     end.
14 
15 send_msgs(_, 0) -> true;
16 send_msgs(S, Count) ->
17     S ! {inc, 1},
18     send_msgs(S, Count-1).

1 from pika.adapters import BlockingConnection
2 from pika import BasicProperties
3 
4 # Open a connection to RabbitMQ on localhost
5 # using all default parameters
6 connection = BlockingConnection()
7 
8 # Open the channel
9 channel = connection.channel()

1 byte[] messageBodyBytes =
2     "Hello, world!".getBytes();
3 
4 channel.basicPublish(
5     "fest-exchange", // Exchange
6     null, // Routing key
7     null, // Properties
8     messageBodyBytes);

1 def handle_delivery(channel,
2     method_frame, header_frame, body):
3     # Process the message and acknowledge it
4 
5     channel.basic_ack(
6         delivery_tag=method_frame.delivery_tag)
7 
8 channel.basic_consume(
9     handle_delivery, queue='fest-queue')

 1 val ctx = ZMQ.context(2)
 2 val s = ctx.socket(ZMQ.PUSH)
 3 s.bind("tcp://*:6001")
 4 
 5 for (i <- 1 to 100) {
 6   var r1 = (Math.random() * 100).toInt
 7   var r2 = (Math.random() * 100).toInt
 8 
 9   s.send("%s+%s".format(r1, r2).getBytes(),
10          0) // flags
11 }

 1 <?php
 2 $ctx = new ZMQContext();
 3 $socket = $ctx->getSocket(ZMQ::SOCKET_PULL);
 4 $socket->connect('tcp://127.0.0.1:6001');
 5 
 6 for ($i = 0; $i < 100; $i++) {
 7     $data = $socket->recv();
 8     list($a, $b) = explode('+', $data);
 9     $c = $a + $b;
10     echo "$a + $b = $c\n";
11 }
12 
13 // 1 + 31 = 32
14 // 84 + 50 = 134
15 // 88 + 62 = 150

 1 zmq = require 'zmq'
 2 
 3 inPort = 5555
 4 outPort = 5556
 5 
 6 connectedClients = {}
 7 
 8 inSocket = zmq.createSocket 'push'
 9 inSocket.bind "tcp://127.0.0.1:#{inPort}", (e) ->
10 
11 outSocket = zmq.createSocket 'pull'
12 outSocket.bind "tcp://127.0.0.1:#{outPort}", (e) ->
13   outSocket.on 'message', (m) ->
14     title = m.toString('utf-8')
15     for id of connectedClients
16       connectedClients[id].send(title)

 1 import time, zmq
 2 from lxml import html
 3 
 4 c = zmq.Context()
 5 in_socket = c.socket(zmq.PULL)
 6 in_socket.connect('tcp://127.0.0.1:5555')
 7 
 8 out_socket = c.socket(zmq.PUSH)
 9 out_socket.connect('tcp://127.0.0.1:5556')
10 
11 while True:
12     try:
13         url = in_socket.recv()
14         time.sleep(1) # Simulate latency
15         dom = html.parse(url)
16         title = dom.getroot().find('head/title').text
17 
18         out_socket.send(title)
19     except KeyboardInterrupt:
20         break