Housecleaning of build warnings

This commit is contained in:
Michael Minella
2017-09-15 15:58:22 -05:00
parent 340406a61f
commit b180c75ce0
46 changed files with 180 additions and 144 deletions

View File

@@ -27,6 +27,8 @@ import org.springframework.batch.item.ItemWriterException;
*/
public class AsynchronousFailureException extends ItemWriterException {
private static final long serialVersionUID = 1L;
/**
* Create a new {@link AsynchronousFailureException} based on a message and
* another exception.

View File

@@ -216,6 +216,7 @@ public class ChunkMessageChannelItemWriter<T> extends StepExecutionListenerSuppo
* @throws IllegalStateException if the result contains the wrong job instance id (maybe we are sharing a channel
* and we shouldn't be)
*/
@SuppressWarnings("unchecked")
private void getNextResult() throws AsynchronousFailureException {
Message<ChunkResponse> message = (Message<ChunkResponse>) messagingGateway.receive(replyChannel);
if (message != null) {

View File

@@ -31,6 +31,8 @@ import org.springframework.batch.core.StepContribution;
*/
public class ChunkRequest<T> implements Serializable {
private static final long serialVersionUID = 1L;
private final long jobId;
private final Collection<? extends T> items;

View File

@@ -28,6 +28,8 @@ import org.springframework.batch.core.StepContribution;
*/
public class ChunkResponse implements Serializable {
private static final long serialVersionUID = 1L;
private final StepContribution stepContribution;
private final Long jobId;

View File

@@ -122,7 +122,7 @@ public class RemoteChunkHandlerFactoryBean<T> implements FactoryBean<ChunkHandle
logger.debug("Converting TaskletStep with name=" + step.getName());
}
Tasklet tasklet = getTasklet((TaskletStep) step);
Tasklet tasklet = getTasklet(step);
Assert.state(tasklet instanceof ChunkOrientedTasklet<?>, "Tasklet must be ChunkOrientedTasklet in step="
+ step.getName());

View File

@@ -15,6 +15,8 @@
*/
package org.springframework.batch.integration.config.xml;
import org.w3c.dom.Element;
import org.springframework.batch.core.step.item.SimpleChunkProcessor;
import org.springframework.batch.integration.chunk.ChunkProcessorChunkHandler;
import org.springframework.batch.item.support.PassThroughItemProcessor;
@@ -29,7 +31,6 @@ import org.springframework.integration.config.ServiceActivatorFactoryBean;
import org.springframework.integration.config.xml.AbstractConsumerEndpointParser;
import org.springframework.util.Assert;
import org.springframework.util.StringUtils;
import org.w3c.dom.Element;
/**
* <p>
@@ -78,7 +79,7 @@ public class RemoteChunkingSlaveParser extends AbstractBeanDefinitionParser {
if(StringUtils.hasText(itemProcessor)) {
chunkProcessorBuilder.addPropertyReference(ITEM_PROCESSOR_PROPERTY_NAME, itemProcessor);
} else {
chunkProcessorBuilder.addPropertyValue(ITEM_PROCESSOR_PROPERTY_NAME, new PassThroughItemProcessor());
chunkProcessorBuilder.addPropertyValue(ITEM_PROCESSOR_PROPERTY_NAME, new PassThroughItemProcessor<>());
}
BeanDefinition chunkProcessorChunkHandler =

View File

@@ -31,7 +31,7 @@ public class BeanFactoryStepLocator implements StepLocator, BeanFactoryAware {
* @see StepLocator#getStep(String)
*/
public Step getStep(String stepName) {
return (Step) beanFactory.getBean(stepName, Step.class);
return beanFactory.getBean(stepName, Step.class);
}
/**

View File

@@ -4,6 +4,8 @@ import java.io.Serializable;
public class StepExecutionRequest implements Serializable {
private static final long serialVersionUID = 1L;
private final Long stepExecutionId;
private final String stepName;