| Modifier and Type | Method and Description |
|---|---|
Address |
DaemonInfo.getAddress() |
| Modifier and Type | Method and Description |
|---|---|
DaemonInfo |
DaemonRegistryContent.getInfo(Address address)
Gets the status for given address.
|
void |
PersistentDaemonRegistry.markBusy(Address address) |
void |
EmbeddedDaemonRegistry.markBusy(Address address) |
void |
DaemonRegistry.markBusy(Address address) |
void |
PersistentDaemonRegistry.markIdle(Address address) |
void |
EmbeddedDaemonRegistry.markIdle(Address address) |
void |
DaemonRegistry.markIdle(Address address) |
void |
PersistentDaemonRegistry.remove(Address address) |
void |
EmbeddedDaemonRegistry.remove(Address address) |
void |
DaemonRegistry.remove(Address address) |
void |
DaemonRegistryContent.removeInfo(Address address)
Removes the status
|
void |
DaemonRegistryContent.setStatus(Address address,
DaemonInfo daemonInfo)
sets the daemonInfo for given address
|
void |
PersistentDaemonRegistry.store(Address address,
DaemonContext daemonContext,
String password) |
void |
EmbeddedDaemonRegistry.store(Address address,
DaemonContext daemonContext,
String password) |
void |
DaemonRegistry.store(Address address,
DaemonContext daemonContext,
String password) |
| Constructor and Description |
|---|
DaemonInfo(Address address,
DaemonContext context,
String password) |
| Modifier and Type | Method and Description |
|---|---|
Address |
Daemon.getAddress() |
Address |
DaemonTcpServerConnector.start(IncomingConnectionHandler handler) |
Address |
DaemonServerConnector.start(IncomingConnectionHandler handler)
Starts accepting connections, passing any established connections to the given handler.
|
| Modifier and Type | Method and Description |
|---|---|
Address |
MessagingServer.accept(Action<ConnectEvent<ObjectConnection>> action)
Creates an endpoint which a single peer can connect to.
|
Address |
ConnectEvent.getLocalAddress() |
Address |
Addressable.getLocalAddress() |
Address |
ConnectEvent.getRemoteAddress() |
Address |
Addressable.getRemoteAddress() |
| Modifier and Type | Method and Description |
|---|---|
ObjectConnection |
MessagingClient.getConnection(Address address)
Returns the connection for this client.
|
| Constructor and Description |
|---|
ConnectEvent(T connection,
Address localAddress,
Address remoteAddress) |
| Modifier and Type | Class and Description |
|---|---|
class |
CompositeAddress |
| 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.
|
Address |
MultiChannelConnector.accept(Action<ConnectEvent<MultiChannelConnection<Object>>> action) |
Address |
DefaultMultiChannelConnector.accept(Action<ConnectEvent<MultiChannelConnection<Object>>> action) |
Address |
DefaultMessagingServer.accept(Action<ConnectEvent<ObjectConnection>> action) |
Address |
CompositeAddress.getAddress() |
Address |
DefaultObjectConnection.getLocalAddress() |
Address |
DefaultObjectConnection.getRemoteAddress() |
| Modifier and Type | Method and Description |
|---|---|
Connection<T> |
OutgoingConnector.connect(Address destinationAddress)
Creates a connection to the given address.
|
MultiChannelConnection<Object> |
MultiChannelConnector.connect(Address destinationAddress) |
Connection<Message> |
HandshakeOutgoingConnector.connect(Address destinationAddress) |
MultiChannelConnection<Object> |
DefaultMultiChannelConnector.connect(Address destinationAddress) |
ObjectConnection |
DefaultMessagingClient.getConnection(Address address) |
| Constructor and Description |
|---|
CompositeAddress(Address address,
Object qualifier) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
InetEndpoint
A Inet-based route.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MultiChoiceAddress |
class |
SocketInetAddress |
| Modifier and Type | Method and Description |
|---|---|
Address |
TcpIncomingConnector.accept(Action<ConnectEvent<Connection<T>>> action,
boolean allowRemote) |
Address |
SocketConnection.getLocalAddress() |
Address |
SocketConnection.getRemoteAddress() |
| Modifier and Type | Method and Description |
|---|---|
Connection<T> |
TcpOutgoingConnector.connect(Address destinationAddress) |
| Modifier and Type | Method and Description |
|---|---|
Address |
ChannelUnavailable.getAddress() |
Address |
ChannelAvailable.getAddress() |
Address |
ConnectRequest.getDestinationAddress() |
| Constructor and Description |
|---|
ChannelAvailable(MessageOriginator originator,
String group,
String channel,
Address address) |
ChannelUnavailable(MessageOriginator originator,
String group,
String channel,
Address address) |
ConnectRequest(Address destinationAddress) |
| Constructor and Description |
|---|
ActionExecutionWorker(Action<WorkerProcessContext> action,
Object workerId,
String displayName,
Address serverAddress) |
ApplicationClassesInIsolatedClassLoaderWorkerFactory(Object workerId,
String displayName,
WorkerProcessBuilder processBuilder,
Collection<URL> implementationClassPath,
Address serverAddress,
ClassPathRegistry classPathRegistry) |
ApplicationClassesInSystemClassLoaderWorkerFactory(Object workerId,
String displayName,
WorkerProcessBuilder processBuilder,
List<URL> implementationClassPath,
Address serverAddress,
ClassPathRegistry classPathRegistry) |
Copyright © 2013. All rights reserved