Package zmq

Class Msg

Direct Known Subclasses:
Msg.Builder

public class Msg extends Object
  • Field Details

  • Constructor Details

    • Msg

      public Msg()
    • Msg

      public Msg(int capacity)
    • Msg

      public Msg(byte[] src)
    • Msg

      public Msg(ByteBuffer src)
    • Msg

      public Msg(Msg m)
    • Msg

      private Msg(Msg src, ByteArrayOutputStream out)
  • Method Details

    • isIdentity

      public boolean isIdentity()
    • isDelimiter

      public boolean isDelimiter()
    • isJoin

      public boolean isJoin()
    • isLeave

      public boolean isLeave()
    • check

      public boolean check()
    • flags

      public int flags()
    • hasMore

      public boolean hasMore()
    • isCommand

      public boolean isCommand()
    • isCredential

      public boolean isCredential()
    • setFlags

      public void setFlags(int flags)
    • initDelimiter

      public void initDelimiter()
    • initJoin

      public void initJoin()
    • initLeave

      public void initLeave()
    • data

      public byte[] data()
      Returns the message data. If possible, a reference to the data is returned, without copy. Otherwise a new byte array will be allocated and the data will be copied.
      Returns:
      the message data.
    • buf

      public ByteBuffer buf()
    • size

      public int size()
    • resetFlags

      public void resetFlags(int f)
    • setFd

      public void setFd(SocketChannel fileDesc)
    • fd

      public SocketChannel fd()
    • getMetadata

      public Metadata getMetadata()
    • setMetadata

      public Msg setMetadata(Metadata metadata)
    • resetMetadata

      public void resetMetadata()
    • get

      public byte get()
    • get

      public byte get(int index)
    • put

      public Msg put(byte b)
    • put

      public Msg put(int b)
    • put

      protected Msg put(int index, byte b)
    • put

      public Msg put(byte[] src)
    • put

      public Msg put(byte[] src, int off, int len)
    • put

      public Msg put(ByteBuffer src, int off, int len)
    • put

      public Msg put(ByteBuffer src)
    • getBytes

      public int getBytes(int index, byte[] dst, int off, int len)
    • getBytes

      public int getBytes(int index, ByteBuffer bb, int len)
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • getWriteIndex

      protected final int getWriteIndex()
    • setWriteIndex

      protected final void setWriteIndex(int writeIndex)
    • getLong

      public long getLong(int offset)
    • getInt

      public int getInt(int offset)
    • getShort

      public int getShort(int offset)
    • transfer

      public void transfer(ByteBuffer destination, int srcOffset, int srcLength)
    • putShortString

      public Msg putShortString(String data)
      Puts a string into the message, prefixed with its length. Users shall size the message by adding 1 to the length of the string: It needs to be able to accommodate (data.length+1) more bytes.
      Parameters:
      data - a string shorter than 256 characters. If null, defaults to a no-op.
      Returns:
      the same message.
    • getRoutingId

      public int getRoutingId()
      Return the routing id of a message. The routing id represent the CLIENT socket that sent the message to the SERVER socket.
      Returns:
      the routing id
    • setRoutingId

      public boolean setRoutingId(int routingId)
      Set the routing id on a message. The routing id represent the CLIENT socket which the message should be sent to. Only SERVER socket is currently using the routing id.
      Parameters:
      routingId - the routing id
      Returns:
      true if successfully set the routing id.
    • getGroup

      public String getGroup()
      Retrieve the group for RADIO/DISH sockets
      Returns:
      the group.
    • setGroup

      public boolean setGroup(String group)
      Set the group for RADIO/DISH sockets
      Parameters:
      group -
      Returns:
      true if successfully set the group.
    • resetRoutingId

      public void resetRoutingId()