@Test public void testSendAbortWithException() throws Exception { setup(); AtomicReference<Record> written = expectWriteRecord(); context.checking(new Expectations() {{ oneOf(transportConnectionReader).dispose(true, true); oneOf(transportConnectionWriter).dispose(true); }}); kat.sendAbort(true); assertNotNull(written.get()); assertRecordEquals(PROTOCOL_VERSION, ABORT, new byte[0], written.get()); }
void sendAbort(boolean exception) { try { writeRecord(ABORT, new byte[0]); } catch (IOException e) { logException(LOG, WARNING, e); exception = true; } tryToClose(exception); }
KeyAgreementTransport { void sendAbort(boolean exception) { try { writeRecord(ABORT, new byte[0]); } catch (IOException e) { logException(LOG, WARNING, e); exception = true; } tryToClose(exception); } }
KeyAgreementTransport { void sendAbort(boolean exception) { try { writeRecord(ABORT, new byte[0]); } catch (IOException e) { logException(LOG, WARNING, e); exception = true; } tryToClose(exception); } KeyAgreementTransport(RecordReaderFactory recordReaderFactory,
			RecordWriterFactory recordWriterFactory, KeyAgreementConnection kac); }
KeyAgreementTransport { void sendAbort(boolean exception) { try { writeRecord(ABORT, new byte[0]); } catch (IOException e) { logException(LOG, WARNING, e); exception = true; } tryToClose(exception); } KeyAgreementTransport(RecordReaderFactory recordReaderFactory,
			RecordWriterFactory recordWriterFactory, KeyAgreementConnection kac); DuplexTransportConnection getConnection(); TransportId getTransportId(); }
KeyAgreementTransport { void sendAbort(boolean exception) { try { writeRecord(ABORT, new byte[0]); } catch (IOException e) { logException(LOG, WARNING, e); exception = true; } tryToClose(exception); } KeyAgreementTransport(RecordReaderFactory recordReaderFactory,
			RecordWriterFactory recordWriterFactory, KeyAgreementConnection kac); DuplexTransportConnection getConnection(); TransportId getTransportId();  }