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();
}
}
