328329330331332333334335336337338
if (HornetQLogger.LOGGER.isTraceEnabled()) { HornetQLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } conn.disconnect(criticalError); } for (Acceptor acceptor : acceptors) { acceptor.stop();
318319320321322323324325326327328
if (log.isTraceEnabled()) { log.trace("Sending connection.disconnection packet to " + conn); } conn.disconnect(criticalError); } for (Acceptor acceptor : acceptors) { acceptor.stop();
309310311312313314315316317318319
HornetQServerLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } if (!conn.isClient()) { conn.disconnect(false); connections.remove(entry.getKey()); } } }
353354355356357358359360361362363
if (HornetQServerLogger.LOGGER.isTraceEnabled()) { HornetQServerLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } conn.disconnect(criticalError); } for (Acceptor acceptor : acceptors) { acceptor.stop();
281282283284285286287288289290291
// then send a disconnect packet for (ConnectionEntry entry : connections.values()) { RemotingConnection conn = entry.connection; conn.disconnect(failoverOnServerShutdown); } for (Acceptor acceptor : acceptors) { acceptor.stop();
276277278279280281282283284285286
// then send a disconnect packet for (ConnectionEntry entry : connections.values()) { RemotingConnection conn = entry.connection; conn.disconnect(); } for (Acceptor acceptor : acceptors) { acceptor.stop();
279280281282283284285286287288289
HornetQLogger.LOGGER.trace("Sending connection.disconnection packet to " + conn); } if (!conn.equals(backupRemotingConnection) && !conn.isClient()) { conn.disconnect(false); connections.remove(entry.getKey()); } } }