Package zmq.io.mechanism
Class Mechanism
java.lang.Object
zmq.io.mechanism.Mechanism
- Direct Known Subclasses:
CurveClientMechanism
,CurveServerMechanism
,GssapiClientMechanism
,GssapiServerMechanism
,NullMechanism
,PlainClientMechanism
,PlainServerMechanism
-
Nested Class Summary
Nested Classes -
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
Mechanism
(SessionBase session, Address peerAddress, Options options) -
Method Summary
Modifier and TypeMethodDescriptionprotected final void
addProperty
(ByteBuffer buf, String name, byte[] value) protected final void
addProperty
(ByteBuffer buf, String name, String value) protected final void
addProperty
(Msg msg, String name, byte[] value) protected final void
addProperty
(Msg msg, String name, String value) protected boolean
compare
(ByteBuffer a1, byte[] b, int offset, int length) protected boolean
void
destroy()
final Blob
abstract int
nextHandshakeCommand
(Msg msg) protected final int
parseMetadata
(ByteBuffer msg, int offset, boolean zapFlag) protected final int
parseMetadata
(Msg msg, int offset, boolean zapFlag) final Msg
abstract int
protected int
protected final int
protected final void
sendZapRequest
(Mechanisms mechanism, boolean more) private void
setPeerIdentity
(byte[] data) private void
setUserId
(byte[] data) protected final String
socketType
(int socketType) abstract Mechanism.Status
status()
abstract int
-
Field Details
-
options
-
identity
-
userId
-
zapProperties
-
zmtpProperties
-
session
-
peerAddress
-
statusCode
-
-
Constructor Details
-
Mechanism
-
-
Method Details
-
status
-
setPeerIdentity
private void setPeerIdentity(byte[] data) -
peerIdentity
-
setUserId
private void setUserId(byte[] data) -
getUserId
-
addProperty
-
addProperty
-
addProperty
-
addProperty
-
parseMetadata
-
parseMetadata
-
property
-
socketType
-
compare
-
compare
-
decode
-
encode
-
zapMsgAvailable
public abstract int zapMsgAvailable() -
processHandshakeCommand
-
nextHandshakeCommand
-
sendZapRequest
-
receiveAndProcessZapReply
protected final int receiveAndProcessZapReply() -
destroy
public void destroy()
-