B C D G I L M O P Q R S T U W Z
All Classes All Packages

B

byte2string(byte[]) - Static method in class org.sim0mq.test.reqrep.Tic

Turn byte array with closing zero into String.

C

call(String) - Method in class org.sim0mq.test.threads.PushPullThreads

Process message and push to central thread.

Client - Class in org.sim0mq.demo

Client example for JeroMQ / ZeroMQ.

ClientTask() - Constructor for class org.sim0mq.test.dealerrouter.DealerRouter.ClientTask

completed - Static variable in class org.sim0mq.test.RouterToReqExample

completed.

constructModel() - Method in class org.sim0mq.demo.mm1.MM1Queue41Model

ConsumerThread(ZContext) - Constructor for class org.sim0mq.test.threads.PushPullThreads.ConsumerThread

Constructor.

counter - Variable in class org.sim0mq.demo.reqrep.Req

counter to see if we are ready.

D

DealerRouter - Class in org.sim0mq.test.dealerrouter

0MQ DEALER-ROUTER example.

DealerRouter.ClientTask - Class in org.sim0mq.test.dealerrouter

This is our client task.

DealerRouter.ServerTask - Class in org.sim0mq.test.dealerrouter

This is our server task.

dN - Variable in class org.sim0mq.demo.mm1.MM1Queue41Model

tally dN.

G

getContext() - Method in class org.sim0mq.demo.Server

getResponder() - Method in class org.sim0mq.demo.Server

getSourceId() - Method in class org.sim0mq.demo.mm1.MM1Queue41Model

getStatistics() - Method in class org.sim0mq.demo.mm1.MM1FederationManager20.StateMachine

I

iat - Variable in class org.sim0mq.demo.mm1.MM1Queue41Model

PARAMETER iat.

InprocPushPull - Class in org.sim0mq.test.pushpull

Send PUSH - PULL messages over the inproc protocol.

InprocPushPullHWM - Class in org.sim0mq.test.pushpull

Send PUSH - PULL messages over the inproc protocol.

L

ListenerTask() - Constructor for class org.sim0mq.test.ZmqChat.ListenerTask

ListenThread(ZMQ.Socket) - Constructor for class org.sim0mq.test.pair.PairClient.ListenThread

ListenThread(ZMQ.Socket) - Constructor for class org.sim0mq.test.pair.PairServer.ListenThread

M

main(String[]) - Static method in class org.sim0mq.demo.Client

main(String[]) - Static method in class org.sim0mq.demo.mm1.MM1FederationManager

main(String[]) - Static method in class org.sim0mq.demo.mm1.MM1FederationManager20

main(String[]) - Static method in class org.sim0mq.demo.mm1.MM1Queue41Application

main(String[]) - Static method in class org.sim0mq.demo.reqrep.Rep

main(String[]) - Static method in class org.sim0mq.demo.reqrep.Req

main(String[]) - Static method in class org.sim0mq.demo.Server

main(String[]) - Static method in class org.sim0mq.test.dealerrouter.DealerRouter

The main thread simply starts several clients, and a server, and then waits for the server to finish.

main(String[]) - Static method in class org.sim0mq.test.pair.PairClient

main(String[]) - Static method in class org.sim0mq.test.pair.PairServer

main(String[]) - Static method in class org.sim0mq.test.pubsub.Publisher

main(String[]) - Static method in class org.sim0mq.test.pubsub.Subscriber

main(String[]) - Static method in class org.sim0mq.test.pushpull.InprocPushPull

main(String[]) - Static method in class org.sim0mq.test.pushpull.InprocPushPullHWM

main(String[]) - Static method in class org.sim0mq.test.reqrep.Tic

main(String[]) - Static method in class org.sim0mq.test.reqrep.Toc

main(String[]) - Static method in class org.sim0mq.test.RouterToReqExample

While this example runs in a single process, that is just to make it easier to start and stop the example.

main(String[]) - Static method in class org.sim0mq.test.threads.PushPullThreads

