public interface MasterProcessChannelProcessorFactory extends Closeable
Modifier and Type | Method and Description |
---|---|
boolean |
canUse(String channelConfig)
Evaluates the
channelConfig . |
void |
connect(String channelConfig)
Open a new connection.
|
MasterProcessChannelDecoder |
createDecoder(ForkNodeArguments forkingArguments)
Decoder factory method.
|
MasterProcessChannelEncoder |
createEncoder(ForkNodeArguments forkingArguments)
Encoder factory method.
|
boolean canUse(String channelConfig)
channelConfig
.channelConfig
- a connection string used by the fork JVMtrue
if channelConfig
is applicable and thus this SPI is eligible in the forkvoid connect(String channelConfig) throws IOException
channelConfig
- e.g. "pipe://3" or "tcp://localhost:65035"IOException
- if cannot connectMasterProcessChannelDecoder createDecoder(@Nonnull ForkNodeArguments forkingArguments) throws IOException
forkingArguments
- forking argumentsIOException
MasterProcessChannelEncoder createEncoder(@Nonnull ForkNodeArguments forkingArguments) throws IOException
forkingArguments
- forking argumentsIOException
Copyright © 2004–2024 The Apache Software Foundation. All rights reserved.