Add simple StdioServerTransportTest
This commit is contained in:
parent
7c9cf46e8a
commit
0dec9420c6
1 changed files with 139 additions and 2 deletions
|
|
@ -41,7 +41,7 @@ public class StdioServerTransport extends AbstractMcpTransport {
|
|||
private Scheduler outboundScheduler;
|
||||
private Scheduler errorScheduler;
|
||||
|
||||
private volatile boolean isRunning;
|
||||
volatile boolean isRunning;
|
||||
|
||||
private final ServerParameters params;
|
||||
|
||||
|
|
@ -74,7 +74,8 @@ public class StdioServerTransport extends AbstractMcpTransport {
|
|||
fullCommand.add(params.getCommand());
|
||||
fullCommand.addAll(params.getArgs());
|
||||
|
||||
ProcessBuilder processBuilder = new ProcessBuilder(fullCommand);
|
||||
ProcessBuilder processBuilder = this.getProcessBuilder();
|
||||
processBuilder.command(fullCommand);
|
||||
processBuilder.environment().putAll(params.getEnv());
|
||||
|
||||
// Start the process
|
||||
|
|
@ -102,6 +103,10 @@ public class StdioServerTransport extends AbstractMcpTransport {
|
|||
startErrorProcessing();
|
||||
}
|
||||
|
||||
protected ProcessBuilder getProcessBuilder() {
|
||||
return new ProcessBuilder();
|
||||
}
|
||||
|
||||
public void awaitForExit() {
|
||||
try {
|
||||
this.process.waitFor();
|
||||
|
|
|
|||
Loading…
Reference in a new issue