com.exalead.papi.helper.http.replay

Class HttpConnection

java.lang.Object

org.apache.http.entity.AbstractHttpEntity

com.exalead.papi.helper.http.replay.HttpConnection

All Implemented Interfaces:

CloseableDataOutput, java.io.Closeable, java.io.DataOutput, java.lang.AutoCloseable, org.apache.http.HttpEntity

public class HttpConnection
extends org.apache.http.entity.AbstractHttpEntity
implements CloseableDataOutput

A single connection to the HTTP server.

Field Summary

Fields inherited from class org.apache.http.entity.AbstractHttpEntity

chunked, contentEncoding, contentType, OUTPUT_BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
HttpConnection(java.util.concurrent.ExecutorService executor, java.net.URI uri, java.lang.String login, java.lang.String password, org.apache.http.impl.client.CloseableHttpClient httpClient)

Method Summary

Modifier and Type	Method and Description
HttpSender.CnxState	awaitStateChange(long time, java.util.concurrent.TimeUnit unit, HttpSender.CnxState expected)
void	close() Do not actually close the connection but mark it as available (aka return it the the pool).
java.io.InputStream	getContent()
long	getContentLength()
java.lang.Throwable	getError()
StateDuration	getState()
boolean	isRepeatable()
boolean	isStreaming()
HttpConnection	open(PAPI_COMMAND cmd) Indicate on the output stream that more data is available.
void	terminateSession(long timeout, java.util.concurrent.TimeUnit unit)
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)
void	writeBoolean(boolean v)
void	writeByte(int v)
void	writeBytes(java.lang.String s)
void	writeChar(int v)
void	writeChars(java.lang.String s)
void	writeDouble(double v)
void	writeFloat(float v)
void	writeInt(int v)
void	writeLong(long v)
void	writeShort(int v)
void	writeTo(java.io.OutputStream outs)
void	writeUTF(java.lang.String s)

Methods inherited from class org.apache.http.entity.AbstractHttpEntity

consumeContent, getContentEncoding, getContentType, isChunked, setChunked, setContentEncoding, setContentEncoding, setContentType, setContentType, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpConnection

public HttpConnection(java.util.concurrent.ExecutorService executor,
                      java.net.URI uri,
                      java.lang.String login,
                      java.lang.String password,
                      org.apache.http.impl.client.CloseableHttpClient httpClient)
               throws java.io.IOException

Parameters:

executor - The executor within which the Http connection is being run

uri - The URI to connect to.

login - The login of the user. May be empty of null. If none Authorization HTTP header is sent. Only basic authorization is supported.

password - the password for the authorization.

httpClient - The HTTP client to have the Http connection executed into.

Throws:

java.io.IOException

Method Detail

open

public HttpConnection open(PAPI_COMMAND cmd)
                    throws PushAPIException

Indicate on the output stream that more data is available. The connection with the HTTP server must be already opened.

Parameters:

cmd - The command to be sent

Returns:

An output stream to write the command to

Throws:

PushAPIException - If it could not write on the stream that more data is available

close

public void close()
           throws java.io.IOException

Do not actually close the connection but mark it as available (aka return it the the pool). To actually destroy the connection, use #terminateSession()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

terminateSession

public void terminateSession(long timeout,
                             java.util.concurrent.TimeUnit unit)
                      throws java.io.IOException,
                             java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getError

public java.lang.Throwable getError()

awaitStateChange

public HttpSender.CnxState awaitStateChange(long time,
                                            java.util.concurrent.TimeUnit unit,
                                            HttpSender.CnxState expected)
                                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getState

public StateDuration getState()

writeTo

public void writeTo(java.io.OutputStream outs)
             throws java.io.IOException

Specified by:

writeTo in interface org.apache.http.HttpEntity

Throws:

java.io.IOException

isRepeatable

public boolean isRepeatable()

Specified by:

isRepeatable in interface org.apache.http.HttpEntity

isStreaming

public boolean isStreaming()

Specified by:

isStreaming in interface org.apache.http.HttpEntity

getContentLength

public long getContentLength()

Specified by:

getContentLength in interface org.apache.http.HttpEntity

getContent

public java.io.InputStream getContent()
                               throws java.io.IOException,
                                      java.lang.UnsupportedOperationException

Specified by:

getContent in interface org.apache.http.HttpEntity

Throws:

java.io.IOException

java.lang.UnsupportedOperationException

write

public void write(int b)
           throws java.io.IOException

Specified by:

write in interface java.io.DataOutput

Throws:

java.io.IOException

write

public void write(byte[] b)
           throws java.io.IOException

Specified by:

write in interface java.io.DataOutput

Throws:

java.io.IOException

write

public void write(byte[] b,
                  int off,
                  int len)
           throws java.io.IOException

Specified by:

write in interface java.io.DataOutput

Throws:

java.io.IOException

writeBoolean

public void writeBoolean(boolean v)
                  throws java.io.IOException

Specified by:

writeBoolean in interface java.io.DataOutput

Throws:

java.io.IOException

writeByte

public void writeByte(int v)
               throws java.io.IOException

Specified by:

writeByte in interface java.io.DataOutput

Throws:

java.io.IOException

writeShort

public void writeShort(int v)
                throws java.io.IOException

Specified by:

writeShort in interface java.io.DataOutput

Throws:

java.io.IOException

writeChar

public void writeChar(int v)
               throws java.io.IOException

Specified by:

writeChar in interface java.io.DataOutput

Throws:

java.io.IOException

writeInt

public void writeInt(int v)
              throws java.io.IOException

Specified by:

writeInt in interface java.io.DataOutput

Throws:

java.io.IOException

writeLong

public void writeLong(long v)
               throws java.io.IOException

Specified by:

writeLong in interface java.io.DataOutput

Throws:

java.io.IOException

writeFloat

public void writeFloat(float v)
                throws java.io.IOException

Specified by:

writeFloat in interface java.io.DataOutput

Throws:

java.io.IOException

writeDouble

public void writeDouble(double v)
                 throws java.io.IOException

Specified by:

writeDouble in interface java.io.DataOutput

Throws:

java.io.IOException

writeBytes

public void writeBytes(java.lang.String s)
                throws java.io.IOException

Specified by:

writeBytes in interface java.io.DataOutput

Throws:

java.io.IOException

writeChars

public void writeChars(java.lang.String s)
                throws java.io.IOException

Specified by:

writeChars in interface java.io.DataOutput

Throws:

java.io.IOException

writeUTF

public void writeUTF(java.lang.String s)
              throws java.io.IOException

Specified by:

writeUTF in interface java.io.DataOutput

Throws:

java.io.IOException