本文整理了Java中com.hazelcast.instance.Node.getLogger()
方法的一些代码示例,展示了Node.getLogger()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.getLogger()
方法的具体详情如下:
包路径:com.hazelcast.instance.Node
类名称:Node
方法名:getLogger
暂无
代码示例来源:origin: hazelcast/hazelcast-jet
InternalPartitionListener(Node node, InternalPartitionServiceImpl partitionService) {
this.node = node;
this.partitionService = partitionService;
logger = node.getLogger(InternalPartitionService.class);
}
代码示例来源:origin: hazelcast/hazelcast-jet
PublishPartitionRuntimeStateTask(Node node, InternalPartitionServiceImpl partitionService) {
this.node = node;
this.partitionService = partitionService;
logger = node.getLogger(InternalPartitionService.class);
}
代码示例来源:origin: hazelcast/hazelcast-jet
ClusterStateManager(Node node, Lock clusterServiceLock) {
this.node = node;
this.clusterServiceLock = clusterServiceLock;
this.logger = node.getLogger(getClass());
}
代码示例来源:origin: hazelcast/hazelcast-jet
OperationBackupHandler(OperationServiceImpl operationService, OutboundOperationHandler outboundOperationHandler) {
this.outboundOperationHandler = outboundOperationHandler;
this.node = operationService.node;
this.nodeEngine = operationService.nodeEngine;
this.backpressureRegulator = operationService.backpressureRegulator;
this.logger = node.getLogger(getClass());
}
代码示例来源:origin: hazelcast/hazelcast-jet
public NodeMulticastListener(Node node) {
this.node = node;
this.logger = node.getLogger(NodeMulticastListener.class.getName());
this.ourConfig = node.createConfigCheck();
}
代码示例来源:origin: hazelcast/hazelcast-jet
public DefaultNodeExtension(Node node) {
this.node = node;
this.logger = node.getLogger(NodeExtension.class);
this.systemLogger = node.getLogger("com.hazelcast.system");
checkSecurityAllowed();
createAndSetPhoneHome();
}
代码示例来源:origin: hazelcast/hazelcast-jet
public SetCommandProcessor(TextCommandService textCommandService) {
super(textCommandService);
logger = textCommandService.getNode().getLogger(this.getClass().getName());
}
代码示例来源:origin: com.hazelcast/hazelcast-all
public NodeMulticastListener(Node node) {
this.node = node;
this.logger = node.getLogger(NodeMulticastListener.class.getName());
this.ourConfig = node.createConfigCheck();
}
代码示例来源:origin: com.hazelcast/hazelcast-all
public DefaultNodeExtension(Node node) {
this.node = node;
this.logger = node.getLogger(NodeExtension.class);
this.systemLogger = node.getLogger("com.hazelcast.system");
checkSecurityAllowed();
createAndSetPhoneHome();
}
代码示例来源:origin: hazelcast/hazelcast-jet
protected AbstractMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
this.clientMessage = clientMessage;
this.logger = node.getLogger(getClass());
this.node = node;
this.nodeEngine = node.nodeEngine;
this.serializationService = node.getSerializationService();
this.connection = connection;
this.clientEngine = node.clientEngine;
this.endpointManager = clientEngine.getEndpointManager();
this.endpoint = initEndpoint();
}
代码示例来源:origin: hazelcast/hazelcast-jet
PartitionReplicaStateChecker(Node node, InternalPartitionServiceImpl partitionService) {
this.node = node;
this.nodeEngine = node.getNodeEngine();
this.partitionService = partitionService;
this.logger = node.getLogger(getClass());
this.partitionStateManager = partitionService.getPartitionStateManager();
this.migrationManager = partitionService.getMigrationManager();
}
代码示例来源:origin: com.hazelcast/hazelcast-all
PartitionReplicaStateChecker(Node node, InternalPartitionServiceImpl partitionService) {
this.node = node;
this.nodeEngine = node.getNodeEngine();
this.partitionService = partitionService;
this.logger = node.getLogger(getClass());
this.partitionStateManager = partitionService.getPartitionStateManager();
this.migrationManager = partitionService.getMigrationManager();
}
代码示例来源:origin: hazelcast/hazelcast-jet
MembershipManager(Node node, ClusterServiceImpl clusterService, Lock clusterServiceLock) {
this.node = node;
this.clusterService = clusterService;
this.clusterServiceLock = clusterServiceLock;
this.nodeEngine = node.getNodeEngine();
this.logger = node.getLogger(getClass());
mastershipClaimTimeoutSeconds = node.getProperties().getInteger(MASTERSHIP_CLAIM_TIMEOUT_SECONDS);
registerThisMember();
}
代码示例来源:origin: hazelcast/hazelcast-jet
public OperationParkerImpl(NodeEngineImpl nodeEngine) {
this.nodeEngine = nodeEngine;
Node node = nodeEngine.getNode();
this.logger = node.getLogger(OperationParker.class);
this.expirationExecutor = Executors.newSingleThreadExecutor(
new SingleExecutorThreadFactory(node.getConfigClassLoader(),
createThreadName(nodeEngine.getHazelcastInstance().getName(), "operation-parker")));
this.expirationTaskFuture = expirationExecutor.submit(new ExpirationTask());
}
代码示例来源:origin: com.hazelcast/hazelcast-all
public OperationParkerImpl(NodeEngineImpl nodeEngine) {
this.nodeEngine = nodeEngine;
Node node = nodeEngine.getNode();
this.logger = node.getLogger(OperationParker.class);
this.expirationExecutor = Executors.newSingleThreadExecutor(
new SingleExecutorThreadFactory(node.getConfigClassLoader(),
createThreadName(nodeEngine.getHazelcastInstance().getName(), "operation-parker")));
this.expirationTaskFuture = expirationExecutor.submit(new ExpirationTask());
}
代码示例来源:origin: com.hazelcast/hazelcast-aws
public TcpIpJoinerOverAWS(Node node) {
super(node);
logger = node.getLogger(getClass());
AwsConfig awsConfig = fromDeprecatedAwsConfig(node.getConfig().getNetworkConfig().getJoin().getAwsConfig());
aws = new AWSClient(awsConfig);
}
代码示例来源:origin: com.hazelcast/hazelcast-all
public TcpIpJoinerOverAWS(Node node) {
super(node);
logger = node.getLogger(getClass());
AwsConfig awsConfig = fromDeprecatedAwsConfig(node.getConfig().getNetworkConfig().getJoin().getAwsConfig());
aws = new AWSClient(awsConfig);
}
代码示例来源:origin: hazelcast/hazelcast-jet
private MetricsRegistryImpl newMetricRegistry(Node node) {
ProbeLevel probeLevel = node.getProperties().getEnum(METRICS_LEVEL, ProbeLevel.class);
return new MetricsRegistryImpl(getHazelcastInstance().getName(), node.getLogger(MetricsRegistry.class), probeLevel);
}
代码示例来源:origin: hazelcast/hazelcast-jet
public HealthMonitor(Node node) {
this.node = node;
this.logger = node.getLogger(HealthMonitor.class);
this.metricRegistry = node.nodeEngine.getMetricsRegistry();
this.monitorLevel = getHealthMonitorLevel();
this.thresholdMemoryPercentage = node.getProperties().getInteger(HEALTH_MONITORING_THRESHOLD_MEMORY_PERCENTAGE);
this.thresholdCPUPercentage = node.getProperties().getInteger(HEALTH_MONITORING_THRESHOLD_CPU_PERCENTAGE);
this.monitorThread = initMonitorThread();
this.healthMetrics = new HealthMetrics();
}
代码示例来源:origin: com.hazelcast/hazelcast-all
public HealthMonitor(Node node) {
this.node = node;
this.logger = node.getLogger(HealthMonitor.class);
this.metricRegistry = node.nodeEngine.getMetricsRegistry();
this.monitorLevel = getHealthMonitorLevel();
this.thresholdMemoryPercentage = node.getProperties().getInteger(HEALTH_MONITORING_THRESHOLD_MEMORY_PERCENTAGE);
this.thresholdCPUPercentage = node.getProperties().getInteger(HEALTH_MONITORING_THRESHOLD_CPU_PERCENTAGE);
this.monitorThread = initMonitorThread();
this.healthMetrics = new HealthMetrics();
}
内容来源于网络,如有侵权,请联系作者删除!