Module com.aoapps.messaging.http.servlet

Package com.aoapps.messaging.http.servlet

Class HttpSocketServlet.ServletSocket

java.lang.Object

com.aoapps.messaging.base.AbstractSocket

com.aoapps.messaging.http.servlet.HttpSocketServlet.ServletSocket

All Implemented Interfaces:

Socket, Closeable, AutoCloseable

Enclosing class:

HttpSocketServlet

public static class HttpSocketServlet.ServletSocket
extends AbstractSocket

Servlet socket implementation.

Method Summary

Modifier and Type	Method	Description
protected Future<?>	callOnError(Throwable t)
protected Future<?>	callOnMessages(List<? extends Message> messages)
void	close()
String	getProtocol()
String	getServerName()	All requests for this socket must use the same server name.
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, 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

Method Details

getServerName

public String getServerName()

All requests for this socket must use the same server name.

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

callOnMessages

protected Future<?> callOnMessages(List<? extends Message> messages)
                            throws IllegalStateException

Overrides:

callOnMessages in class AbstractSocket

Throws:

IllegalStateException

callOnError

protected Future<?> callOnError(Throwable t)
                         throws IllegalStateException

Overrides:

callOnError in class AbstractSocket

Throws:

IllegalStateException

startImpl

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

Specified by:

startImpl in class AbstractSocket

sendMessagesImpl

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

Specified by:

sendMessagesImpl in class AbstractSocket