Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
</developer>
</developers>

<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>

<modules>
<module>spring-batch-lightmin-core</module>
Expand All @@ -48,6 +48,7 @@
<module>spring-batch-lightmin-embedded</module>
<module>spring-batch-lightmin-validation</module>
<module>spring-batch-lightmin-metrics</module>
<module>spring-batch-lightmin-bom</module>
</modules>

<properties>
Expand Down
2 changes: 1 addition & 1 deletion spring-batch-lightmin-api/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
2 changes: 1 addition & 1 deletion spring-batch-lightmin-bom/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

<groupId>org.tuxdevelop</groupId>
<artifactId>spring-batch-lightmin-bom</artifactId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
<packaging>pom</packaging>

<name>Spring Batch Lightmin BOM</name>
Expand Down
2 changes: 1 addition & 1 deletion spring-batch-lightmin-client/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin-client</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.web.client.RestTemplate;
import org.tuxdevelop.spring.batch.lightmin.client.annotation.EnableLightminClientCore;
import org.tuxdevelop.spring.batch.lightmin.client.classic.event.OnClientApplicationReadyEventListener;
Expand All @@ -14,12 +15,14 @@
import org.tuxdevelop.spring.batch.lightmin.client.classic.service.LightminClientRegistratorService;
import org.tuxdevelop.spring.batch.lightmin.client.classic.service.UrlLightminServerLocatorService;
import org.tuxdevelop.spring.batch.lightmin.client.configuration.LightminClientProperties;
import org.tuxdevelop.spring.batch.lightmin.client.configuration.LightminClientPublishEventsConfiguration;
import org.tuxdevelop.spring.batch.lightmin.client.service.LightminServerLocatorService;

@Configuration
@EnableLightminClientCore
@EnableConfigurationProperties(
value = {LightminClientClassicConfigurationProperties.class})
@Import(LightminClientPublishEventsConfiguration.class)
public class ClassicLightminClientConfiguration {

@Bean
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,4 @@
spring:
main:
allow-bean-definition-overriding: true
application:
name: test_application
batch:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin-client</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,38 +53,6 @@ public RestTemplate serverRestTemplate(final LightminClientProperties lightminCl
lightminClientProperties.getServer());
}

@Configuration
@ConditionalOnProperty(
prefix = "spring.batch.lightmin.client",
value = "publish-job-events",
havingValue = "true",
matchIfMissing = true)
public static class LightminClientPublishEventsConfiguration {

@Bean
@ConditionalOnMissingBean(value = {StepExecutionEventPublisher.class})
public StepExecutionEventPublisher stepExecutionEventPublisher(
final LightminServerLocatorService lightminServerLocator,
@Qualifier("serverRestTemplate") final RestTemplate restTemplate) {
return new RemoteStepExecutionEventPublisher(restTemplate, lightminServerLocator);
}

@Bean
@ConditionalOnMissingBean(value = {JobExecutionEventPublisher.class})
public JobExecutionEventPublisher jobExecutionEventPublisher(
final LightminServerLocatorService lightminServerLocatorService,
@Qualifier("serverRestTemplate") final RestTemplate restTemplate) {
return new RemoteJobExecutionEventPublisher(restTemplate, lightminServerLocatorService);
}

@Bean
public OnJobExecutionFinishedEventListener onJobExecutionFinishedEventListener(
final JobExecutionEventPublisher jobExecutionEventPublisher,
final StepExecutionEventPublisher stepExecutionEventPublisher) {
return new OnJobExecutionFinishedEventListener(jobExecutionEventPublisher, stepExecutionEventPublisher);
}
}

