Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGreg Wilkins2012-06-07 12:11:40 +0000
committerGreg Wilkins2012-06-07 12:11:40 +0000
commit0b56e3ae7c63e4967bd3af668fdffa0c8fb2cc1e (patch)
tree73f478055e326fbe09d827b861020c57970948e5 /jetty-client
parentd1bc48de70b819dcc07e005c8674166d3248c8b4 (diff)
downloadorg.eclipse.jetty.project-0b56e3ae7c63e4967bd3af668fdffa0c8fb2cc1e.tar.gz
org.eclipse.jetty.project-0b56e3ae7c63e4967bd3af668fdffa0c8fb2cc1e.tar.xz
org.eclipse.jetty.project-0b56e3ae7c63e4967bd3af668fdffa0c8fb2cc1e.zip
jetty-9 starting to cleanup websocket and client
Diffstat (limited to 'jetty-client')
-rw-r--r--jetty-client/pom.xml3
-rw-r--r--jetty-client/src/main/java/org/eclipse/jetty/client/HttpExchange.java75
2 files changed, 11 insertions, 67 deletions
diff --git a/jetty-client/pom.xml b/jetty-client/pom.xml
index 3249d8d1bd..f9a0495f88 100644
--- a/jetty-client/pom.xml
+++ b/jetty-client/pom.xml
@@ -106,12 +106,13 @@
<version>${project.version}</version>
<scope>test</scope>
</dependency>
+ <!--
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-websocket</artifactId>
<version>${project.version}</version>
<scope>test</scope>
- </dependency>
+ </dependency>-->
<dependency>
<groupId>org.eclipse.jetty.toolchain</groupId>
<artifactId>jetty-test-helper</artifactId>
diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpExchange.java b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpExchange.java
index f7c5ce17a4..d9133cb354 100644
--- a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpExchange.java
+++ b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpExchange.java
@@ -16,6 +16,7 @@ package org.eclipse.jetty.client;
import java.io.IOException;
import java.io.InputStream;
import java.net.URI;
+import java.nio.ByteBuffer;
import java.util.concurrent.atomic.AtomicInteger;
import org.eclipse.jetty.client.security.SecurityListener;
@@ -26,9 +27,6 @@ import org.eclipse.jetty.http.HttpScheme;
import org.eclipse.jetty.http.HttpURI;
import org.eclipse.jetty.http.HttpVersion;
-import org.eclipse.jetty.io.BufferCache.ByteBuffer;
-import org.eclipse.jetty.io.ByteArrayBuffer;
-import org.eclipse.jetty.io.Connection;
import org.eclipse.jetty.io.EndPoint;
import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
@@ -88,10 +86,10 @@ public class HttpExchange
public static final int STATUS_CANCELLED = 11;
// HTTP protocol fields
- private String _method = HttpMethod.GET;
- private ByteBuffer _scheme = HttpScheme.HTTP_BUFFER;
+ private String _method = HttpMethod.GET.asString();
+ private String _scheme = HttpScheme.HTTP.asString();
private String _uri;
- private int _version = HttpVersion.HTTP_1_1_ORDINAL;
+ private HttpVersion _version = HttpVersion.HTTP_1_1;
private Address _address;
private final HttpFields _requestFields = new HttpFields();
private ByteBuffer _requestContent;
@@ -459,32 +457,16 @@ public class HttpExchange
* @param scheme
* the scheme of the URL (for example 'http')
*/
- public void setScheme(ByteBuffer scheme)
+ public void setScheme(String scheme)
{
_scheme = scheme;
}
- /**
- * @param scheme
- * the scheme of the URL (for example 'http')
- */
- public void setScheme(String scheme)
- {
- if (scheme != null)
- {
- if (HttpScheme.HTTP.equalsIgnoreCase(scheme))
- setScheme(HttpScheme.HTTP_BUFFER);
- else if (HttpScheme.HTTPS.equalsIgnoreCase(scheme))
- setScheme(HttpScheme.HTTPS_BUFFER);
- else
- setScheme(new ByteArrayBuffer(scheme));
- }
- }
/**
* @return the scheme of the URL
*/
- public ByteBuffer getScheme()
+ public String getScheme()
{
return _scheme;
}
@@ -493,29 +475,16 @@ public class HttpExchange
* @param version
* the HTTP protocol version as integer, 9, 10 or 11 for 0.9, 1.0 or 1.1
*/
- public void setVersion(int version)
+ public void setVersion(HttpVersion version)
{
_version = version;
}
/**
- * @param version
- * the HTTP protocol version as string
- */
- public void setVersion(String version)
- {
- CachedBuffer v = HttpVersion.CACHE.get(version);
- if (v == null)
- _version = 10;
- else
- _version = v.getOrdinal();
- }
-
- /**
* @return the HTTP protocol version as integer
* @see #setVersion(int)
*/
- public int getVersion()
+ public HttpVersion getVersion()
{
return _version;
}
@@ -635,19 +604,6 @@ public class HttpExchange
}
/**
- * Adds the specified request header
- *
- * @param name
- * the header name
- * @param value
- * the header value
- */
- public void addRequestHeader(ByteBuffer name, ByteBuffer value)
- {
- getRequestFields().add(name,value);
- }
-
- /**
* Sets the specified request header
*
* @param name
@@ -661,25 +617,12 @@ public class HttpExchange
}
/**
- * Sets the specified request header
- *
- * @param name
- * the header name
- * @param value
- * the header value
- */
- public void setRequestHeader(ByteBuffer name, ByteBuffer value)
- {
- getRequestFields().put(name,value);
- }
-
- /**
* @param value
* the content type of the request
*/
public void setRequestContentType(String value)
{
- getRequestFields().put(HttpHeader.CONTENT_TYPE_BUFFER,value);
+ getRequestFields().put(HttpHeader.CONTENT_TYPE,value);
}
/**

Back to the top