Class FlowStackItemSession

  • All Implemented Interfaces:
    java.io.Externalizable , java.io.Serializable , java.lang.Comparable , org.apache.avro.generic.GenericContainer , org.apache.avro.generic.GenericRecord , org.apache.avro.generic.IndexedRecord , org.apache.avro.specific.SpecificRecord

    
    public class FlowStackItemSession
    extends SpecificRecordBase implements SpecificRecord
                        

    Represents a session in the flow stack.

    • Constructor Detail

      • FlowStackItemSession

        FlowStackItemSession()
        Default constructor.
      • FlowStackItemSession

        FlowStackItemSession(String sessionId, Boolean initiated)
        All-args constructor.
        Parameters:
        sessionId - The session ID.
        initiated - Flag to show if the session has sent a session init message or was initiated by a peer session.
    • Method Detail

      • getSessionId

         String getSessionId()

        Gets the value of the 'sessionId' field.

        Returns:

        The session ID.

      • setSessionId

         void setSessionId(String value)

        Sets the value of the 'sessionId' field. The session ID.

        Parameters:
        value - the value to set.
      • getInitiated

         boolean getInitiated()

        Gets the value of the 'initiated' field.

        Returns:

        Flag to show if the session has sent a session init message or was initiated by a peer session.

      • setInitiated

         void setInitiated(boolean value)

        Sets the value of the 'initiated' field. Flag to show if the session has sent a session init message or was initiated by a peer session.

        Parameters:
        value - the value to set.
      • getEncoder

         static BinaryMessageEncoder<FlowStackItemSession> getEncoder()

        Return the BinaryMessageEncoder instance used by this class.

        Returns:

        the message encoder used by this class

      • getDecoder

         static BinaryMessageDecoder<FlowStackItemSession> getDecoder()

        Return the BinaryMessageDecoder instance used by this class.

        Returns:

        the message decoder used by this class

      • createDecoder

         static BinaryMessageDecoder<FlowStackItemSession> createDecoder(SchemaStore resolver)

        Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.

        Parameters:
        resolver - a SchemaStore used to find schemas by fingerprint
        Returns:

        a BinaryMessageDecoder instance for this class backed by the given SchemaStore

      • toByteBuffer

         ByteBuffer toByteBuffer()

        Serializes this FlowStackItemSession to a ByteBuffer.

        Returns:

        a buffer holding the serialized data for this instance

      • fromByteBuffer

         static FlowStackItemSession fromByteBuffer(ByteBuffer b)

        Deserializes a FlowStackItemSession from a ByteBuffer.

        Parameters:
        b - a byte buffer holding serialized data for an instance of this class
        Returns:

        a FlowStackItemSession instance decoded from the given buffer

      • newBuilder

         static FlowStackItemSession.Builder newBuilder(FlowStackItemSession other)

        Creates a new FlowStackItemSession RecordBuilder by copying an existing FlowStackItemSession instance.

        Parameters:
        other - The existing instance to copy.
        Returns:

        A new FlowStackItemSession RecordBuilder