Index

A C G I N R S T 
All Classes and Interfaces|All Packages

A

AbstractSocket - Class in com.aoapps.messaging.base
Base implementation of socket.
AbstractSocket(AbstractSocketContext<? extends AbstractSocket>, Identifier, long, SocketAddress) - Constructor for class com.aoapps.messaging.base.AbstractSocket
 
AbstractSocketContext<S> - Class in com.aoapps.messaging.base
Base implementation of socket context.
AbstractSocketContext() - Constructor for class com.aoapps.messaging.base.AbstractSocketContext
 
AbstractSocketContext.IdentifierAvailabilityChecker - Interface in com.aoapps.messaging.base
Something that can check the availability of a session ID, to skip used session IDs when creating new sessions.
addIdentifierAvailabilityChecker(AbstractSocketContext.IdentifierAvailabilityChecker) - Method in class com.aoapps.messaging.base.AbstractSocketContext
addSocket(S) - Method in class com.aoapps.messaging.base.AbstractSocketContext
Adds a new socket to this context, sockets must be added to the context before they create any of their own events.
addSocketContextListener(SocketContextListener, boolean) - Method in class com.aoapps.messaging.base.AbstractSocketContext
 
addSocketListener(SocketListener, boolean) - Method in class com.aoapps.messaging.base.AbstractSocket
 

C

callOnError(Throwable) - Method in class com.aoapps.messaging.base.AbstractSocket
When an error as occurred, call this to distribute to all of the listeners.
callOnError(Throwable) - Method in class com.aoapps.messaging.base.AbstractSocketContext
When an error as occurred, call this to distribute to all of the listeners.
callOnMessages(List<? extends Message>) - Method in class com.aoapps.messaging.base.AbstractSocket
When one or more new messages have arrived, call this to distribute to all of the listeners.
close() - Method in class com.aoapps.messaging.base.AbstractSocket
Any overriding implementation must call super.close() first.
close() - Method in class com.aoapps.messaging.base.AbstractSocketContext
Any overriding implementation must call super.close() first.
com.aoapps.messaging.base - module com.aoapps.messaging.base
 
com.aoapps.messaging.base - package com.aoapps.messaging.base
 

G

getCloseTime() - Method in class com.aoapps.messaging.base.AbstractSocket
 
getConnectRemoteSocketAddress() - Method in class com.aoapps.messaging.base.AbstractSocket
 
getConnectTime() - Method in class com.aoapps.messaging.base.AbstractSocket
 
getId() - Method in class com.aoapps.messaging.base.AbstractSocket
 
getProtocol() - Method in class com.aoapps.messaging.base.AbstractSocket
 
getRemoteSocketAddress() - Method in class com.aoapps.messaging.base.AbstractSocket
 
getSocket(Identifier) - Method in class com.aoapps.messaging.base.AbstractSocketContext
 
getSocketContext() - Method in class com.aoapps.messaging.base.AbstractSocket
 
getSockets() - Method in class com.aoapps.messaging.base.AbstractSocketContext
 

I

isClosed() - Method in class com.aoapps.messaging.base.AbstractSocket
 
isClosed() - Method in class com.aoapps.messaging.base.AbstractSocketContext
 
isIdentifierAvailable(Identifier) - Method in interface com.aoapps.messaging.base.AbstractSocketContext.IdentifierAvailabilityChecker
 

N

newIdentifier() - Method in class com.aoapps.messaging.base.AbstractSocketContext
Creates a random identifier that is not in the current set of sockets.

R

removeIdentifierAvailabilityChecker(AbstractSocketContext.IdentifierAvailabilityChecker) - Method in class com.aoapps.messaging.base.AbstractSocketContext
removeSocketContextListener(SocketContextListener) - Method in class com.aoapps.messaging.base.AbstractSocketContext
 
removeSocketListener(SocketListener) - Method in class com.aoapps.messaging.base.AbstractSocket
 

S

sendMessage(Message) - Method in class com.aoapps.messaging.base.AbstractSocket
 
sendMessages(Collection<? extends Message>) - Method in class com.aoapps.messaging.base.AbstractSocket
 
sendMessagesImpl(Collection<? extends Message>) - Method in class com.aoapps.messaging.base.AbstractSocket
Implementation to actually enqueue and send messages.
setRemoteSocketAddress(SocketAddress) - Method in class com.aoapps.messaging.base.AbstractSocket
Sets the most recently seen remote address.
start(Callback<? super Socket>, Callback<? super Throwable>) - Method in class com.aoapps.messaging.base.AbstractSocket
Makes sure the socket is not already closed then calls startImpl.
startImpl(Callback<? super Socket>, Callback<? super Throwable>) - Method in class com.aoapps.messaging.base.AbstractSocket
Called once the socket is confirmed to not be closed.

T

toString() - Method in class com.aoapps.messaging.base.AbstractSocket
 
A C G I N R S T 
All Classes and Interfaces|All Packages