changed port to PORT
This commit is contained in:
parent
18239fce80
commit
9a1a9fe39b
1 changed files with 3 additions and 2 deletions
|
@ -17,6 +17,7 @@ public class SocketServer implements FrojCallable {
|
||||||
protected static BlockingQueue<String> messageQueue = new LinkedBlockingQueue<>();
|
protected static BlockingQueue<String> messageQueue = new LinkedBlockingQueue<>();
|
||||||
private static ServerSocket serverSocket;
|
private static ServerSocket serverSocket;
|
||||||
private final String EXIT_CODE = "EXIT";
|
private final String EXIT_CODE = "EXIT";
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public int arity() {
|
public int arity() {
|
||||||
return 1;
|
return 1;
|
||||||
|
@ -26,9 +27,9 @@ public class SocketServer implements FrojCallable {
|
||||||
public Object call(Interpreter interpreter, List<Object> arguments) {
|
public Object call(Interpreter interpreter, List<Object> arguments) {
|
||||||
try {
|
try {
|
||||||
Double param = (Double) arguments.get(0);
|
Double param = (Double) arguments.get(0);
|
||||||
int port = param.intValue();
|
final int PORT = param.intValue();
|
||||||
|
|
||||||
serverSocket = new ServerSocket(port);
|
serverSocket = new ServerSocket(PORT);
|
||||||
while (true) {
|
while (true) {
|
||||||
Socket socket = serverSocket.accept();
|
Socket socket = serverSocket.accept();
|
||||||
System.out.println("Incoming connection from " + socket.getInetAddress());
|
System.out.println("Incoming connection from " + socket.getInetAddress());
|
||||||
|
|
Loading…
Reference in a new issue