Interface MasterProcessChannelProcessorFactory

    • Method Detail

      • canUse

        boolean canUse​(java.lang.String channelConfig)
        Evaluates the channelConfig.
        Parameters:
        channelConfig - a connection string used by the fork JVM
        Returns:
        true if channelConfig is applicable and thus this SPI is eligible in the fork
      • connect

        void connect​(java.lang.String channelConfig)
              throws java.io.IOException
        Open a new connection.
        Parameters:
        channelConfig - e.g. "pipe://3" or "tcp://localhost:65035"
        Throws:
        java.io.IOException - if cannot connect
      • createDecoder

        MasterProcessChannelDecoder createDecoder​(@Nonnull
                                                  ForkNodeArguments forkingArguments)
                                           throws java.io.IOException
        Decoder factory method.
        Parameters:
        forkingArguments - forking arguments
        Returns:
        a new instance of decoder
        Throws:
        java.io.IOException
      • createEncoder

        MasterProcessChannelEncoder createEncoder​(@Nonnull
                                                  ForkNodeArguments forkingArguments)
                                           throws java.io.IOException
        Encoder factory method.
        Parameters:
        forkingArguments - forking arguments
        Returns:
        a new instance of encoder
        Throws:
        java.io.IOException