884885886887888889890891892893894
} catch (Exception e) { failure = e; LOG.debug("Connect fail to: " + uri + ", reason: " + e); if (t != null) { try { t.stop(); } catch (Exception ee) { LOG.debug("Stop of failed transport: " + t + " failed with reason: " + ee); } } } finally {
264265266267268269270271272273274
synchronized (sleepMutex) { sleepMutex.notifyAll(); } reconnectTask.shutdown(); if( transportToStop!=null ) { transportToStop.stop(); } } public long getInitialReconnectDelay() { return initialReconnectDelay;
751752753754755756757758759760761
} catch (Exception e) { failure = e; LOG.debug("Connect fail to: " + uri + ", reason: " + e); if (t!=null) { try { t.stop(); } catch (Exception ee) { LOG.debug("Stop of failed transport: " + t + " failed with reason: " + ee); } } }
96979899100101102103104105106
.getVmConnectorURI()); localTransport.setTransportListener(new TransportListener() { public void onCommand(Object command) { if (command instanceof ShutdownInfo) { try { localTransport.stop(); } catch (Exception ex) { throw new RuntimeException(ex); } } }
117118119120121122123124125126127
// ignore } }); localTransport.start(); localTransport.stop(); // Ensure that the persistent connection is still usable. producer.send(session.createMessage()); session.rollback(); }
333334335336337338339340341342343
synchronized (sleepMutex) { sleepMutex.notifyAll(); } reconnectTask.shutdown(); if (transportToStop != null) { transportToStop.stop(); } } public long getInitialReconnectDelay() { return initialReconnectDelay;
644645646647648649650651652653654
if (started) { if (rebalance) { Transport transport = this.connectedTransport.getAndSet(null); if (transport != null) { try { transport.stop(); } catch (Exception e) { LOG.debug("Caught an exception stopping existing transport", e); } }
882883884885886887888889890891892
263264265266267268269270271272273
267268269270271272273274275276277