| Modifier and Type | Method and Description |
|---|---|
Connection<Object> |
DaemonConnection.getConnection() |
| Modifier and Type | Method and Description |
|---|---|
void |
StopDispatcher.dispatch(BuildClientMetaData clientMetaData,
Connection<Object> connection) |
protected Object |
DaemonClient.executeBuild(Build build,
Connection<Object> connection) |
| Constructor and Description |
|---|
DaemonConnection(String uid,
Connection<Object> connection,
String password) |
| Modifier and Type | Method and Description |
|---|---|
void |
IncomingConnectionHandler.handle(Connection<Object> connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultDaemonCommandExecuter.executeCommand(Connection<Object> connection,
Command command,
DaemonContext daemonContext,
DaemonStateCoordinator daemonStateCoordinator) |
void |
DaemonCommandExecuter.executeCommand(Connection<Object> connection,
Command command,
DaemonContext daemonContext,
DaemonStateCoordinator daemonStateCoordinator)
Handle the given command, and communicate as necessary with the client over the given connection.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
DisconnectAwareConnection<T>
A
DisconnectAwareConnection is a connection capable of executing an action when
the other side of connection disconnects before the stop method is called on this connection. |
| Modifier and Type | Class and Description |
|---|---|
class |
DelegatingConnection<T> |
class |
DisconnectAwareConnectionDecorator<T>
A
DisconnectAwareConnection implementation that decorates an existing connection, adding disconnect awareness. |
class |
SynchronizedDispatch<T>
Connection decorator that synchronizes dispatching.
|
| Modifier and Type | Method and Description |
|---|---|
Connection<T> |
OutgoingConnector.connect(Address destinationAddress)
Creates a connection to the given address.
|
Connection<Message> |
HandshakeOutgoingConnector.connect(Address destinationAddress) |
| Modifier and Type | Method and Description |
|---|---|
void |
MessageHub.addConnection(Connection<Message> connection)
Adds an incoming connection.
|
| Modifier and Type | Method and Description |
|---|---|
Address |
HandshakeIncomingConnector.accept(Action<ConnectEvent<Connection<Message>>> action,
boolean allowRemote) |
Address |
IncomingConnector.accept(Action<ConnectEvent<Connection<T>>> action,
boolean allowRemote)
Allocates a new incoming endpoint.
|
| Constructor and Description |
|---|
AsyncConnectionAdapter(Connection<T> connection,
DispatchFailureHandler<? super T> dispatchFailureHandler,
ExecutorFactory executor,
Protocol<T>... protocols) |
DelegatingConnection(Connection<T> delegate) |
DisconnectAwareConnectionDecorator(Connection<T> connection,
StoppableExecutor executor) |
DisconnectAwareConnectionDecorator(Connection<T> connection,
StoppableExecutor executor,
int bufferSize) |
SynchronizedDispatch(Connection<T> delegate) |
| Modifier and Type | Class and Description |
|---|---|
class |
MulticastConnection<T> |
class |
SocketConnection<T> |
| Modifier and Type | Method and Description |
|---|---|
Connection<T> |
TcpOutgoingConnector.connect(Address destinationAddress) |
| Modifier and Type | Method and Description |
|---|---|
Address |
TcpIncomingConnector.accept(Action<ConnectEvent<Connection<T>>> action,
boolean allowRemote) |
Copyright © 2013. All rights reserved