This is an automated email from the ASF dual-hosted git repository. nizhikov 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 b65dfc7 IGNITE-16932 Checkstyle RightCurly rule added (#140) b65dfc7 is described below commit b65dfc77f24d9929506f0a131eb8e1c2d29196f4 Author: Nikolay <nizhi...@apache.org> AuthorDate: Fri May 13 11:31:26 2022 +0300 IGNITE-16932 Checkstyle RightCurly rule added (#140) --- .../tcp/ipfinder/azure/TcpDiscoveryAzureBlobStoreIpFinder.java | 6 ++++-- .../java/org/apache/ignite/cdc/CacheConflictOperationsTest.java | 3 ++- .../java/org/apache/ignite/cache/hibernate/HibernateRegion.java | 3 ++- .../performancestatistics/PerformanceStatisticsReportSelfTest.java | 3 ++- .../main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java | 6 ++++-- .../ignite/springdata/repository/support/IgniteProxyFactory.java | 3 ++- .../org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java | 3 ++- 7 files changed, 18 insertions(+), 9 deletions(-) diff --git a/modules/azure-ext/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/azure/TcpDiscoveryAzureBlobStoreIpFinder.java b/modules/azure-ext/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/azure/TcpDiscoveryAzureBlobStoreIpFinder.java index a53d9a3..35d2695 100644 --- a/modules/azure-ext/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/azure/TcpDiscoveryAzureBlobStoreIpFinder.java +++ b/modules/azure-ext/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/azure/TcpDiscoveryAzureBlobStoreIpFinder.java @@ -170,7 +170,8 @@ public class TcpDiscoveryAzureBlobStoreIpFinder extends TcpDiscoveryIpFinderAdap try { blobContainerClient.getBlobClient(key).delete(); - } catch (Exception e) { + } + catch (Exception e) { // https://github.com/Azure/azure-sdk-for-java/issues/20551 if ((!(e.getMessage().contains("InterruptedException"))) || (e instanceof BlobStorageException && (((BlobStorageException)e).getErrorCode() != BlobErrorCode.BLOB_NOT_FOUND))) { @@ -279,7 +280,8 @@ public class TcpDiscoveryAzureBlobStoreIpFinder extends TcpDiscoveryIpFinderAdap try { if (!blobContainerClient.exists()) throw new IgniteSpiException("IpFinder has not been initialized properly"); - } catch (Exception e) { + } + catch (Exception e) { // Check if this is a nested exception wrapping an InterruptedException // https://github.com/Azure/azure-sdk-for-java/issues/20551 if (!(e.getCause() instanceof InterruptedException)) { diff --git a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CacheConflictOperationsTest.java b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CacheConflictOperationsTest.java index 8d8738e..20a0e5f 100644 --- a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CacheConflictOperationsTest.java +++ b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CacheConflictOperationsTest.java @@ -286,7 +286,8 @@ public class CacheConflictOperationsTest extends GridCommonAbstractTest { if (success) { assertEquals(newVer, ((GridCacheVersion)cache.getEntry(k).version()).conflictVersion()); assertEquals(newVal, cache.get(k)); - } else if (oldEntry != null) { + } + else if (oldEntry != null) { assertEquals(oldEntry.getValue(), cache.get(k)); assertEquals(oldEntry.version(), cache.getEntry(k).version()); } diff --git a/modules/hibernate-ext/hibernate/src/main/java/org/apache/ignite/cache/hibernate/HibernateRegion.java b/modules/hibernate-ext/hibernate/src/main/java/org/apache/ignite/cache/hibernate/HibernateRegion.java index 184196e..648627d 100644 --- a/modules/hibernate-ext/hibernate/src/main/java/org/apache/ignite/cache/hibernate/HibernateRegion.java +++ b/modules/hibernate-ext/hibernate/src/main/java/org/apache/ignite/cache/hibernate/HibernateRegion.java @@ -47,7 +47,8 @@ public abstract class HibernateRegion extends AbstractRegion implements Extended @Override public void clear() { try { cache.clear(); - } catch (IgniteCheckedException e) { + } + catch (IgniteCheckedException e) { throw new CacheException("Problem clearing cache [name=" + cache.name() + "]", e); } } diff --git a/modules/performance-statistics-ext/src/test/java/org/apache/ignite/internal/performancestatistics/PerformanceStatisticsReportSelfTest.java b/modules/performance-statistics-ext/src/test/java/org/apache/ignite/internal/performancestatistics/PerformanceStatisticsReportSelfTest.java index 79314d1..140ae64 100644 --- a/modules/performance-statistics-ext/src/test/java/org/apache/ignite/internal/performancestatistics/PerformanceStatisticsReportSelfTest.java +++ b/modules/performance-statistics-ext/src/test/java/org/apache/ignite/internal/performancestatistics/PerformanceStatisticsReportSelfTest.java @@ -110,7 +110,8 @@ public class PerformanceStatisticsReportSelfTest { assertTrue(index.exists()); assertTrue(dataDir.exists()); assertTrue(dataJs.exists()); - } finally { + } + finally { U.delete(new File(U.defaultWorkDirectory())); } } diff --git a/modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java b/modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java index 32f0e32..b626b41 100644 --- a/modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java +++ b/modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java @@ -217,7 +217,8 @@ public class PubSubStreamer<K, V> extends StreamAdapter<PubsubMessage, K, V> { this.subscriptionName = subscriptionName; this.returnImmediately = returnImmediately; this.maxMessages = maxMessages; - } catch (IOException e) { + } + catch (IOException e) { throw new IgniteException(e); } } @@ -248,7 +249,8 @@ public class PubSubStreamer<K, V> extends StreamAdapter<PubsubMessage, K, V> { subscriberStub.acknowledgeCallable().call(acknowledgeRequest); } - } finally { + } + finally { subscriberStub.close(); } diff --git a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/support/IgniteProxyFactory.java b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/support/IgniteProxyFactory.java index a722e0e..433988f 100644 --- a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/support/IgniteProxyFactory.java +++ b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/support/IgniteProxyFactory.java @@ -152,7 +152,8 @@ public class IgniteProxyFactory implements ApplicationContextAware, DisposableBe default Object getBean() { try { return get(); - } catch (BeansException ex) { + } + catch (BeansException ex) { return null; } } diff --git a/modules/twitter-ext/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java b/modules/twitter-ext/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java index 0cfefc2..b61e98d 100644 --- a/modules/twitter-ext/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java +++ b/modules/twitter-ext/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java @@ -124,7 +124,8 @@ public class IgniteTwitterStreamerTest extends GridCommonAbstractTest { streamer.setThreadsCount(8); executeStreamer(streamer); - } finally { + } + finally { cleanup(); } }