handleSelfMessage(message);
} else {
handleAppMessage(message);
}
}
<BUG>private void handleHearbeatPing(HeartbeatPing ping) {
</BUG>
HeartbeatAck.Builder ack = new HeartbeatAck.Builder().status(ping.status);
if (inputStream.newStreamIdAvailable()) {
ack.last_stream_id_received(inputStream.getStreamId());

handleSelfMessage(message);
} else {
handleAppMessage(message);
}
}
private void handleHeartbeatPing(HeartbeatPing ping) {
HeartbeatAck.Builder ack = new HeartbeatAck.Builder().status(ping.status);
if (inputStream.newStreamIdAvailable()) {
ack.last_stream_id_received(inputStream.getStreamId());
