Class CompositeFrontendMessage

java.lang.Object
io.r2dbc.postgresql.message.frontend.CompositeFrontendMessage
All Implemented Interfaces:
FrontendMessage, FrontendMessage.DirectEncoder
public final class CompositeFrontendMessage extends Object implements FrontendMessage, FrontendMessage.DirectEncoder
FrontendMessage that aggregates FrontendMessage, specifically FrontendMessage.DirectEncoder messages to send multiple FrontendMessage in a single TCP packet.
Since:
0.8.6

  • Constructor Details

  • Method Details

    • contains

      public boolean contains(FrontendMessage message)

    • encode

      public Publisher<io.netty.buffer.ByteBuf> encode(io.netty.buffer.ByteBufAllocator byteBufAllocator)
      Description copied from interface: FrontendMessage
      Encode a message into a ByteBuf.
      Specified by:
      encode in interface FrontendMessage
      Parameters:
      byteBufAllocator - the byteBufAllocator to use to get a ByteBuf to write into
      Returns:
      a Publisher that produces the ByteBuf containing the encoded message

    • encode

      public void encode(io.netty.buffer.ByteBuf byteBuf)
      Description copied from interface: FrontendMessage.DirectEncoder
      Encode a message directly by writing its content to a ByteBuf.
      Specified by:
      encode in interface FrontendMessage.DirectEncoder
      Parameters:
      byteBuf - the target ByteBuf to write into

    • dispose

      public void dispose()
      Description copied from interface: FrontendMessage
      Release any resources (such as bound parameter buffers) held by this message without encoding it. Invoked when a message is discarded before reaching the wire, e.g. when the connection is closed or the conversation is cancelled while the message is still queued. The default implementation does nothing. Implementations that own reference-counted buffers must release them here and must be idempotent so that disposal is safe regardless of whether the message was already encoded.
      Specified by:
      dispose in interface FrontendMessage

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object