main(String[]) - Static method in class org.sim0mq.test.ZmqChat

Decentralized chat example

MM1FederationManager - Class in org.sim0mq.demo.mm1

Example implementation of a FederationManager to start the MM1Queue41Application DSOL model.

MM1FederationManager20 - Class in org.sim0mq.demo.mm1

Example implementation of a FederationManager to start the MM1Queue41Application DSOL model.

MM1FederationManager20.StateMachine - Class in org.sim0mq.demo.mm1

State machine to run several models in parallel.

MM1Queue41Application - Class in org.sim0mq.demo.mm1

Copyright (c) 2015-2020 Delft University of Technology, Jaffalaan 5, 2628 BX Delft, the Netherlands.

MM1Queue41Application(String, int) - Constructor for class org.sim0mq.demo.mm1.MM1Queue41Application

Construct a console application.

MM1Queue41Model - Class in org.sim0mq.demo.mm1

The M/M/1 example as published in Simulation Modeling and Analysis by A.M.

MM1Queue41Model(DEVSSimulatorInterface.TimeDouble) - Constructor for class org.sim0mq.demo.mm1.MM1Queue41Model

Construct the model.

O

org.sim0mq.demo - package org.sim0mq.demo

Demo classes for Sim0MQ.

org.sim0mq.demo.mm1 - package org.sim0mq.demo.mm1

MM1 DSOL model demo classes for Sim0MQ.

org.sim0mq.demo.reqrep - package org.sim0mq.demo.reqrep

Test classes for 0MQ.

org.sim0mq.test - package org.sim0mq.test

Test classes for 0MQ.

org.sim0mq.test.dealerrouter - package org.sim0mq.test.dealerrouter

Test of the DEALER - ROUTER pattern with multiple threads, inproc messages and workers.

org.sim0mq.test.pair - package org.sim0mq.test.pair

Example with the PAIR - PAIR pattern.

org.sim0mq.test.pubsub - package org.sim0mq.test.pubsub

A 0MQ example with publish/subscribe over the network using the PUB-SUB pattern, combined with a PAIR-PAIR pattern for flow control.

org.sim0mq.test.pushpull - package org.sim0mq.test.pushpull

PUSH-PULL examples for 0MQ.

org.sim0mq.test.reqrep - package org.sim0mq.test.reqrep

Example with the REQ - REP pattern.

org.sim0mq.test.threads - package org.sim0mq.test.threads

Studying the effect of multiple threads on the use of 0MQ sockets.

P

PairClient - Class in org.sim0mq.test.pair

Client-server implementation in 0MQ using the PAIR implementation.

PairClient.ListenThread - Class in org.sim0mq.test.pair

PairServer - Class in org.sim0mq.test.pair

Client-server implementation in 0MQ using the PAIR implementation.

PairServer.ListenThread - Class in org.sim0mq.test.pair

ProducerThread(PushPullThreads, int) - Constructor for class org.sim0mq.test.threads.PushPullThreads.ProducerThread

Publisher - Class in org.sim0mq.test.pubsub

The PUB-SUB pattern takes place on port 9001.

PushPullThreads - Class in org.sim0mq.test.threads

Play with three event producing threads that need to send their message via a shared method to a receiving thread that is listening.

PushPullThreads() - Constructor for class org.sim0mq.test.threads.PushPullThreads

Constructor.

PushPullThreads.ConsumerThread - Class in org.sim0mq.test.threads

PushPullThreads.ProducerThread - Class in org.sim0mq.test.threads

Q

qN - Variable in class org.sim0mq.demo.mm1.MM1Queue41Model

tally qN.

R

rand - Static variable in class org.sim0mq.test.dealerrouter.DealerRouter

random stream.

rand - Static variable in class org.sim0mq.test.RouterToReqExample

random stream.

recvStringWithTimeout(ZContext, ZMQ.Socket, long, String) - Static method in class org.sim0mq.test.RouterToReqExample

Rep - Class in org.sim0mq.demo.reqrep

Copyright (c) 2013-2020 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands.

