diff --git a/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/RdaSink.java b/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/RdaSink.java index f6ae35f525..e5e4a44da2 100644 --- a/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/RdaSink.java +++ b/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/RdaSink.java @@ -193,9 +193,9 @@ Optional transformMessage(String apiVersion, TMessage message) int writeClaims(Collection objects) throws ProcessingException; /** - * test. + * Updates the available range of sequence numbers. * - * @param sequenceNumberRange test + * @param sequenceNumberRange Current range of sequence numbers. */ void updateSequenceNumberRange(ClaimSequenceNumberRange sequenceNumberRange); diff --git a/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/server/MessageSource.java b/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/server/MessageSource.java index e03e6a50d2..335ec045c4 100644 --- a/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/server/MessageSource.java +++ b/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/server/MessageSource.java @@ -40,9 +40,9 @@ public interface MessageSource extends AutoCloseable { MessageSource skipTo(long startingSequenceNumber) throws Exception; /** - * test. + * Returns the current range of sequence numbers. * - * @return test + * @return sequence number range */ ClaimSequenceNumberRange getSequenceNumberRange(); } diff --git a/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/sink/direct/AbstractClaimRdaSink.java b/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/sink/direct/AbstractClaimRdaSink.java index 775849437b..9ea2dae12c 100644 --- a/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/sink/direct/AbstractClaimRdaSink.java +++ b/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/sink/direct/AbstractClaimRdaSink.java @@ -540,10 +540,10 @@ static class Metrics { /** The number of insert statements executed. */ private final DistributionSummary insertCount; - /** test. */ + /** Maximum available sequence number. */ private final AtomicLong maxSequenceNumber; - /** test. */ + /** The value returned by the maxSequenceNumber gauge. */ private final AtomicLong maxSequenceNumberValue; /** @@ -588,9 +588,9 @@ void setLatestSequenceNumber(long value) { } /** - * test. + * Sets the {@link #maxSequenceNumber}. * - * @param value test + * @param value value to set */ void setMaxSequenceNumber(long value) { maxSequenceNumberValue.set(value); diff --git a/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/source/GrpcStreamCaller.java b/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/source/GrpcStreamCaller.java index d11314556e..3e7d34ff9e 100644 --- a/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/source/GrpcStreamCaller.java +++ b/apps/bfd-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/source/GrpcStreamCaller.java @@ -64,11 +64,11 @@ public abstract GrpcResponseStream callService( throws Exception; /** - * test. + * Calls the service to get the sequence number range. * - * @param channel test - * @param callOptions test - * @return test + * @param channel an already open channel to the service being called + * @param callOptions the CallOptions object to use for the API call + * @return sequence number range */ public abstract ClaimSequenceNumberRange callSequenceNumberRangeService( ManagedChannel channel, CallOptions callOptions);