Iterates through all the protocols from top to bottom and does the following: Waits until all messages in the down queue have been flushed (ie., size is 0) Calls stop() on the protocol
(String cluster)
| 933 | * </ol> |
| 934 | */ |
| 935 | public void stopStack(String cluster) { |
| 936 | if(stopped) return; |
| 937 | getProtocols().forEach(Protocol::stop); |
| 938 | TP transport=getTransport(); |
| 939 | transport.unregisterProbeHandler(props_handler); |
| 940 | stopped=true; |
| 941 | } |
| 942 | |
| 943 | |
| 944 |