Author: rmannibucau
Date: Thu Sep 27 13:16:57 2012
New Revision: 1390994
URL: http://svn.apache.org/viewvc?rev=1390994&view=rev
Log:
integrating stophost and stopcommand in remote tomee arquillian adapter
Modified:
openejb/trunk/openejb/arquillian/arquillian-tomee-common/src/main/java/org/apache/openejb/arquillian/common/TomEEConfiguration.java
openejb/trunk/openejb/arquillian/arquillian-tomee-remote/src/main/java/org/apache/tomee/arquillian/remote/RemoteTomEEContainer.java
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/config/RemoteServer.java
Modified:
openejb/trunk/openejb/arquillian/arquillian-tomee-common/src/main/java/org/apache/openejb/arquillian/common/TomEEConfiguration.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/openejb/arquillian/arquillian-tomee-common/src/main/java/org/apache/openejb/arquillian/common/TomEEConfiguration.java?rev=1390994&r1=1390993&r2=1390994&view=diff
==============================================================================
---
openejb/trunk/openejb/arquillian/arquillian-tomee-common/src/main/java/org/apache/openejb/arquillian/common/TomEEConfiguration.java
(original)
+++
openejb/trunk/openejb/arquillian/arquillian-tomee-common/src/main/java/org/apache/openejb/arquillian/common/TomEEConfiguration.java
Thu Sep 27 13:16:57 2012
@@ -153,7 +153,7 @@ public class TomEEConfiguration implemen
}
public String getStopCommand() {
- return stopCommand + Character.toString((char) -1); // last char to
avoid warning/error log message
+ return stopCommand + Character.toString((char) 0); // last char to
avoid warning/error log message
}
public void setStopCommand(String stopCommand) {
Modified:
openejb/trunk/openejb/arquillian/arquillian-tomee-remote/src/main/java/org/apache/tomee/arquillian/remote/RemoteTomEEContainer.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/openejb/arquillian/arquillian-tomee-remote/src/main/java/org/apache/tomee/arquillian/remote/RemoteTomEEContainer.java?rev=1390994&r1=1390993&r2=1390994&view=diff
==============================================================================
---
openejb/trunk/openejb/arquillian/arquillian-tomee-remote/src/main/java/org/apache/tomee/arquillian/remote/RemoteTomEEContainer.java
(original)
+++
openejb/trunk/openejb/arquillian/arquillian-tomee-remote/src/main/java/org/apache/tomee/arquillian/remote/RemoteTomEEContainer.java
Thu Sep 27 13:16:57 2012
@@ -56,6 +56,7 @@ public class RemoteTomEEContainer extend
final String shutdownPort =
System.getProperty(RemoteServer.SERVER_SHUTDOWN_PORT);
final String shutdownHost =
System.getProperty(RemoteServer.SERVER_SHUTDOWN_HOST);
+ final String shutdownCommand =
System.getProperty(RemoteServer.SERVER_SHUTDOWN_COMMAND);
final String debug =
System.getProperty(RemoteServer.OPENEJB_SERVER_DEBUG);
final String debugPort =
System.getProperty(RemoteServer.SERVER_DEBUG_PORT);
@@ -64,7 +65,8 @@ public class RemoteTomEEContainer extend
configure();
System.setProperty(RemoteServer.SERVER_SHUTDOWN_PORT,
Integer.toString(configuration.getStopPort()));
- System.setProperty(RemoteServer.SERVER_SHUTDOWN_HOST,
configuration.getHost());
+ System.setProperty(RemoteServer.SERVER_SHUTDOWN_COMMAND,
configuration.getStopCommand());
+ System.setProperty(RemoteServer.SERVER_SHUTDOWN_HOST,
configuration.getStopHost());
if (configuration.isDebug()) {
System.setProperty(RemoteServer.OPENEJB_SERVER_DEBUG, "true");
System.setProperty(RemoteServer.SERVER_DEBUG_PORT,
Integer.toString(configuration.getDebugPort()));
@@ -78,6 +80,7 @@ public class RemoteTomEEContainer extend
} finally {
resetSystemProperty(RemoteServer.SERVER_SHUTDOWN_PORT,
shutdownPort);
resetSystemProperty(RemoteServer.SERVER_SHUTDOWN_HOST,
shutdownHost);
+ resetSystemProperty(RemoteServer.SERVER_SHUTDOWN_COMMAND,
shutdownCommand);
resetSystemProperty(RemoteServer.OPENEJB_SERVER_DEBUG, debug);
resetSystemProperty(RemoteServer.SERVER_DEBUG_PORT, debugPort);
}
Modified:
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/config/RemoteServer.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/config/RemoteServer.java?rev=1390994&r1=1390993&r2=1390994&view=diff
==============================================================================
---
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/config/RemoteServer.java
(original)
+++
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/config/RemoteServer.java
Thu Sep 27 13:16:57 2012
@@ -40,6 +40,7 @@ public class RemoteServer {
public static final String SERVER_DEBUG_PORT = "server.debug.port";
public static final String SERVER_SHUTDOWN_PORT = "server.shutdown.port";
public static final String SERVER_SHUTDOWN_HOST = "server.shutdown.host";
+ public static final String SERVER_SHUTDOWN_COMMAND =
"server.shutdown.command";
public static final String OPENEJB_SERVER_DEBUG = "openejb.server.debug";
private final boolean debug = options.get(OPENEJB_SERVER_DEBUG, false);
@@ -58,6 +59,7 @@ public class RemoteServer {
private final boolean verbose;
private final int shutdownPort;
private final String host;
+ private final String command;
public RemoteServer() {
this(options.get("connect.tries", 60), options.get("verbose", false));
@@ -70,6 +72,7 @@ public class RemoteServer {
tomcat = (home != null) && (new File(new File(home, "bin"),
"catalina.sh").exists());
shutdownPort = options.get(SERVER_SHUTDOWN_PORT, tomcat ? 8005 : 4200);
+ command = options.get(SERVER_SHUTDOWN_COMMAND, "SHUTDOWN");
host = options.get(SERVER_SHUTDOWN_HOST, "localhost");
}
@@ -417,13 +420,13 @@ public class RemoteServer {
System.out.println("[] STOP SERVER");
}
- String command = "SHUTDOWN" + Character.toString((char) 0); //
SHUTDOWN + EOF
+ String fcommand = command + Character.toString((char) 0); //
SHUTDOWN + EOF
Socket socket = null;
try {
socket= new Socket(host, shutdownPort);
OutputStream out = socket.getOutputStream();
- out.write(command.getBytes());
+ out.write(fcommand.getBytes());
} finally {
if (socket != null) {
socket.close();
