Package zmq.io.mechanism.plain
Class PlainServerMechanism
- java.lang.Object
-
- zmq.io.mechanism.Mechanism
-
- zmq.io.mechanism.plain.PlainServerMechanism
-
public class PlainServerMechanism extends Mechanism
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static classPlainServerMechanism.State-
Nested classes/interfaces inherited from class zmq.io.mechanism.Mechanism
Mechanism.Status
-
-
Field Summary
Fields Modifier and Type Field Description private PlainServerMechanism.Statestate-
Fields inherited from class zmq.io.mechanism.Mechanism
options, session, statusCode, zapProperties, zmtpProperties
-
-
Constructor Summary
Constructors Constructor Description PlainServerMechanism(SessionBase session, Address peerAddress, Options options)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intnextHandshakeCommand(Msg msg)intprocessHandshakeCommand(Msg msg)private intproduceError(Msg msg)private intproduceHello(Msg msg)private intproduceInitiate(Msg msg)private intproduceReady(Msg msg)private intproduceWelcome(Msg msg)private voidsendZapRequest(byte[] username, byte[] password)Mechanism.Statusstatus()intzapMsgAvailable()-
Methods inherited from class zmq.io.mechanism.Mechanism
addProperty, addProperty, addProperty, addProperty, compare, compare, decode, destroy, encode, getUserId, handleErrorReason, parseErrorMessage, parseMetadata, parseMetadata, peerIdentity, property, receiveAndProcessZapReply, sendZapRequest, socketType
-
-
-
-
Field Detail
-
state
private PlainServerMechanism.State state
-
-
Constructor Detail
-
PlainServerMechanism
public PlainServerMechanism(SessionBase session, Address peerAddress, Options options)
-
-
Method Detail
-
nextHandshakeCommand
public int nextHandshakeCommand(Msg msg)
- Specified by:
nextHandshakeCommandin classMechanism
-
processHandshakeCommand
public int processHandshakeCommand(Msg msg)
- Specified by:
processHandshakeCommandin classMechanism
-
status
public Mechanism.Status status()
-
zapMsgAvailable
public int zapMsgAvailable()
- Specified by:
zapMsgAvailablein classMechanism
-
produceHello
private int produceHello(Msg msg)
-
produceWelcome
private int produceWelcome(Msg msg)
-
produceInitiate
private int produceInitiate(Msg msg)
-
produceReady
private int produceReady(Msg msg)
-
produceError
private int produceError(Msg msg)
-
sendZapRequest
private void sendZapRequest(byte[] username, byte[] password)
-
-