@Test public void testProcessMessageReassemblesFragmentedMessages() throws GeneralSecurityException, HandshakeException { int nextSeqNo = 0; int futureSeqNo = 1; givenAHandshakerWithAQueuedFragmentedMessage(futureSeqNo); Record record = getRecordForMessage(0, 0, createCertificateMessage(session, nextSeqNo, certificateChain)); handshakerWithoutAnchors.decryptAndProcessMessage(record); assertThat(receivedMessages[nextSeqNo], is(1)); assertThat(receivedMessages[futureSeqNo], is(1)); assertTrue(handshakerWithoutAnchors.isInboundMessageProcessed()); }
public boolean isInboundMessageProcessed() { return inboundMessageBuffer.isEmpty(); }
Handshaker implements Destroyable { public boolean isInboundMessageProcessed() { return inboundMessageBuffer.isEmpty(); } }
Handshaker implements Destroyable { public boolean isInboundMessageProcessed() { return inboundMessageBuffer.isEmpty(); } @NoPublicAPI protected  Handshaker(boolean isClient, int initialMessageSeq, DTLSSession session, RecordLayer recordLayer,
			ScheduledExecutorService timer, Connection connection, DtlsConnectorConfig config); }
Handshaker implements Destroyable { public boolean isInboundMessageProcessed() { return inboundMessageBuffer.isEmpty(); } @NoPublicAPI protected  Handshaker(boolean isClient, int initialMessageSeq, DTLSSession session, RecordLayer recordLayer,
			ScheduledExecutorService timer, Connection connection, DtlsConnectorConfig config); boolean isInboundMessageProcessed(); final void processMessage(Record record); abstract void startHandshake(); void processAsyncHandshakeResult(HandshakeResult handshakeResult); @Deprecated void processAsyncPskSecretResult(PskSecretResult pskSecretResult); final DTLSSession getSession(); final InetSocketAddress getPeerAddress(); final Connection getConnection(); Random getClientRandom(); Random getServerRandom(); void addApplicationDataForDeferredProcessing(RawData outgoingMessage); void addRecordsForDeferredProcessing(Record incomingMessage); List<RawData> takeDeferredApplicationData(); List<Record> takeDeferredRecords(); void takeDeferredApplicationData(Handshaker replacedHandshaker); void completePendingFlight(); void sendLastFlight(DTLSFlight flight); void sendFlight(DTLSFlight flight); final void addSessionListener(SessionListener listener); final void removeSessionListener(SessionListener listener); final void handshakeCompleted(); final void handshakeFailed(Throwable cause); final void handshakeAborted(Throwable cause); boolean hasSessionEstablished(); boolean isProbing(); void resetProbing(); boolean isExpired(); boolean isPskRequestPending(); boolean isRemovingConnection(); Throwable getFailureCause(); void setFailureCause(Throwable cause); final void handshakeFlightRetransmitted(int flight); final boolean isChangeCipherSpecMessageExpected(); void verifyCertificate(CertificateMessage message); @Override void destroy(); @Override boolean isDestroyed(); }
Handshaker implements Destroyable { public boolean isInboundMessageProcessed() { return inboundMessageBuffer.isEmpty(); } @NoPublicAPI protected  Handshaker(boolean isClient, int initialMessageSeq, DTLSSession session, RecordLayer recordLayer,
			ScheduledExecutorService timer, Connection connection, DtlsConnectorConfig config); boolean isInboundMessageProcessed(); final void processMessage(Record record); abstract void startHandshake(); void processAsyncHandshakeResult(HandshakeResult handshakeResult); @Deprecated void processAsyncPskSecretResult(PskSecretResult pskSecretResult); final DTLSSession getSession(); final InetSocketAddress getPeerAddress(); final Connection getConnection(); Random getClientRandom(); Random getServerRandom(); void addApplicationDataForDeferredProcessing(RawData outgoingMessage); void addRecordsForDeferredProcessing(Record incomingMessage); List<RawData> takeDeferredApplicationData(); List<Record> takeDeferredRecords(); void takeDeferredApplicationData(Handshaker replacedHandshaker); void completePendingFlight(); void sendLastFlight(DTLSFlight flight); void sendFlight(DTLSFlight flight); final void addSessionListener(SessionListener listener); final void removeSessionListener(SessionListener listener); final void handshakeCompleted(); final void handshakeFailed(Throwable cause); final void handshakeAborted(Throwable cause); boolean hasSessionEstablished(); boolean isProbing(); void resetProbing(); boolean isExpired(); boolean isPskRequestPending(); boolean isRemovingConnection(); Throwable getFailureCause(); void setFailureCause(Throwable cause); final void handshakeFlightRetransmitted(int flight); final boolean isChangeCipherSpecMessageExpected(); void verifyCertificate(CertificateMessage message); @Override void destroy(); @Override boolean isDestroyed();  }