| | |
| | | disabled = true; |
| | | |
| | | // Stop the listener thread |
| | | if (listenerThread != null) |
| | | listenerThread.shutdown(); |
| | | listenerThread.shutdown(); |
| | | |
| | | broker.stop(); // This will cut the session and wake up the listener |
| | | |
| | | // Wait for the listener thread to stop |
| | | if (listenerThread != null) |
| | | listenerThread.waitForShutdown(); |
| | | listenerThread.waitForShutdown(); |
| | | } |
| | | |
| | | /** |
| | |
| | | maxSendQueue, maxSendDelay, window, heartbeatInterval); |
| | | isolationpolicy = configuration.getIsolationPolicy(); |
| | | |
| | | // To be able to stop and restart the broker properly just |
| | | // disable and enable the domain. That way a new session |
| | | // with the new configuration is available. |
| | | this.disable(); |
| | | this.enable(); |
| | | |
| | | return new ConfigChangeResult(ResultCode.SUCCESS, false); |
| | | } |
| | | |