Package | Description |
---|---|
net.grinder.communication |
The Grinder communication subsystem.
|
net.grinder.console.communication |
Console communication.
|
net.grinder.console.communication.server.messages |
Messages used by the console client.
|
net.grinder.engine.messages |
Messages that can be sent to the worker processes.
|
net.grinder.messages.agent |
Messages that can be sent to the agent process.
|
net.grinder.messages.console |
Messages that can be sent to the console.
|
net.grinder.synchronisation.messages |
Messages used by distributed implementations of the synchronisation classes.
|
Modifier and Type | Class and Description |
---|---|
static class |
MessageDispatchRegistry.AbstractBlockingHandler<T extends Message>
Most handlers ignore the shutdown event, so provide this as a convenient
base for anonymous classes.
|
static class |
MessageDispatchRegistry.AbstractHandler<T extends Message>
Most handlers ignore the shutdown event, so provide this as a convenient
base for anonymous classes.
|
static interface |
MessageDispatchRegistry.BlockingHandler<T extends Message>
Handler interface.
|
static interface |
MessageDispatchRegistry.Handler<T extends Message>
Handler interface.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AddressAwareMessage
Message that wants to know its origin address.
|
Modifier and Type | Class and Description |
---|---|
class |
KeepAliveMessage
No-op message used to keep a connection alive.
|
Modifier and Type | Method and Description |
---|---|
<T extends Message,S extends T> |
MessageDispatchRegistry.set(Class<S> messageType,
MessageDispatchRegistry.BlockingHandler<T> responder)
Register a message responder.
|
<T extends Message,S extends T> |
MessageDispatchSender.set(Class<S> messageType,
MessageDispatchRegistry.BlockingHandler<T> responder)
Register a message responder.
|
<T extends Message,S extends T> |
MessageDispatchRegistry.set(Class<S> messageType,
MessageDispatchRegistry.Handler<T> messageHandler)
Register a message handler.
|
<T extends Message,S extends T> |
MessageDispatchSender.set(Class<S> messageType,
MessageDispatchRegistry.Handler<T> messageHandler)
Register a message handler.
|
Modifier and Type | Method and Description |
---|---|
Message |
BlockingSender.blockingSend(Message message)
Send the given message and await a response.
|
Message |
ClientSender.blockingSend(Message message)
Send the given message and await a response.
|
Message |
MessageDispatchRegistry.BlockingHandler.blockingSend(T message)
Handle the given message.
|
Message |
ServerReceiver.waitForMessage()
Block until a message is available, or another thread has called
ServerReceiver.shutdown() . |
Message |
StreamReceiver.waitForMessage()
Block until a message is available.
|
Message |
Receiver.waitForMessage()
Block until a message is available, or another thread has
called
Receiver.shutdown() . |
Modifier and Type | Method and Description |
---|---|
Message |
BlockingSender.blockingSend(Message message)
Send the given message and await a response.
|
Message |
ClientSender.blockingSend(Message message)
Send the given message and await a response.
|
void |
TeeSender.handle(Message message)
Handle the given message.
|
void |
FanOutServerSender.send(Address address,
Message message)
Send a message to a particular address.
|
void |
QueuedSenderDecorator.send(Message message)
Queue the given message for later sending.
|
void |
IgnoreShutdownSender.send(Message message)
Send the given message using the delegate.
|
void |
MessageDispatchSender.send(Message message)
Sends a message to each handler until one claims to have handled the
message.
|
void |
Sender.send(Message message)
Send the given message.
|
void |
TeeSender.send(Message message)
Send the given message.
|
protected void |
StreamSender.writeMessage(Message message)
Send a message.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageDispatchRegistry.addFallback(MessageDispatchRegistry.Handler<Message> messageHandler)
Register a message handler that is called if no other handler or responder
is registered for the message type.
|
void |
MessageDispatchSender.addFallback(MessageDispatchRegistry.Handler<Message> messageHandler)
Register a message handler that is called if no other handler or responder
is registered for the message type.
|
Modifier and Type | Method and Description |
---|---|
void |
ConsoleCommunication.sendToAddressedAgents(Address address,
Message message)
Send the given message to the given agent processes (which may pass it on
to its workers).
|
void |
ConsoleCommunicationImplementation.sendToAddressedAgents(Address address,
Message message)
Send the given message to the given agent processes (which may pass it on
to its workers).
|
void |
ConsoleCommunication.sendToAgents(Message message)
Send the given message to the agent processes (which may pass it on to
their workers).
|
void |
ConsoleCommunicationImplementation.sendToAgents(Message message)
Send the given message to the agent processes (which may pass it on to
their workers).
|
Modifier and Type | Class and Description |
---|---|
class |
GetNumberOfAgentsMessage
Message requesting the number of live agents.
|
class |
ResetRecordingMessage
Message indicating that the console recording should be reset.
|
class |
ResetWorkerProcessesMessage
Message indicating that all worker processes should be reset.
|
class |
ResultMessage
Response message that contains a result.
|
class |
StartRecordingMessage
Message indicating that the console recording should be started.
|
class |
StartWorkerProcessesMessage
Message indicating that all worker processes should be started.
|
class |
StopAgentAndWorkerProcessesMessage
Message indicating that all agent and worker processes should be stopped.
|
class |
StopRecordingMessage
Message indicating that the console recording should be stopped.
|
class |
SuccessMessage
Message indicating that a command completed successfully.
|
Modifier and Type | Class and Description |
---|---|
class |
InitialiseGrinderMessage
Message used by the agent to initialise the worker processes.
|
Modifier and Type | Class and Description |
---|---|
class |
ClearCacheMessage
Message that instructs the agent to clear its file cache.
|
class |
DistributeFileMessage
Message used to distribute a file from the console to the agent
processes.
|
class |
DistributionCacheCheckpointMessage
Pass a cache check point to the agent.
|
class |
ResetGrinderMessage
Message used to reset the Grinder processes.
|
class |
StartGrinderMessage
Message used to start the Grinder processes.
|
class |
StopGrinderMessage
Message used to stop the Grinder processes.
|
Modifier and Type | Class and Description |
---|---|
class |
AgentProcessReportMessage
Message for informing the console of agent process status.
|
class |
RegisterExpressionViewMessage
Message used to register a expression view with Console.
|
class |
RegisterTestsMessage
Message used to register tests with Console.
|
class |
ReportStatisticsMessage
Message used to report test statistics to the console.
|
class |
WorkerProcessReportMessage
Message for informing the console of worker process status.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBarrierGroupMessage
Common implementation for barrier group messages.
|
class |
AddBarrierMessage
Barrier group message requesting that a barrier be added.
|
class |
AddWaiterMessage
Barrier group message requesting that a waiter be added.
|
class |
CancelWaiterMessage
Barrier group message requesting that a waiter be removed.
|
class |
OpenBarrierMessage
Barrier group message sent to agents when a barrier is opened.
|
class |
RemoveBarriersMessage
Barrier group message requesting that a number of barriers be removed.
|
Copyright © 2000-2014. All Rights Reserved.