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

add Manager.Options

Browse Source
This commit is contained in:
Naoyuki Kanezawa
2014-07-12 22:54:00 +09:00
parent f33ccdf7f9
commit a928fae69e
2 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/github/nkzawa/socketio/client/IO.java
View File

@@ -79,7 +79,7 @@ public class IO {
} }
public static class Options extends com.github.nkzawa.engineio.client.Socket.Options { public static class Options extends Manager.Options {
public boolean forceNew; public boolean forceNew;
@@ -87,12 +87,5 @@ public class IO {
* Whether to enable multiplexing. Default is true. * Whether to enable multiplexing. Default is true.
*/ */
public boolean multiplex = true; public boolean multiplex = true;
public boolean reconnection = true;
public int reconnectionAttempts;
public long reconnectionDelay;
public long reconnectionDelayMax;
public long timeout = -1;
} }
} }

17
src/main/java/com/github/nkzawa/socketio/client/Manager.java
View File

@@ -81,7 +81,7 @@ public class Manager extends Emitter {
private URI uri; private URI uri;
private List<Packet> packetBuffer; private List<Packet> packetBuffer;
private Queue<On.Handle> subs; private Queue<On.Handle> subs;
private IO.Options opts; private Options opts;
/*package*/ com.github.nkzawa.engineio.client.Socket engine; /*package*/ com.github.nkzawa.engineio.client.Socket engine;
private Parser.Encoder encoder; private Parser.Encoder encoder;
private Parser.Decoder decoder; private Parser.Decoder decoder;
@@ -103,13 +103,13 @@ public class Manager extends Emitter {
this(uri, null); this(uri, null);
} }
public Manager(IO.Options opts) { public Manager(Options opts) {
this(null, opts); this(null, opts);
} }
public Manager(URI uri, IO.Options opts) { public Manager(URI uri, Options opts) {
if (opts == null) { if (opts == null) {
opts = new IO.Options(); opts = new Options();
} }
if (opts.path == null) { if (opts.path == null) {
opts.path = "/socket.io"; opts.path = "/socket.io";
@@ -487,4 +487,13 @@ public class Manager extends Emitter {
super(uri, opts); super(uri, opts);
} }
} }
public static class Options extends com.github.nkzawa.engineio.client.Socket.Options {
public boolean reconnection = true;
public int reconnectionAttempts;
public long reconnectionDelay;
public long reconnectionDelayMax;
public long timeout = -1;
}
} }