Class Mechanism

java.lang.Object
zmq.io.mechanism.Mechanism
Direct Known Subclasses:
CurveClientMechanism, CurveServerMechanism, GssapiClientMechanism, GssapiServerMechanism, NullMechanism, PlainClientMechanism, PlainServerMechanism

public abstract class Mechanism extends Object
  • Field Details

    • options

      protected final Options options
    • identity

      private Blob identity
    • userId

      private Blob userId
    • zapProperties

      public final Metadata zapProperties
    • zmtpProperties

      public final Metadata zmtpProperties
    • session

      protected final SessionBase session
    • peerAddress

      private final Address peerAddress
    • statusCode

      protected String statusCode
  • Constructor Details

  • Method Details

    • status

      public abstract Mechanism.Status status()
    • setPeerIdentity

      private void setPeerIdentity(byte[] data)
    • peerIdentity

      public final Msg peerIdentity()
    • setUserId

      private void setUserId(byte[] data)
    • getUserId

      public final Blob getUserId()
    • addProperty

      protected final void addProperty(ByteBuffer buf, String name, String value)
    • addProperty

      protected final void addProperty(Msg msg, String name, String value)
    • addProperty

      protected final void addProperty(ByteBuffer buf, String name, byte[] value)
    • addProperty

      protected final void addProperty(Msg msg, String name, byte[] value)
    • parseMetadata

      protected final int parseMetadata(Msg msg, int offset, boolean zapFlag)
    • parseMetadata

      protected final int parseMetadata(ByteBuffer msg, int offset, boolean zapFlag)
    • property

      protected int property(String name, byte[] value)
    • socketType

      protected final String socketType(int socketType)
    • compare

      protected boolean compare(Msg msg, String data, boolean includeLength)
    • compare

      protected boolean compare(ByteBuffer a1, byte[] b, int offset, int length)
    • decode

      public Msg decode(Msg msg)
    • encode

      public Msg encode(Msg msg)
    • zapMsgAvailable

      public abstract int zapMsgAvailable()
    • processHandshakeCommand

      public abstract int processHandshakeCommand(Msg msg)
    • nextHandshakeCommand

      public abstract int nextHandshakeCommand(Msg msg)
    • sendZapRequest

      protected final void sendZapRequest(Mechanisms mechanism, boolean more)
    • receiveAndProcessZapReply

      protected final int receiveAndProcessZapReply()
    • destroy

      public void destroy()