Package zmq.pipe

Class Pipe


public class Pipe extends ZObject
  • Field Details

    • inpipe

      private YPipeBase<Msg> inpipe
    • outpipe

      private YPipeBase<Msg> outpipe
    • 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
    • sink

      private Pipe.IPipeEvents sink
    • state

      private Pipe.State state
    • delay

      private boolean delay
    • identity

      private Blob identity
    • credential

      private Blob credential
    • conflate

      private final boolean conflate
    • parent

      private final ZObject parent
  • Constructor Details

  • Method Details

    • pair

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

      private void setPeer(Pipe peer)
    • setEventSink

      public void setEventSink(Pipe.IPipeEvents sink)
    • setIdentity

      public void setIdentity(Blob identity)
    • getIdentity

      public Blob getIdentity()
    • 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()
    • processActivateRead

      protected void processActivateRead()
      Overrides:
      processActivateRead in class ZObject
    • processActivateWrite

      protected void processActivateWrite(long msgsRead)
      Overrides:
      processActivateWrite in class ZObject
    • processHiccup

      protected void processHiccup(YPipeBase<Msg> pipe)
      Overrides:
      processHiccup in class ZObject
    • processPipeTerm

      protected void processPipeTerm()
      Overrides:
      processPipeTerm in class ZObject
    • processPipeTermAck

      protected void processPipeTermAck()
      Overrides:
      processPipeTermAck in class ZObject
    • 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()
    • toString

      public String toString()
      Overrides:
      toString in class Object