Class Mechanism

    • Field Detail

      • options

        protected final Options options
      • identity

        private Blob identity
      • userId

        private Blob userId
      • zapProperties

        public final Metadata zapProperties
      • zmtpProperties

        public final Metadata zmtpProperties
      • peerAddress

        private final Address peerAddress
      • statusCode

        protected java.lang.String statusCode
    • Method Detail

      • 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​(java.nio.ByteBuffer buf,
                                         java.lang.String name,
                                         java.lang.String value)
      • addProperty

        protected final void addProperty​(Msg msg,
                                         java.lang.String name,
                                         java.lang.String value)
      • addProperty

        protected final void addProperty​(java.nio.ByteBuffer buf,
                                         java.lang.String name,
                                         byte[] value)
      • addProperty

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

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

        protected final int parseMetadata​(java.nio.ByteBuffer msg,
                                          int offset,
                                          boolean zapFlag)
      • property

        protected int property​(java.lang.String name,
                               byte[] value)
      • socketType

        protected final java.lang.String socketType​(int socketType)
      • compare

        protected boolean compare​(Msg msg,
                                  java.lang.String data,
                                  boolean includeLength)
      • compare

        protected boolean compare​(java.nio.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()