Skip to content

Commit

Permalink
Gardening: Rename Java FIT performer from PerformerService to `Java…
Browse files Browse the repository at this point in the history
…Performer`

for consistency with `ScalaPerformer` and `KotlinPerformer`.

Change-Id: I9603e46c328a7e42bd20fbc512b673caf19e7540
Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/204941
Reviewed-by: Michael Reiche <michael.reiche@couchbase.com>
Tested-by: Build Bot <build@couchbase.com>
  • Loading branch information
dnault committed Feb 6, 2024
1 parent 6590549 commit f83568a
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 8 deletions.
4 changes: 2 additions & 2 deletions java-fit-performer/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
<properties>
<maven.compiler.target>17</maven.compiler.target>
<maven.compiler.source>17</maven.compiler.source>
<exec.mainClass>com.couchbase.PerformerService</exec.mainClass>
<exec.mainClass>com.couchbase.JavaPerformer</exec.mainClass>
</properties>

<dependencies>
Expand Down Expand Up @@ -102,7 +102,7 @@
<configuration>
<archive>
<manifest>
<mainClass>com.couchbase.PerformerService</mainClass>
<mainClass>com.couchbase.JavaPerformer</mainClass>
</manifest>
</archive>
<descriptorRefs>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,8 +96,8 @@
import static com.couchbase.client.core.io.CollectionIdentifier.DEFAULT_COLLECTION;
import static com.couchbase.client.core.io.CollectionIdentifier.DEFAULT_SCOPE;

public class PerformerService extends CorePerformer {
private static final Logger logger = LoggerFactory.getLogger(PerformerService.class);
public class JavaPerformer extends CorePerformer {
private static final Logger logger = LoggerFactory.getLogger(JavaPerformer.class);
private static final ConcurrentHashMap<String, ClusterConnection> clusterConnections = new ConcurrentHashMap<>();
private static final ConcurrentHashMap<String, RequestSpan> spans = new ConcurrentHashMap<>();

Expand Down Expand Up @@ -546,7 +546,7 @@ public static void main(String[] args) throws IOException, InterruptedException
LogRedaction.setRedactionLevel(RedactionLevel.PARTIAL);

Server server = ServerBuilder.forPort(port)
.addService(new PerformerService())
.addService(new JavaPerformer())
.build();
server.start();
logger.info("Server Started at {}", server.getPort());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
package com.couchbase.utils;

import com.couchbase.InternalPerformerFailure;
import com.couchbase.PerformerService;
import com.couchbase.JavaPerformer;
import com.couchbase.client.core.error.AmbiguousTimeoutException;
import com.couchbase.client.core.error.AuthenticationFailureException;
import com.couchbase.client.core.error.DocumentExistsException;
Expand Down Expand Up @@ -100,7 +100,7 @@ public static TransactionResult createResult(Optional<Exception> exception,
response.addLog(l.toString()));
}

String globalError = PerformerService.globalError.getAndSet(null);
String globalError = JavaPerformer.globalError.getAndSet(null);
if (globalError != null) {
response.setPerformerSpecificValidation(globalError);
}
Expand Down Expand Up @@ -250,4 +250,4 @@ public static TransactionException mapToRaise(TransactionOperationFailedExceptio
}
}
}
// [end:3.3.0]
// [end:3.3.0]

0 comments on commit f83568a

Please sign in to comment.