@Configuration
@ConditionalOnProperty(
prefix = "spring.batch.lightmin.client",
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
package org.tuxdevelop.spring.batch.lightmin.client.configuration;

import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
import org.tuxdevelop.spring.batch.lightmin.client.listener.OnJobExecutionFinishedEventListener;
import org.tuxdevelop.spring.batch.lightmin.client.publisher.JobExecutionEventPublisher;
import org.tuxdevelop.spring.batch.lightmin.client.publisher.RemoteJobExecutionEventPublisher;
import org.tuxdevelop.spring.batch.lightmin.client.publisher.RemoteStepExecutionEventPublisher;
import org.tuxdevelop.spring.batch.lightmin.client.publisher.StepExecutionEventPublisher;
import org.tuxdevelop.spring.batch.lightmin.client.service.LightminServerLocatorService;

@Configuration
@ConditionalOnProperty(
prefix = "spring.batch.lightmin.client",
value = "publish-job-events",
havingValue = "true",
matchIfMissing = true)
public class LightminClientPublishEventsConfiguration {

@Bean
@ConditionalOnMissingBean(value = {StepExecutionEventPublisher.class})
public StepExecutionEventPublisher stepExecutionEventPublisher(
final LightminServerLocatorService lightminServerLocator,
@Qualifier("serverRestTemplate") final RestTemplate restTemplate) {
return new RemoteStepExecutionEventPublisher(restTemplate, lightminServerLocator);
}

@Bean
@ConditionalOnMissingBean(value = {JobExecutionEventPublisher.class})
public JobExecutionEventPublisher jobExecutionEventPublisher(
final LightminServerLocatorService lightminServerLocatorService,
@Qualifier("serverRestTemplate") final RestTemplate restTemplate) {
return new RemoteJobExecutionEventPublisher(restTemplate, lightminServerLocatorService);
}

@Bean
public OnJobExecutionFinishedEventListener onJobExecutionFinishedEventListener(
final JobExecutionEventPublisher jobExecutionEventPublisher,
final StepExecutionEventPublisher stepExecutionEventPublisher) {
return new OnJobExecutionFinishedEventListener(jobExecutionEventPublisher, stepExecutionEventPublisher);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin-client</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,4 @@
spring:
main:
allow-bean-definition-overriding: true
application:
name: test_application
batch:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin-client</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
package org.tuxdevelop.spring.batch.lightmin.client.discovery.configuration;

import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
Expand All @@ -12,8 +11,6 @@
import org.tuxdevelop.spring.batch.lightmin.client.configuration.LightminClientConfiguration;
import org.tuxdevelop.spring.batch.lightmin.client.configuration.LightminClientProperties;
import org.tuxdevelop.spring.batch.lightmin.client.discovery.listener.DiscoveryListener;
import org.tuxdevelop.spring.batch.lightmin.client.discovery.metadata.MetaDataExtender;
import org.tuxdevelop.spring.batch.lightmin.client.discovery.metadata.NoOperationMetaDataExtender;
import org.tuxdevelop.spring.batch.lightmin.client.discovery.service.DiscoveryLightminServerLocatorService;
import org.tuxdevelop.spring.batch.lightmin.client.service.LightminServerLocatorService;

Expand All @@ -33,12 +30,6 @@ public DiscoveryListener discoveryListener(final LightminClientProperties lightm
return new DiscoveryListener(lightminClientProperties);
}

@Bean
@ConditionalOnMissingBean(MetaDataExtender.class)
public MetaDataExtender metaDataExtender() {
return new NoOperationMetaDataExtender();
}

@Bean
public LightminServerLocatorService discoveryLightminServerLocator(
final LightminClientDiscoveryProperties lightminClientDiscoveryProperties,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin-client</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,4 @@
spring:
main:
allow-bean-definition-overriding: true
application:
name: test_application
batch:
Expand Down
2 changes: 1 addition & 1 deletion spring-batch-lightmin-core/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
<parent>
<artifactId>spring-batch-lightmin</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>

<artifactId>spring-batch-lightmin-core</artifactId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin-core</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.task.SimpleAsyncTaskExecutor;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.support.incrementer.AbstractDataFieldMaxValueIncrementer;
Expand Down Expand Up @@ -92,12 +91,6 @@ public JobLauncher defaultAsyncJobLauncher(final JobRepository jobRepository) {
return jobLauncher;
}

@Primary
@Bean(name = "jobLauncher")
public JobLauncher jobLauncher(final BatchConfigurer batchConfigurer) throws Exception {
return batchConfigurer.getJobLauncher();
}

@Bean
@ConditionalOnMissingBean(value = {JobLauncher.class})
public JobExplorer jobExplorer(final BatchConfigurer batchConfigurer) throws Exception {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,2 +1 @@
spring.batch.job.enabled=false
spring.main.allow-bean-definition-overriding=true
spring.batch.job.enabled=false
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<artifactId>spring-batch-lightmin-core</artifactId>
<groupId>org.tuxdevelop</groupId>
<version>2.2.2-SNAPSHOT</version>
<version>2.2.3-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,6 @@
@ConfigurationProperties(prefix = "spring.batch.lightmin")
public class SpringBatchLightminCoreConfigurationProperties {

private static final String DEFAULT_DATA_SOURCE_NAME = "dataSource";

private final Environment environment;

@Autowired
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package org.tuxdevelop.spring.batch.lightmin.util;

import lombok.extern.slf4j.Slf4j;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.springframework.batch.core.Job;
Expand All @@ -19,6 +20,7 @@
import java.util.Set;

import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.assertFalse;

@Slf4j
public class BeanRegistrarIT {
Expand All @@ -28,12 +30,25 @@ public class BeanRegistrarIT {
private Job simpleJob;
private JobLauncher jobLauncher;

@Test
public void registerUnregisteredBean() {
this.beanRegistrar.registerBean(String.class, "firstBean", null, null, null, null, null);
String registeredBean = (String) this.applicationContext.getBean("firstBean");
assertThat(registeredBean).isNotNull();

this.beanRegistrar.unregisterBean("firstBean");
assertFalse(this.applicationContext.containsBeanDefinition("firstBean"));

this.beanRegistrar.registerBean(String.class, "firstBean", null, null, null, null, null);
registeredBean = (String) this.applicationContext.getBean("firstBean");
assertThat(registeredBean).isNotNull();
}

@Test
public void registerBeanStringIT() {
this.beanRegistrar.registerBean(String.class, "sampleString", null, null, null, null, null);
final String registeredBean = (String) this.applicationContext.getBean("sampleString");
assertThat(registeredBean).isNotNull();
this.applicationContext.close();
}

@Test
Expand All @@ -44,7 +59,6 @@ public void registerBeanStringValueIT() {
final String registeredBean = (String) this.applicationContext.getBean("sampleString");
assertThat(registeredBean).isNotNull();
assertThat(registeredBean).isEqualTo("Test");
this.applicationContext.close();
}

@Test(expected = NoSuchBeanDefinitionException.class)
Expand All @@ -58,7 +72,6 @@ public void unregisterBeanStringIT() {
this.beanRegistrar.unregisterBean("sampleStringSecond");
final String gotBean = this.applicationContext.getBean("sampleStringSecond", String.class);
log.info("got: " + gotBean);
this.applicationContext.close();
}

@Test(expected = NoSuchBeanDefinitionException.class)
Expand Down Expand Up @@ -88,7 +101,6 @@ public void registerPeriodSchedulerIT() {
.class);
assertThat(periodScheduler).isNotNull();
periodScheduler.schedule();
this.applicationContext.close();
}

@Before
Expand All @@ -98,4 +110,9 @@ public void init() {
this.simpleJob = this.applicationContext.getBean("simpleJob", Job.class);
this.jobLauncher = this.applicationContext.getBean("jobLauncher", JobLauncher.class);
}

@After
public void tearDown() {
this.applicationContext.close();
}
}
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
spring.batch.job.enabled=false
spring.batch.lightmin.batch.repository-type=jdbc
spring.batch.lightmin.application-name=test
spring.main.allow-bean-definition-overriding=true
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
spring.batch.job.enabled=false
spring.batch.lightmin.batch.repository-type=map
spring.batch.lightmin.application-name=test
spring.main.allow-bean-definition-overriding=true
Loading