Package zmq.pipe

Class Pipe


  • public class Pipe
    extends ZObject
    • Field Detail

      • inActive

        private boolean inActive
      • outActive

        private boolean outActive
      • hwm

        private int hwm
      • lwm

        private int lwm
      • msgsRead

        private long msgsRead
      • msgsWritten

        private long msgsWritten
      • peersMsgsRead

        private long peersMsgsRead
      • peer

        private Pipe peer
      • delay

        private boolean delay
      • identity

        private Blob identity
      • routingId

        private int routingId
      • credential

        private Blob credential
      • conflate

        private final boolean conflate
      • disconnectMsg

        private Msg disconnectMsg
      • parent

        private final ZObject parent
    • Method Detail

      • pair

        public static Pipe[] pair​(ZObject[] parents,
                                  int[] hwms,
                                  boolean[] conflates)
      • setPeer

        private void setPeer​(Pipe peer)
      • setIdentity

        public void setIdentity​(Blob identity)
      • getIdentity

        public Blob getIdentity()
      • setRoutingId

        public void setRoutingId​(int routingId)
      • getRoutingId

        public int getRoutingId()
      • getCredential

        public Blob getCredential()
      • checkRead

        public boolean checkRead()
      • read

        public Msg read()
      • checkWrite

        public boolean checkWrite()
      • write

        public boolean write​(Msg msg)
      • rollback

        public void rollback()
      • flush

        public void flush()
      • setNoDelay

        public void setNoDelay()
      • terminate

        public void terminate​(boolean delay)
      • isDelimiter

        private static boolean isDelimiter​(Msg msg)
      • computeLwm

        private static int computeLwm​(int hwm)
      • processDelimiter

        private void processDelimiter()
      • hiccup

        public void hiccup()
      • setHwms

        public void setHwms​(int inhwm,
                            int outhwm)
      • checkHwm

        public boolean checkHwm()
      • setDisconnectMsg

        public void setDisconnectMsg​(Msg msg)
      • sendDisconnectMsg

        public void sendDisconnectMsg()
      • sendHiccupMsg

        public void sendHiccupMsg​(Msg hiccupMsg)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object