|
BEAST
|
The message manager that will distribute the messages to the available adaptors/routes. More...
Public Member Functions | |
| BltMessageManager () | |
| Default constructor. | |
| BltMessageManager (int poolSize) | |
| Constructor. | |
| void | setRouter (IRouter router) |
| void | setManager (IBltAdaptorManager manager) |
| synchronized void | setExecutor (ExecutorService executor) |
| ExecutorService | getExecutor () |
| synchronized void | manage (IBltMessage message) |
| synchronized void | afterPropertiesSet () throws Exception |
| If the executor service not has been set when arriving here, the default executor service will be set. | |
| synchronized void | shutdown () |
| Safely terminates the manager and ensures that pending messages are managed properly. | |
| void | destroy () throws Exception |
Protected Member Functions | |
| Runnable | createRunnable (final IBltMessage message) |
| Creates a runnable for use with an executor. | |
The message manager that will distribute the messages to the available adaptors/routes.
|
inline |
Default constructor.
|
inline |
Constructor.
| poolSize | the number of threads in the default executor pool |
|
inline |
If the executor service not has been set when arriving here, the default executor service will be set.
|
inlineprotected |
Creates a runnable for use with an executor.
| message | a message |
|
inline |
|
inline |
|
inline |
Implements eu.baltrad.beast.manager.IBltMessageManager.
|
inline |
| executor | the executor service to set |
|
inline |
| manager | the adaptor manager to set |
|
inline |
| router | the router to set |
|
inline |
Safely terminates the manager and ensures that pending messages are managed properly.
Implements eu.baltrad.beast.manager.IBltMessageManager.