h4ckx0r/engine.io-client-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix to carry environment variables

Browse Source
This commit is contained in:
Naoyuki Kanezawa
2015-02-01 21:33:01 +09:00
parent a65a043c65
commit 5cd669abe4
4 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/test/java/com/github/nkzawa/engineio/client/Connection.java
View File

@@ -6,6 +6,8 @@ import org.junit.Before;
import java.io.BufferedReader; import java.io.BufferedReader;
import java.io.IOException; import java.io.IOException;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.*; import java.util.concurrent.*;
public abstract class Connection { public abstract class Connection {
@@ -78,6 +80,15 @@ public abstract class Connection {
} }
String[] createEnv() { String[] createEnv() {
return new String[] {"DEBUG=engine*", "PORT=" + PORT}; Map<String, String> env = new HashMap<String, String>(System.getenv());
env.put("DEBUG", "engine*");
env.put("PORT", String.valueOf(PORT));
String[] _env = new String[env.size()];
int i = 0;
for (String key : env.keySet()) {
_env[i] = key + "=" + env.get(key);
i++;
}
return _env;
} }
} }

4
src/test/java/com/github/nkzawa/engineio/client/executions/Connection.java
View File

@@ -4,13 +4,11 @@ import com.github.nkzawa.emitter.Emitter;
import com.github.nkzawa.engineio.client.Socket; import com.github.nkzawa.engineio.client.Socket;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.Map;
public class Connection { public class Connection {
public static void main(String[] args) throws URISyntaxException { public static void main(String[] args) throws URISyntaxException {
Map<String, String> env = System.getenv(); final Socket socket = new Socket("http://localhost:" + System.getenv("PORT"));
final Socket socket = new Socket("http://localhost:" + env.get("PORT"));
socket.on(Socket.EVENT_OPEN, new Emitter.Listener() { socket.on(Socket.EVENT_OPEN, new Emitter.Listener() {
@Override @Override
public void call(Object... args) { public void call(Object... args) {

4
src/test/java/com/github/nkzawa/engineio/client/executions/ConnectionFailure.java
View File

@@ -4,13 +4,11 @@ import com.github.nkzawa.emitter.Emitter;
import com.github.nkzawa.engineio.client.Socket; import com.github.nkzawa.engineio.client.Socket;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.Map;
public class ConnectionFailure { public class ConnectionFailure {
public static void main(String[] args) throws URISyntaxException { public static void main(String[] args) throws URISyntaxException {
Map<String, String> env = System.getenv(); int port = Integer.parseInt(System.getenv("PORT"));
int port = Integer.parseInt(env.get("PORT"));
port++; port++;
final Socket socket = new Socket("http://localhost:" + port); final Socket socket = new Socket("http://localhost:" + port);
socket.on(Socket.EVENT_CLOSE, new Emitter.Listener() { socket.on(Socket.EVENT_CLOSE, new Emitter.Listener() {

4
src/test/java/com/github/nkzawa/engineio/client/executions/ImmediateClose.java
View File

@@ -4,13 +4,11 @@ import com.github.nkzawa.emitter.Emitter;
import com.github.nkzawa.engineio.client.Socket; import com.github.nkzawa.engineio.client.Socket;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.Map;
public class ImmediateClose { public class ImmediateClose {
public static void main(String[] args) throws URISyntaxException { public static void main(String[] args) throws URISyntaxException {
Map<String, String> env = System.getenv(); final Socket socket = new Socket("http://localhost:" + System.getenv("PORT"));
final Socket socket = new Socket("http://localhost:" + env.get("PORT"));
socket.on(Socket.EVENT_OPEN, new Emitter.Listener() { socket.on(Socket.EVENT_OPEN, new Emitter.Listener() {
@Override @Override
public void call(Object... args) { public void call(Object... args) {