sendHeartbeat(registration);
            }
        }
    }
    
    private void sendHeartbeat(WitnessRegistration registration) {
        try {
            WitnessHeartbeatRequest request = new WitnessHeartbeatRequest();
            request.setRegistrationId(registration.getRegistrationId());
            request.setSequenceNumber(registration.getNextSequenceNumber());
            

     *
     * @param registration the registration
     */
    private void sendHeartbeat(WitnessRegistration registration) {
        try {
            WitnessHeartbeatRequest request = new WitnessHeartbeatRequest();
            request.setRegistrationId(registration.getRegistrationId());
            request.setSequenceNumber(registration.getNextSequenceNumber());

     *
     * @param request the heartbeat request
     * @return the heartbeat response
     * @throws IOException if the RPC call fails
     */
    public WitnessHeartbeatResponse heartbeat(WitnessHeartbeatRequest request) throws IOException {
        if (!connected) {
            throw new IOException("Witness client not connected");
        }

        try {