org.jumpmind.symmetric.transport.http

Class Http2Connection

java.lang.Object

org.jumpmind.symmetric.transport.http.HttpConnection

org.jumpmind.symmetric.transport.http.Http2Connection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class Http2Connection
extends HttpConnection

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	Http2Connection.BlockingOutputStream
protected class	Http2Connection.BlockingRequestBody
protected class	Http2Connection.CallableResponse

Field Summary

Fields

Modifier and Type	Field and Description
protected okhttp3.OkHttpClient.Builder	clientBuilder
protected boolean	dooutput
protected java.io.IOException	exception
protected java.util.concurrent.ExecutorService	executor
protected java.io.OutputStream	externalOut
protected static javax.net.ssl.HostnameVerifier	hostnameVerifier
protected java.io.OutputStream	internalOut
protected org.slf4j.Logger	log
protected okhttp3.MediaType	mediaType
protected okhttp3.Request.Builder	requestBuilder
protected java.lang.String	requestMethod
protected okhttp3.Response	response
protected static javax.net.ssl.SSLSocketFactory	sslSocketFactory
protected static javax.net.ssl.X509TrustManager	trustManager

Fields inherited from class org.jumpmind.symmetric.transport.http.HttpConnection

conn, HTTP_NOT_MODIFIED, HTTP_OK, url

Constructor Summary

Constructors

Constructor and Description
Http2Connection(java.net.URL url)

Method Summary

Modifier and Type	Method and Description
void	addRequestProperty(java.lang.String key, java.lang.String value)
void	close()
protected void	closeOutput()
protected void	detectMediaType(java.lang.String key, java.lang.String value)
void	disconnect()
java.lang.String	getContentEncoding()
java.lang.String	getHeaderField(java.lang.String name)
java.util.Map<java.lang.String,java.util.List<java.lang.String>>	getHeaderFields()
static javax.net.ssl.HostnameVerifier	getHostnameVerifier()
java.io.InputStream	getInputStream()
java.io.OutputStream	getOutputStream()
protected okhttp3.Response	getResponse()
java.lang.String	getResponseBody()
int	getResponseCode()
static javax.net.ssl.SSLSocketFactory	getSslSocketFactory()
static javax.net.ssl.X509TrustManager	getTrustManager()
protected void	logHeaders(java.lang.String name, okhttp3.Headers headers)
protected void	reset()
void	setAllowUserInteraction(boolean allowuserinteraction)
void	setChunkedStreamingMode(int chunklen)
void	setConnectTimeout(int timeout)
void	setDoInput(boolean doinput)
void	setDoOutput(boolean dooutput)
static void	setHostnameVerifier(javax.net.ssl.HostnameVerifier hostnameVerifier)
void	setInstanceFollowRedirects(boolean followRedirects)
void	setReadTimeout(int timeout)
void	setRequestMethod(java.lang.String method)
void	setRequestProperty(java.lang.String key, java.lang.String value)
static void	setSslSocketFactory(javax.net.ssl.SSLSocketFactory sslSocketFactory)
static void	setTrustManager(javax.net.ssl.X509TrustManager trustManager)
void	setUseCaches(boolean usecaches)
protected void	waitForResponse()

Methods inherited from class org.jumpmind.symmetric.transport.http.HttpConnection

getURL

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected final org.slf4j.Logger log

trustManager

protected static javax.net.ssl.X509TrustManager trustManager

sslSocketFactory

protected static javax.net.ssl.SSLSocketFactory sslSocketFactory

hostnameVerifier

protected static javax.net.ssl.HostnameVerifier hostnameVerifier

executor

protected java.util.concurrent.ExecutorService executor

clientBuilder

protected okhttp3.OkHttpClient.Builder clientBuilder

requestBuilder

protected okhttp3.Request.Builder requestBuilder

response

protected okhttp3.Response response

requestMethod

protected java.lang.String requestMethod

mediaType

protected okhttp3.MediaType mediaType

dooutput

protected boolean dooutput

