Skip to content

Commit 35f2a44

Browse files
spotless and remove repeat annotation
1 parent af00bcd commit 35f2a44

File tree

2 files changed

+4
-11
lines changed

2 files changed

+4
-11
lines changed

x-pack/plugin/security/src/main/java/org/elasticsearch/xpack/security/transport/CrossClusterAccessTransportInterceptor.java

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -80,9 +80,7 @@ public class CrossClusterAccessTransportInterceptor implements RemoteClusterTran
8080
TaskCancellationService.REMOTE_CLUSTER_CANCEL_CHILD_ACTION_NAME
8181
);
8282

83-
private final Function<
84-
Transport.Connection,
85-
Optional<RemoteClusterAliasWithCredentials>> remoteClusterCredentialsResolver;
83+
private final Function<Transport.Connection, Optional<RemoteClusterAliasWithCredentials>> remoteClusterCredentialsResolver;
8684
private final CrossClusterAccessAuthenticationService crossClusterAccessAuthcService;
8785
private final AuthenticationService authcService;
8886
private final AuthorizationService authzService;
@@ -165,8 +163,8 @@ public <T extends TransportResponse> void sendRequest(
165163
* Returns cluster credentials if the connection is remote, and cluster credentials are set up for the target cluster.
166164
*/
167165
private Optional<RemoteClusterCredentials> getRemoteClusterCredentials(Transport.Connection connection) {
168-
final Optional<RemoteClusterAliasWithCredentials> remoteClusterAliasWithCredentials =
169-
remoteClusterCredentialsResolver.apply(connection);
166+
final Optional<RemoteClusterAliasWithCredentials> remoteClusterAliasWithCredentials = remoteClusterCredentialsResolver
167+
.apply(connection);
170168
if (remoteClusterAliasWithCredentials.isEmpty()) {
171169
logger.trace("Connection is not remote");
172170
return Optional.empty();
@@ -325,9 +323,7 @@ private static IllegalArgumentException illegalArgumentExceptionWithDebugLog(Str
325323

326324
@Override
327325
public boolean isRemoteClusterConnection(Transport.Connection connection) {
328-
return remoteClusterCredentialsResolver.apply(connection)
329-
.map(RemoteClusterAliasWithCredentials::clusterAlias)
330-
.isPresent();
326+
return remoteClusterCredentialsResolver.apply(connection).map(RemoteClusterAliasWithCredentials::clusterAlias).isPresent();
331327
}
332328

333329
@Override

x-pack/plugin/security/src/test/java/org/elasticsearch/xpack/security/transport/SecurityServerTransportInterceptorTests.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,6 @@
66
*/
77
package org.elasticsearch.xpack.security.transport;
88

9-
import com.carrotsearch.randomizedtesting.annotations.Repeat;
10-
119
import org.elasticsearch.ElasticsearchSecurityException;
1210
import org.elasticsearch.TransportVersion;
1311
import org.elasticsearch.TransportVersions;
@@ -114,7 +112,6 @@
114112
import static org.mockito.Mockito.verify;
115113
import static org.mockito.Mockito.when;
116114

117-
@Repeat(iterations = 1000)
118115
public class SecurityServerTransportInterceptorTests extends ESTestCase {
119116

120117
private Settings settings;

0 commit comments

Comments
 (0)