public class ZeroMQ<T> extends Object
Constructor and Description |
---|
ZeroMQ(Environment env) |
ZeroMQ(Environment env,
Dispatcher dispatcher) |
ZeroMQ(Environment env,
String dispatcher) |
Modifier and Type | Method and Description |
---|---|
ZeroMQ<T> |
codec(Codec<Buffer,T,T> codec) |
Promise<ChannelStream<T,T>> |
createClient(String addrs,
int socketType) |
Promise<ChannelStream<T,T>> |
createServer(String addrs,
int socketType) |
Promise<ChannelStream<T,T>> |
dealer(String addrs) |
static String |
findSocketTypeName(int socketType) |
Promise<ChannelStream<T,T>> |
pull(String addrs) |
Promise<ChannelStream<T,T>> |
push(String addrs) |
Promise<ChannelStream<T,T>> |
reply(String addrs) |
Promise<ChannelStream<T,T>> |
request(String addrs) |
Promise<ChannelStream<T,T>> |
router(String addrs) |
void |
shutdown() |
public ZeroMQ(Environment env)
public ZeroMQ(Environment env, String dispatcher)
public ZeroMQ(Environment env, Dispatcher dispatcher)
public static String findSocketTypeName(int socketType)
public Promise<ChannelStream<T,T>> dealer(String addrs)
public Promise<ChannelStream<T,T>> push(String addrs)
public Promise<ChannelStream<T,T>> pull(String addrs)
public Promise<ChannelStream<T,T>> request(String addrs)
public Promise<ChannelStream<T,T>> reply(String addrs)
public Promise<ChannelStream<T,T>> router(String addrs)
public Promise<ChannelStream<T,T>> createClient(String addrs, int socketType)
public Promise<ChannelStream<T,T>> createServer(String addrs, int socketType)
public void shutdown()
Copyright © 2017. All rights reserved.