@SuppressWarnings("unchecked")
This commit is contained in:
@@ -18,12 +18,13 @@ public class ChunkProcessorChunkHandlerTests {
|
||||
public void testVanillaHandleChunk() {
|
||||
handler.setChunkProcessor(new ChunkProcessor<Object>() {
|
||||
public int process(Collection<? extends Object> items, int skipCount) throws Exception {
|
||||
count+=items.size();
|
||||
count += items.size();
|
||||
return 0;
|
||||
}
|
||||
});
|
||||
ChunkResponse response = handler.handleChunk(new ChunkRequest<Object>(StringUtils.commaDelimitedListToSet("foo,bar"),
|
||||
12L, 10));
|
||||
@SuppressWarnings("unchecked")
|
||||
ChunkResponse response = handler.handleChunk(new ChunkRequest<Object>(StringUtils
|
||||
.commaDelimitedListToSet("foo,bar"), 12L, 10));
|
||||
assertEquals(0, response.getSkipCount());
|
||||
assertEquals(new Long(12L), response.getJobId());
|
||||
assertTrue(response.isSuccessful());
|
||||
|
||||
Reference in New Issue
Block a user