public final class RouterToReqExample extends Object
BSD-style license. See OpenTrafficSim License.
$LastChangedDate: 2015-07-24 02:58:59 +0200 (Fri, 24 Jul 2015) $, @version $Revision: 1147 $, by $Author: averbraeck $, initial version Apr 20, 2017Modifier and Type | Field and Description |
---|---|
(package private) static AtomicInteger |
completed
completed.
|
(package private) static Random |
rand
random stream.
|
(package private) static AtomicInteger |
staticBrokerIdRecv
static counter for broker identity.
|
(package private) static AtomicInteger |
staticBrokerMsgRecv
static counter for broker Message.
|
(package private) static AtomicInteger |
staticWorkerRecv
static counter for worker.
|
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args)
While this example runs in a single process, that is just to make it easier to start and stop the example.
|
(package private) static String |
recvStringWithTimeout(org.zeromq.ZContext context,
org.zeromq.ZMQ.Socket socket,
long timeoutMs,
String resend) |
static Random rand
static AtomicInteger staticWorkerRecv
static AtomicInteger staticBrokerIdRecv
static AtomicInteger staticBrokerMsgRecv
static AtomicInteger completed
public static void main(String[] args) throws Exception
args
- args, can be emptyException
- on errorstatic String recvStringWithTimeout(org.zeromq.ZContext context, org.zeromq.ZMQ.Socket socket, long timeoutMs, String resend)
context
- the contextsocket
- the sockettimeoutMs
- timeout in millisecondsresend
- string to resend if it failsCopyright © 2016–2019. All rights reserved.