From bb562c891381049c572a9ba8674df0b93b7917bc Mon Sep 17 00:00:00 2001
From: Evgeniy Cheban <mister.cheban@gmail.com>
Date: Sat, 31 Oct 2026 20:28:59 +0200
Subject: [PATCH] Ensure ObservationConnection.queryFormatVersion delegates to
 underlying connection

Closes gh-156
---
 .../reindexer/binding/cproto/ObservationDataSource.java      | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/main/java/ru/rt/restream/reindexer/binding/cproto/ObservationDataSource.java b/src/main/java/ru/rt/restream/reindexer/binding/cproto/ObservationDataSource.java
index 55c5a3f2..bac81a65 100644
--- a/src/main/java/ru/rt/restream/reindexer/binding/cproto/ObservationDataSource.java
+++ b/src/main/java/ru/rt/restream/reindexer/binding/cproto/ObservationDataSource.java
@@ -96,6 +96,11 @@ public boolean hasError() {
             return delegate.hasError();
         }
 
+        @Override
+        public int queryFormatVersion() {
+            return delegate.queryFormatVersion();
+        }
+
         @Override
         public void close() {
             delegate.close();