Module com.aoapps.messaging.http

Package com.aoapps.messaging.http

Class HttpSocket

java.lang.Object

com.aoapps.messaging.base.AbstractSocket

com.aoapps.messaging.http.HttpSocket

All Implemented Interfaces:

Socket, Closeable, AutoCloseable

public class HttpSocket
extends AbstractSocket

One established connection over HTTP.

Field Summary

Fields

Modifier and Type	Field	Description
static final Charset	ENCODING
static final String	PROTOCOL
static final int	READ_TIMEOUT	Server should normally respond within 60 seconds even if no data coming back.

Constructor Summary

Constructors

Constructor	Description
HttpSocket(HttpSocketContext socketContext, Identifier id, long connectTime, URL endpoint)	Creates a new HTTP(S) socket.

Method Summary

Modifier and Type	Method	Description
void	close()
String	getProtocol()
protected void	sendMessagesImpl(Collection<? extends Message> messages)
protected void	startImpl(Callback<? super Socket> onStart, Callback<? super Throwable> onError)

Methods inherited from class com.aoapps.messaging.base.AbstractSocket

addSocketListener, callOnError, callOnMessages, getCloseTime, getConnectRemoteSocketAddress, getConnectTime, getId, getRemoteSocketAddress, getSocketContext, isClosed, removeSocketListener, sendMessage, sendMessages, setRemoteSocketAddress, start, toString

Methods inherited from class java.lang.Object

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

Field Details

PROTOCOL

public static final String PROTOCOL

See Also:

• Constant Field Values

ENCODING

public static final Charset ENCODING

READ_TIMEOUT

public static final int READ_TIMEOUT

Server should normally respond within 60 seconds even if no data coming back.

See Also:

• Constant Field Values

Constructor Details

HttpSocket

public HttpSocket(HttpSocketContext socketContext,
 Identifier id,
 long connectTime,
 URL endpoint)

Creates a new HTTP(S) socket.

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Socket

Overrides:

close in class AbstractSocket

Throws:

IOException

getProtocol

public String getProtocol()

Specified by:

getProtocol in interface Socket

Specified by:

getProtocol in class AbstractSocket

startImpl

protected void startImpl(Callback<? super Socket> onStart,
 Callback<? super Throwable> onError)
                  throws IllegalStateException

Specified by:

startImpl in class AbstractSocket

Throws:

IllegalStateException

sendMessagesImpl

protected void sendMessagesImpl(Collection<? extends Message> messages)

Specified by:

sendMessagesImpl in class AbstractSocket