Skip to content

Commit

Permalink
warn if the meterRegistry is different
Browse files Browse the repository at this point in the history
  • Loading branch information
jrhee17 committed Apr 26, 2021
1 parent 693f651 commit 8775eeb
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,9 @@

import java.net.UnknownHostException;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.linecorp.armeria.client.ClientBuilder;
import com.linecorp.armeria.client.ClientRequestContext;
import com.linecorp.armeria.client.encoding.DecodingClient;
Expand All @@ -39,6 +42,8 @@
*/
@Deprecated
public class LegacyCentralDogmaBuilder extends AbstractArmeriaCentralDogmaBuilder<LegacyCentralDogmaBuilder> {
private static final Logger logger = LoggerFactory.getLogger(LegacyCentralDogmaBuilder.class);

/**
* Returns a newly-created {@link CentralDogma} instance.
*
Expand Down Expand Up @@ -68,7 +73,11 @@ public CentralDogma build() throws UnknownHostException {

final EventLoopGroup executor = clientFactory().eventLoopGroup();
final int maxRetriesOnReplicationLag = maxNumRetriesOnReplicationLag();

final MeterRegistry meterRegistry = meterRegistry().orElse(clientFactory().meterRegistry());
if (meterRegistry().isPresent() && meterRegistry().get() != clientFactory().meterRegistry()) {
logger.info("The specified meterRegistry differs from the meterRegistry from clientFactory.");
}

final CentralDogma dogma = new LegacyCentralDogma(executor, builder.build(AsyncIface.class),
meterRegistry);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,9 @@

import java.net.UnknownHostException;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.linecorp.armeria.client.ClientBuilder;
import com.linecorp.armeria.client.ClientRequestContext;
import com.linecorp.armeria.client.WebClient;
Expand All @@ -34,6 +37,8 @@
*/
public final class ArmeriaCentralDogmaBuilder
extends AbstractArmeriaCentralDogmaBuilder<ArmeriaCentralDogmaBuilder> {
private static final Logger logger = LoggerFactory.getLogger(ArmeriaCentralDogmaBuilder.class);

/**
* Returns a newly-created {@link CentralDogma} instance.
*
Expand All @@ -46,7 +51,12 @@ public CentralDogma build() throws UnknownHostException {
newClientBuilder(scheme, endpointGroup, cb -> cb.decorator(DecodingClient.newDecorator()), "/");
final EventLoopGroup executor = clientFactory().eventLoopGroup();
final int maxRetriesOnReplicationLag = maxNumRetriesOnReplicationLag();

final MeterRegistry meterRegistry = meterRegistry().orElse(clientFactory().meterRegistry());
if (meterRegistry().isPresent() && meterRegistry().get() != clientFactory().meterRegistry()) {
logger.info("The specified meterRegistry differs from the meterRegistry from clientFactory.");
}

final CentralDogma dogma = new ArmeriaCentralDogma(executor,
builder.build(WebClient.class),
accessToken(), meterRegistry);
Expand Down

0 comments on commit 8775eeb

Please sign in to comment.