Skip to content

Commit c18d41f

Browse files
committed
work in progress but posting for others to see
1 parent fd77051 commit c18d41f

28 files changed

+1757
-2828
lines changed

api/src/test/java/com/ning/http/client/async/AbstractBasicTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,8 @@
4141
import java.net.ServerSocket;
4242
import java.util.Enumeration;
4343

44+
import junit.framework.TestCase;
45+
4446
public abstract class AbstractBasicTest {
4547
protected final Logger log = LoggerFactory.getLogger(AbstractBasicTest.class);
4648
protected Server server;

providers/channelmgr/src/main/java/com/ning/http/client/providers/chanmgr/ChanMgrAsyncHttpProvider.java

Lines changed: 783 additions & 0 deletions
Large diffs are not rendered by default.
Lines changed: 4 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -25,42 +25,12 @@
2525
/**
2626
* This class can be used to pass Netty's internal configuration options. See Netty documentation for more information.
2727
*/
28-
public class NettyAsyncHttpProviderConfig implements AsyncHttpProviderConfig<String, Object> {
29-
30-
/**
31-
* Use Netty's blocking IO stategy.
32-
*/
33-
public final static String USE_BLOCKING_IO = "useBlockingIO";
34-
35-
/**
36-
* Use direct {@link java.nio.ByteBuffer}
37-
*/
38-
public final static String USE_DIRECT_BYTEBUFFER = "bufferFactory";
39-
40-
/**
41-
* Execute the connect operation asynchronously.
42-
*/
43-
public final static String EXECUTE_ASYNC_CONNECT = "asyncConnect";
44-
45-
/**
46-
* Allow nested request from any {@link com.ning.http.client.AsyncHandler}
47-
*/
48-
public final static String DISABLE_NESTED_REQUEST = "disableNestedRequest";
49-
50-
/**
51-
* Allow configuring the Netty's boss executor service.
52-
*/
53-
public final static String BOSS_EXECUTOR_SERVICE = "bossExecutorService";
54-
55-
/**
56-
* See {@link java.net.Socket#setReuseAddress(boolean)}
57-
*/
58-
public final static String REUSE_ADDRESS = "reuseAddress";
28+
public class ChanMgrAsyncHttpProviderConfig implements AsyncHttpProviderConfig<String, Object> {
5929

6030
private final ConcurrentHashMap<String, Object> properties = new ConcurrentHashMap<String, Object>();
6131

62-
public NettyAsyncHttpProviderConfig() {
63-
properties.put(REUSE_ADDRESS, "false");
32+
public ChanMgrAsyncHttpProviderConfig() {
33+
//properties.put(REUSE_ADDRESS, "false");
6434
}
6535

6636
/**
@@ -70,7 +40,7 @@ public NettyAsyncHttpProviderConfig() {
7040
* @param value the value of the property
7141
* @return this instance of AsyncHttpProviderConfig
7242
*/
73-
public NettyAsyncHttpProviderConfig addProperty(String name, Object value) {
43+
public ChanMgrAsyncHttpProviderConfig addProperty(String name, Object value) {
7444
properties.put(name, value);
7545
return this;
7646
}

0 commit comments

Comments
 (0)