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

Creates a new AbstractSocket.

AbstractSocketContext<S> - Class in com.aoapps.messaging.base

Base implementation of socket context.

AbstractSocketContext() - Constructor for class com.aoapps.messaging.base.AbstractSocketContext

Creates a new 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

Adds a AbstractSocketContext.IdentifierAvailabilityChecker.

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

Removes a AbstractSocketContext.IdentifierAvailabilityChecker.

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