Package org.zeromq.ZMQ

Examples of org.zeromq.ZMQ.Context.socket()

49
50
51
52
53
54
55
56
57
58
59
  public void run()
  {
    Context context = ZMQ.context(1);

    //  Prepare our context and sockets
    Socket worker  = context.socket(ZMQ.REQ);

    //  Initialize random number generator
    Random srandom = new Random(System.nanoTime());
    String id = String.format("%04x-%04x", srandom.nextInt(0x10000)+1,srandom.nextInt(0x10000)+1);
    worker.setIdentity(id.getBytes());  //  Makes tracing easier
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
  public static void main(String[] args) {
    Context context = ZMQ.context(1);

    //  Prepare our context and sockets
    Socket frontend  = context.socket(ZMQ.ROUTER);
    Socket backend  = context.socket(ZMQ.ROUTER);
    frontend.bind("ipc://frontend.ipc");
    backend.bind("ipc://backend.ipc");

    int client_nbr;
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
  public static void main(String[] args) {
    Context context = ZMQ.context(1);

    //  Prepare our context and sockets
    Socket frontend  = context.socket(ZMQ.ROUTER);
    Socket backend  = context.socket(ZMQ.ROUTER);
    frontend.bind("ipc://frontend.ipc");
    backend.bind("ipc://backend.ipc");

    int client_nbr;
    for (client_nbr = 0; client_nbr < 10; client_nbr++)
View Full Code Here
12
13
14
15
16
17
18
19
20
21
22
public class rrclient{
  public static void main (String[] args) {
    Context context = ZMQ.context(1);

    //  Socket to talk to server
    Socket requester = context.socket(ZMQ.REQ);
    requester.connect("tcp://localhost:5559");
   
    System.out.println("launch and connect client.");

    for (int request_nbr = 0; request_nbr < 10; request_nbr++) {
View Full Code Here
12
13
14
15
16
17
18
19
20
21
22
public class rrserver{
  public static void main (String[] args) {
    Context context = ZMQ.context(1);

    //  Socket to talk to clients
    Socket responder  = context.socket(ZMQ.REP);
    responder.connect("tcp://localhost:5560");
   
    System.out.println("launch and connect server.");

    while (!Thread.currentThread().isInterrupted()) {
View Full Code Here
14
15
16
17
18
19
20
21
22
23
24
  public static void main (String[] args) {
    //  Prepare our context and sockets
    Context context = ZMQ.context(1);

    //  Socket facing clients
    Socket frontend = context.socket(ZMQ.ROUTER);
    frontend.bind("tcp://*:5559");

    //  Socket facing services
    Socket backend = context.socket(ZMQ.DEALER);
    backend.bind("tcp://*:5560");
 
View Full Code Here
18
19
20
21
22
23
24
25
26
27
28
    //  Socket facing clients
    Socket frontend = context.socket(ZMQ.ROUTER);
    frontend.bind("tcp://*:5559");

    //  Socket facing services
    Socket backend = context.socket(ZMQ.DEALER);
    backend.bind("tcp://*:5560");

    //  Start built-in device
    ZMQQueue queue = new ZMQQueue(context, frontend, backend);
    // have fun!
View Full Code Here
16
17
18
19
20
21
22
23
24
25
26
  public static void main (String[] args) {
    Context context = ZMQ.context(1);

    //  Socket to talk to clients
    Socket publisher = context.socket(ZMQ.PUB);
    publisher.bind("tcp://*:5561");

    //  Socket to receive signals
    Socket syncservice = context.socket(ZMQ.REP);
    syncservice.bind("tcp://*:5562");
 
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
    //  Socket to talk to clients
    Socket publisher = context.socket(ZMQ.PUB);
    publisher.bind("tcp://*:5561");

    //  Socket to receive signals
    Socket syncservice = context.socket(ZMQ.REP);
    syncservice.bind("tcp://*:5562");

    //  Get synchronization from subscribers
    int subscribers = 0;
    while (subscribers < SUBSCRIBERS_EXPECTED) {
View Full Code Here
13
14
15
16
17
18
19
20
21
22
23
  public static void main (String[] args) {
    //  Prepare our context and sockets
    Context context = ZMQ.context(1);

    //  This is where the weather server sits
    Socket frontend =  context.socket(ZMQ.SUB);
    frontend.connect("tcp://192.168.55.210:5556");

    //  This is our public endpoint for subscribers
    Socket backend  = context.socket(ZMQ.PUB);
    backend.bind("tcp://10.1.1.0:8100");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.