1 package org.apache.maven.surefire.booter.spi;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import org.apache.maven.surefire.api.booter.MasterProcessChannelDecoder;
23 import org.apache.maven.surefire.api.booter.MasterProcessChannelEncoder;
24 import org.apache.maven.surefire.spi.MasterProcessChannelProcessorFactory;
25
26 import java.io.IOException;
27 import java.net.MalformedURLException;
28
29 import static org.apache.maven.surefire.api.util.internal.Channels.newBufferedChannel;
30
31
32
33
34
35
36
37
38 public class LegacyMasterProcessChannelProcessorFactory
39 implements MasterProcessChannelProcessorFactory
40 {
41 @Override
42 public boolean canUse( String channelConfig )
43 {
44 return channelConfig.startsWith( "pipe://" );
45 }
46
47 @Override
48 public void connect( String channelConfig ) throws IOException
49 {
50 if ( !canUse( channelConfig ) )
51 {
52 throw new MalformedURLException( "Unknown chanel string " + channelConfig );
53 }
54 }
55
56 @Override
57 public MasterProcessChannelDecoder createDecoder()
58 {
59 return new LegacyMasterProcessChannelDecoder( newBufferedChannel( System.in ) );
60 }
61
62 @Override
63 public MasterProcessChannelEncoder createEncoder()
64 {
65 return new LegacyMasterProcessChannelEncoder( newBufferedChannel( System.out ) );
66 }
67
68 @Override
69 public void close()
70 {
71 }
72 }