(ignite-extensions) branch master updated: IGNITE-28856 Fix ignite-extensions compilation after IGNITE-28727 and IGNITE-28819 (#357)

[av]

This is an automated email from the ASF dual-hosted git repository.

anton-vinogradov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git


The following commit(s) were added to refs/heads/master by this push:
     new 33ff47cb IGNITE-28856 Fix ignite-extensions compilation after 
IGNITE-28727 and IGNITE-28819 (#357)
33ff47cb is described below

commit 33ff47cb7b6159337d3fd215cec849fe5ff2d4ba
Author: Anton Vinogradov <a...@apache.org>
AuthorDate: Fri Jul 3 18:55:11 2026 +0300

    IGNITE-28856 Fix ignite-extensions compilation after IGNITE-28727 and 
IGNITE-28819 (#357)
    
    * IGNITE-28856 Fix ignite-extensions compilation after IGNITE-28727 and 
IGNITE-28819
    
    * IGNITE-28856 Fix AnnotationOnSameLine checkstyle violation in JmsStreamer
    
    * IGNITE-28856 Fix AnnotationOnSameLine checkstyle violation in StringQuery
---
 .../kafka/KafkaToIgniteMetadataUpdaterTest.java    |  2 +-
 .../cache/hibernate/HibernateCacheProxy.java       | 26 ++++++++++++++++++++++
 .../apache/ignite/stream/jms11/JmsStreamer.java    |  4 ++--
 .../springdata/repository/query/StringQuery.java   |  3 +--
 4 files changed, 30 insertions(+), 5 deletions(-)

diff --git 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java
 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java
index d5576d27..5138648d 100644
--- 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java
+++ 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java
@@ -179,7 +179,7 @@ public class KafkaToIgniteMetadataUpdaterTest extends 
GridCommonAbstractTest {
             null,
             CU.affinityFields(null),
             BinaryConfiguration.DFLT_COMPACT_FOOTER,
-            CU::affinityFieldName,
+            BinaryUtils::affinityFieldName,
             log
         ) {
             @Override public boolean registerUserClassName(int typeId, String 
clsName, boolean failIfUnregistered,
diff --git 
a/modules/hibernate-ext/hibernate/src/main/java/org/apache/ignite/cache/hibernate/HibernateCacheProxy.java
 
b/modules/hibernate-ext/hibernate/src/main/java/org/apache/ignite/cache/hibernate/HibernateCacheProxy.java
index dcd9eb11..42b11173 100644
--- 
a/modules/hibernate-ext/hibernate/src/main/java/org/apache/ignite/cache/hibernate/HibernateCacheProxy.java
+++ 
b/modules/hibernate-ext/hibernate/src/main/java/org/apache/ignite/cache/hibernate/HibernateCacheProxy.java
@@ -439,6 +439,32 @@ public class HibernateCacheProxy implements 
IgniteInternalCache<Object, Object>
         return delegate.get().lockAllAsync(transform(keys), timeout);
     }
 
+    /** {@inheritDoc} */
+    @Override public boolean lockTxEntry(CacheEntry<Object, Object> entry, 
long waitTimeout) throws IgniteCheckedException {
+        return delegate.get().lockTxEntry(entry, waitTimeout);
+    }
+
+    /** {@inheritDoc} */
+    @Override public boolean lockTxEntries(
+        Collection<CacheEntry<Object, Object>> entries,
+        long waitTimeout
+    ) throws IgniteCheckedException {
+        return delegate.get().lockTxEntries(entries, waitTimeout);
+    }
+
+    /** {@inheritDoc} */
+    @Override public IgniteInternalFuture<Boolean> 
lockTxEntryAsync(CacheEntry<Object, Object> entry, long waitTimeout) {
+        return delegate.get().lockTxEntryAsync(entry, waitTimeout);
+    }
+
+    /** {@inheritDoc} */
+    @Override public IgniteInternalFuture<Boolean> lockTxEntriesAsync(
+        Collection<CacheEntry<Object, Object>> entries,
+        long waitTimeout
+    ) {
+        return delegate.get().lockTxEntriesAsync(entries, waitTimeout);
+    }
+
     /** {@inheritDoc} */
     @Override public void unlock(Object key) throws IgniteCheckedException {
         delegate.get().unlock(keyTransformer.transform(key));
diff --git 
a/modules/jms11-ext/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java
 
b/modules/jms11-ext/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java
index b9e09871..2f11e204 100644
--- 
a/modules/jms11-ext/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java
+++ 
b/modules/jms11-ext/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java
@@ -521,8 +521,8 @@ public class JmsStreamer<T extends Message, K, V> extends 
StreamAdapter<T, K, V>
             }
 
             executor.execute(new Runnable() {
-                @Override @SuppressWarnings("unchecked")
-                public void run() {
+                @SuppressWarnings("unchecked")
+                @Override public void run() {
                     processMessage((T)message);
                     if (batched) {
                         // batch completion may be handled by timer only
diff --git 
a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/query/StringQuery.java
 
b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/query/StringQuery.java
index 20ba53e3..97742525 100644
--- 
a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/query/StringQuery.java
+++ 
b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/query/StringQuery.java
@@ -135,8 +135,7 @@ class StringQuery implements DeclaredQuery {
 
     // See 
org.springframework.data.jpa.repository.query.DeclaredQuery#getAlias()
     /** {@inheritDoc} */
-    @Override @Nullable
-    public String getAlias() {
+    @Nullable @Override public String getAlias() {
         return alias;
     }