internalOut

protected java.io.OutputStream internalOut

externalOut

protected java.io.OutputStream externalOut

exception

protected java.io.IOException exception

Constructor Detail

Http2Connection

public Http2Connection(java.net.URL url)
                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

reset

protected void reset()

disconnect

public void disconnect()

Overrides:

disconnect in class HttpConnection

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class HttpConnection

closeOutput

protected void closeOutput()

getResponse

protected okhttp3.Response getResponse()
                                throws java.io.IOException

Throws:

java.io.IOException

logHeaders

protected void logHeaders(java.lang.String name,
                          okhttp3.Headers headers)

getResponseCode

public int getResponseCode()
                    throws java.io.IOException

Overrides:

getResponseCode in class HttpConnection

Throws:

java.io.IOException

getInputStream

public java.io.InputStream getInputStream()
                                   throws java.io.IOException

Overrides:

getInputStream in class HttpConnection

Throws:

java.io.IOException

getResponseBody

public java.lang.String getResponseBody()
                                 throws java.io.IOException

Throws:

java.io.IOException

waitForResponse

protected void waitForResponse()
                        throws java.io.IOException

Throws:

java.io.IOException

getOutputStream

public java.io.OutputStream getOutputStream()
                                     throws java.io.IOException

Overrides:

getOutputStream in class HttpConnection

Throws:

java.io.IOException

getContentEncoding

public java.lang.String getContentEncoding()

Overrides:

getContentEncoding in class HttpConnection

getHeaderField

public java.lang.String getHeaderField(java.lang.String name)

Overrides:

getHeaderField in class HttpConnection

getHeaderFields

public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getHeaderFields()

Overrides:

getHeaderFields in class HttpConnection

setConnectTimeout

public void setConnectTimeout(int timeout)

Overrides:

setConnectTimeout in class HttpConnection

setReadTimeout

public void setReadTimeout(int timeout)

Overrides:

setReadTimeout in class HttpConnection

setInstanceFollowRedirects

public void setInstanceFollowRedirects(boolean followRedirects)

Overrides:

setInstanceFollowRedirects in class HttpConnection

setRequestMethod

public void setRequestMethod(java.lang.String method)
                      throws java.net.ProtocolException

Overrides:

setRequestMethod in class HttpConnection

Throws:

java.net.ProtocolException

setDoInput

public void setDoInput(boolean doinput)

Overrides:

setDoInput in class HttpConnection

setDoOutput

public void setDoOutput(boolean dooutput)

Overrides:

setDoOutput in class HttpConnection

setAllowUserInteraction

public void setAllowUserInteraction(boolean allowuserinteraction)

Overrides:

setAllowUserInteraction in class HttpConnection

setChunkedStreamingMode

public void setChunkedStreamingMode(int chunklen)

Overrides:

setChunkedStreamingMode in class HttpConnection

setUseCaches

public void setUseCaches(boolean usecaches)

Overrides:

setUseCaches in class HttpConnection

setRequestProperty

public void setRequestProperty(java.lang.String key,
                               java.lang.String value)

Overrides:

setRequestProperty in class HttpConnection

addRequestProperty

public void addRequestProperty(java.lang.String key,
                               java.lang.String value)

Overrides:

addRequestProperty in class HttpConnection

detectMediaType

protected void detectMediaType(java.lang.String key,
                               java.lang.String value)

getTrustManager

public static javax.net.ssl.X509TrustManager getTrustManager()

setTrustManager

public static void setTrustManager(javax.net.ssl.X509TrustManager trustManager)

getSslSocketFactory

public static javax.net.ssl.SSLSocketFactory getSslSocketFactory()

setSslSocketFactory

public static void setSslSocketFactory(javax.net.ssl.SSLSocketFactory sslSocketFactory)

getHostnameVerifier

public static javax.net.ssl.HostnameVerifier getHostnameVerifier()

setHostnameVerifier

public static void setHostnameVerifier(javax.net.ssl.HostnameVerifier hostnameVerifier)