Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
zhaoyuguang committed Jul 15, 2020
1 parent e94e93f commit d1ab802
Showing 1 changed file with 7 additions and 7 deletions.
Expand Up @@ -17,6 +17,7 @@

package org.apache.shardingsphere.elasticjob.lite.boot;

import com.google.common.base.Strings;
import lombok.Setter;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
Expand All @@ -26,7 +27,6 @@
import org.apache.shardingsphere.elasticjob.reg.base.CoordinatorRegistryCenter;
import org.apache.shardingsphere.elasticjob.reg.boot.ElasticJobRegistryCenterAutoConfiguration;
import org.apache.shardingsphere.elasticjob.tracing.api.TracingConfiguration;
import org.assertj.core.util.Strings;
import org.springframework.beans.factory.BeanCreationException;
import org.springframework.beans.factory.config.SingletonBeanRegistry;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
Expand All @@ -50,9 +50,9 @@
@EnableConfigurationProperties(ElasticJobProperties.class)
@Setter
public class ElasticJobLiteAutoConfiguration implements ApplicationContextAware {

private ApplicationContext applicationContext;

/**
* Create job bootstrap instances.
*
Expand All @@ -68,7 +68,7 @@ public void createJobBootstrapBeans() throws ClassNotFoundException {
registerClassedJobs(elasticJobProperties, beanFactory, registryCenter, tracingConfiguration);
registerTypedJobs(elasticJobProperties, beanFactory, registryCenter, tracingConfiguration);
}

private TracingConfiguration getTracingConfiguration() {
Map<String, TracingConfiguration> tracingConfigurationBeans = applicationContext.getBeansOfType(TracingConfiguration.class);
if (tracingConfigurationBeans.isEmpty()) {
Expand All @@ -81,7 +81,7 @@ private TracingConfiguration getTracingConfiguration() {
"More than one [org.apache.shardingsphere.elasticjob.tracing.api.TracingConfiguration] beans found. "
+ "Consider disabling [org.apache.shardingsphere.elasticjob.tracing.boot.ElasticjobTracingAutoConfiguration].");
}

private void registerClassedJobs(final ElasticJobProperties elasticJobProperties, final SingletonBeanRegistry beanFactory,
final CoordinatorRegistryCenter registryCenter, final TracingConfiguration tracingConfiguration) throws ClassNotFoundException {
for (Entry<String, List<JobConfigurationPOJO>> entry : elasticJobProperties.getClassed().entrySet()) {
Expand All @@ -97,8 +97,8 @@ private void registerClassedJobs(final ElasticJobProperties elasticJobProperties
}
}
}
private void registerTypedJobs(final ElasticJobProperties elasticJobProperties, final SingletonBeanRegistry beanFactory,

private void registerTypedJobs(final ElasticJobProperties elasticJobProperties, final SingletonBeanRegistry beanFactory,
final CoordinatorRegistryCenter registryCenter, final TracingConfiguration tracingConfiguration) {
for (Entry<String, List<JobConfigurationPOJO>> entry : elasticJobProperties.getTyped().entrySet()) {
for (JobConfigurationPOJO each : entry.getValue()) {
Expand Down

0 comments on commit d1ab802

Please sign in to comment.