public class ZSocket
extends java.lang.Object
implements java.lang.AutoCloseable
ZeroMQ sockets being asynchronous means that the timings of the physical connection setup and tear down, reconnect and effective delivery are transparent to the user and organized by ZeroMQ itself. Further, messages may be queued in the event that a peer is unavailable to receive them.
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicBoolean |
isClosed |
private SocketBase |
socketBase |
Constructor and Description |
---|
ZSocket(int socketType)
Create a ZeroMQ socket
|
ZSocket(SocketType socketType)
Create a ZeroMQ socket
|
Modifier and Type | Method and Description |
---|---|
boolean |
bind(java.lang.String endpoint)
Creates an endpoint for accepting connections and binds to it.
|
void |
close() |
boolean |
connect(java.lang.String endpoint)
Connects the socket to an endpoint and then accepts incoming connections on that endpoint.
|
boolean |
disconnect(java.lang.String endpoint)
Disconnecting a socket from an endpoint.
|
private java.lang.Object |
getOption(int option) |
SocketType |
getSocketType()
Retrieve the socket type for the current 'socket'.
|
int |
getType()
Retrieve the socket type for the current 'socket'.
|
boolean |
hasReceiveMore()
Returns a boolean value indicating if the multipart message currently being read from the
Socket and has more message parts to follow. |
private void |
mayRaise() |
byte[] |
receive() |
byte[] |
receive(int flags) |
java.lang.String |
receiveStringUtf8() |
java.lang.String |
receiveStringUtf8(int flags) |
int |
send(byte[] b) |
int |
send(byte[] b,
int flags) |
boolean |
sendFrame(ZFrame frame,
int flags)
Send a frame
|
boolean |
sendMessage(ZMsg message) |
int |
sendStringUtf8(java.lang.String str) |
int |
sendStringUtf8(java.lang.String str,
int flags) |
private void |
setOption(int option,
java.lang.Object value) |
void |
subscribe(byte[] topic) |
void |
subscribe(java.lang.String topic) |
boolean |
unbind(java.lang.String endpoint)
Stop accepting connections on a socket.
|
void |
unsubscribe(byte[] topic) |
void |
unsubscribe(java.lang.String topic) |
private final SocketBase socketBase
private final java.util.concurrent.atomic.AtomicBoolean isClosed
public ZSocket(int socketType)
socketType
- ZeroMQ socket typepublic ZSocket(SocketType socketType)
socketType
- ZeroMQ Socket typepublic SocketType getSocketType()
public int getType()
getSocketType()
public boolean bind(java.lang.String endpoint)
The endpoint argument is a string consisting of two parts as follows: transport ://address. The transport part specifies the underlying transport protocol to use. The meaning of the address part is specific to the underlying transport protocol selected.
endpoint
- the endpoint to bind topublic boolean unbind(java.lang.String endpoint)
Shall unbind from the endpoint specified by the endpoint argument.
endpoint
- the endpoint to unbind frompublic boolean connect(java.lang.String endpoint)
The endpoint is a string consisting of a transport :// followed by an address. The transport specifies the underlying protocol to use. The address specifies the transport-specific address to connect to.
endpoint
- the endpoint to connect topublic boolean disconnect(java.lang.String endpoint)
endpoint
- the endpoint to disconnect frompublic final boolean hasReceiveMore()
Socket
and has more message parts to follow. If there are no message parts to follow or
if the message currently being read is not a multipart message a value of false shall be
returned. Otherwise, a value of true shall be returned.public void subscribe(byte[] topic)
public void subscribe(java.lang.String topic)
public void unsubscribe(byte[] topic)
public void unsubscribe(java.lang.String topic)
public int send(byte[] b)
public int send(byte[] b, int flags)
public boolean sendFrame(ZFrame frame, int flags)
frame
- flags
- public boolean sendMessage(ZMsg message)
public int sendStringUtf8(java.lang.String str)
public int sendStringUtf8(java.lang.String str, int flags)
public byte[] receive()
public byte[] receive(int flags)
public java.lang.String receiveStringUtf8()
public java.lang.String receiveStringUtf8(int flags)
private void mayRaise()
private void setOption(int option, java.lang.Object value)
private java.lang.Object getOption(int option)
public void close()
close
in interface java.lang.AutoCloseable