Class ArteryTcpTransport

    • Method Detail

      • optionToTry

        public static scala.util.Try<scala.runtime.BoxedUnit> optionToTry​(scala.Option<java.lang.Throwable> opt)
      • bindInboundStreams

        protected scala.Tuple2<java.lang.Object,​java.lang.Object> bindInboundStreams()
        Description copied from class: ArteryTransport
        Bind to the ports for inbound streams. If '0' is specified, this will also select an arbitrary free local port. For UDP, we only select the port and leave the actual binding to Aeron when running the inbound stream.

        After calling this method the 'localAddress' and 'bindAddress' fields can be set.

        Specified by:
        bindInboundStreams in class ArteryTransport
        Returns:
        (undocumented)
      • runInboundStreams

        protected void runInboundStreams​(int port,
                                         int bindPort)
        Description copied from class: ArteryTransport
        Run the inbound streams that have been previously bound.

        Before calling this method the 'localAddress' and 'bindAddress' should have been set.

        Specified by:
        runInboundStreams in class ArteryTransport
        Parameters:
        port - (undocumented)
        bindPort - (undocumented)