Package org.apache.maven.surefire.booter.spi

Class LegacyMasterProcessChannelProcessorFactory

java.lang.Object

org.apache.maven.surefire.booter.spi.AbstractMasterProcessChannelProcessorFactory

org.apache.maven.surefire.booter.spi.LegacyMasterProcessChannelProcessorFactory

All Implemented Interfaces:

Closeable, AutoCloseable, MasterProcessChannelProcessorFactory

public class LegacyMasterProcessChannelProcessorFactory
extends AbstractMasterProcessChannelProcessorFactory

Producer of encoder and decoder for process pipes.

Since:

3.0.0-M5

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	FLUSH_PERIOD_MILLIS

Constructor Summary

Constructors

Constructor	Description
LegacyMasterProcessChannelProcessorFactory()

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.apache.maven.surefire.booter.spi.AbstractMasterProcessChannelProcessorFactory

close, schedulePeriodicFlusher

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

FLUSH_PERIOD_MILLIS

private static final int FLUSH_PERIOD_MILLIS

See Also:

• Constant Field Values

Constructor Details

LegacyMasterProcessChannelProcessorFactory

public LegacyMasterProcessChannelProcessorFactory()

Method Details

canUse

public boolean canUse(String channelConfig)

Description copied from interface: MasterProcessChannelProcessorFactory

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

public void connect(String channelConfig)
             throws IOException

Description copied from interface: MasterProcessChannelProcessorFactory

Open a new connection.

Parameters:

channelConfig - e.g. "pipe://3" or "tcp://localhost:65035"

Throws:

IOException - if cannot connect

createDecoder

public MasterProcessChannelDecoder createDecoder(@Nonnull
 ForkNodeArguments forkingArguments)

Description copied from interface: MasterProcessChannelProcessorFactory

Decoder factory method.

Parameters:

forkingArguments - forking arguments

Returns:

a new instance of decoder

createEncoder

public MasterProcessChannelEncoder createEncoder(@Nonnull
 ForkNodeArguments forkingArguments)

Description copied from interface: MasterProcessChannelProcessorFactory

Encoder factory method.

Parameters:

forkingArguments - forking arguments

Returns:

a new instance of encoder