Rep(String[]) - Constructor for class org.sim0mq.demo.reqrep.Rep

Rep.RepThread - Class in org.sim0mq.demo.reqrep

The worker thread for the REP requests.

RepThread(ZContext, int) - Constructor for class org.sim0mq.demo.reqrep.Rep.RepThread

Req - Class in org.sim0mq.demo.reqrep

Copyright (c) 2013-2020 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands.

Req(String[]) - Constructor for class org.sim0mq.demo.reqrep.Req

Req.ReqThread - Class in org.sim0mq.demo.reqrep

The worker thread for the REQ requests.

ReqThread(ZContext, int, long) - Constructor for class org.sim0mq.demo.reqrep.Req.ReqThread

RouterToReqExample - Class in org.sim0mq.test

Example from http://stackoverflow.com/questions/20944140/zeromq-route-req-java-example-does-not-work.

run() - Method in class org.sim0mq.demo.reqrep.Rep.RepThread

run() - Method in class org.sim0mq.demo.reqrep.Req.ReqThread

run() - Method in class org.sim0mq.demo.Server.Worker

run() - Method in class org.sim0mq.test.dealerrouter.DealerRouter.ClientTask

run() - Method in class org.sim0mq.test.dealerrouter.DealerRouter.ServerTask

run() - Method in class org.sim0mq.test.pair.PairClient.ListenThread

run() - Method in class org.sim0mq.test.pair.PairServer.ListenThread

run() - Method in class org.sim0mq.test.threads.PushPullThreads.ConsumerThread

run() - Method in class org.sim0mq.test.threads.PushPullThreads.ProducerThread

run(Object[], ZContext, ZMQ.Socket) - Method in class org.sim0mq.test.ZmqChat.ListenerTask

S

seed - Variable in class org.sim0mq.demo.mm1.MM1Queue41Model

PARAMETER seed.

Server - Class in org.sim0mq.demo

Server example for JeroMQ / ZeroMQ.

Server() - Constructor for class org.sim0mq.demo.Server

Server.Worker - Class in org.sim0mq.demo

ServerTask() - Constructor for class org.sim0mq.test.dealerrouter.DealerRouter.ServerTask

serviceTime - Variable in class org.sim0mq.demo.mm1.MM1Queue41Model

PARAMETER serviceTime.

startListener(int) - Method in class org.sim0mq.demo.mm1.MM1Queue41Application

Start listening on a port.

StateMachine(AtomicLong, String, String, int, String, int) - Constructor for class org.sim0mq.demo.mm1.MM1FederationManager20.StateMachine

staticBrokerIdRecv - Static variable in class org.sim0mq.test.RouterToReqExample

static counter for broker identity.

staticBrokerMsgRecv - Static variable in class org.sim0mq.test.RouterToReqExample

static counter for broker Message.

staticWorkerRecv - Static variable in class org.sim0mq.test.RouterToReqExample

static counter for worker.

string2byte(String) - Static method in class org.sim0mq.test.reqrep.Tic

Turn String into byte array with closing zero.

Subscriber - Class in org.sim0mq.test.pubsub

The PUB-SUB pattern takes place on port 9001.

T

terminate() - Method in class org.sim0mq.demo.mm1.MM1Queue41Application

stop the simulation.

Tic - Class in org.sim0mq.test.reqrep

Client example for JeroMQ / ZeroMQ.

Toc - Class in org.sim0mq.test.reqrep

Server example for JeroMQ / ZeroMQ.

U

uN - Variable in class org.sim0mq.demo.mm1.MM1Queue41Model

utilization uN.

W

Worker(Server) - Constructor for class org.sim0mq.demo.Server.Worker

Constructor.

Z

ZmqChat - Class in org.sim0mq.test

Copyright (c) 2013-2017 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands.

ZmqChat() - Constructor for class org.sim0mq.test.ZmqChat

ZmqChat.ListenerTask - Class in org.sim0mq.test

B C D G I L M O P Q R S T U W Z
All Classes All Packages