419420421422423424425426427428429
if (HornetQServerLogger.LOGGER.isTraceEnabled()) { HornetQServerLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } conn.disconnect(criticalError); } for (Acceptor acceptor : acceptors.values()) { acceptor.stop();
275276277278279280281282283284285
// then send a disconnect packet for (ConnectionEntry entry : connections.values()) { RemotingConnection conn = entry.connection; conn.disconnect(); } for (Acceptor acceptor : acceptors) { acceptor.stop();
305306307308309310311312313314315
HornetQServerLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } if (!conn.isClient()) { conn.disconnect(false); connections.remove(entry.getKey()); } } }
354355356357358359360361362363364
if (HornetQServerLogger.LOGGER.isTraceEnabled()) { HornetQServerLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } conn.disconnect(criticalError); } for (Acceptor acceptor : acceptors) { acceptor.stop();
302303304305306307308309310311312
HornetQServerLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } if (!conn.equals(backupRemotingConnection) && !conn.isClient()) { conn.disconnect(false); connections.remove(entry.getKey()); } } }
351352353354355356357358359360361
304305306307308309310311312313314
if (log.isTraceEnabled()) { log.trace("Sending connection.disconnection packet to " + conn); } conn.disconnect(criticalError); } for (Acceptor acceptor : acceptors) { acceptor.stop();
380381382383384385386387388389390
424425426427428429430431432433434
279280281282283284285286287288289
HornetQLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } if (!conn.equals(backupRemotingConnection) && !conn.isClient()) { conn.disconnect(false); connections.remove(entry.getKey()); } } }