findbugs fixes
This commit is contained in:
@@ -44,7 +44,7 @@ public class MessageOrientedStep extends AbstractStep {
|
||||
|
||||
private PollableChannel source;
|
||||
|
||||
private static int MINUTE = 1000 * 60;
|
||||
private static long MINUTE = 1000 * 60;
|
||||
|
||||
private long executionTimeout = 30*MINUTE ;
|
||||
|
||||
|
||||
@@ -172,7 +172,7 @@ public class ChunkMessageItemWriterIntegrationTests {
|
||||
stepExecution.getExecutionContext().putLong(ChunkMessageChannelItemWriter.EXPECTED, 3);
|
||||
stepExecution.getExecutionContext().putLong(ChunkMessageChannelItemWriter.ACTUAL, 2);
|
||||
// And make the back log real
|
||||
requests.send(getSimpleMessage("foo", new Long(4321)));
|
||||
requests.send(getSimpleMessage("foo", 4321L));
|
||||
step.execute(stepExecution);
|
||||
assertEquals(BatchStatus.FAILED, stepExecution.getStatus());
|
||||
assertEquals(ExitStatus.FAILED.getExitCode(), stepExecution.getExitStatus().getExitCode());
|
||||
|
||||
@@ -26,7 +26,7 @@ public class ChunkProcessorChunkHandlerTests {
|
||||
ChunkResponse response = handler.handleChunk(new ChunkRequest<Object>(StringUtils
|
||||
.commaDelimitedListToSet("foo,bar"), 12L, 10));
|
||||
assertEquals(0, response.getSkipCount());
|
||||
assertEquals(new Long(12L), response.getJobId());
|
||||
assertEquals(12, response.getJobId().longValue());
|
||||
assertTrue(response.isSuccessful());
|
||||
assertEquals(2, count);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user