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()
Decoder factory method.
|
MasterProcessChannelEncoder |
createEncoder()
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://127.0.0.1:65035"IOException
- if cannot connectMasterProcessChannelDecoder createDecoder() throws IOException
IOException
MasterProcessChannelEncoder createEncoder() throws IOException
IOException
Copyright © 2004–2020 The Apache Software Foundation. All rights reserved.