From 4402792abca89c84fafa2ebf98f88607e9232e63 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Mon, 26 Apr 2010 19:13:14 +0000 Subject: [PATCH] organized imports --- .../aggregator/CorrelatingMessageHandler.java | 17 ++++++++++++----- 1 file changed, 12 insertions(+), 5 deletions(-) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageHandler.java b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageHandler.java index f07664fdec..5793577ddc 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageHandler.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageHandler.java @@ -16,6 +16,18 @@ package org.springframework.integration.aggregator; +import java.util.List; +import java.util.Queue; +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.DelayQueue; +import java.util.concurrent.Delayed; +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.ScheduledFuture; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.locks.ReentrantLock; + import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -35,11 +47,6 @@ import org.springframework.integration.support.ComponentMetadata; import org.springframework.scheduling.TaskScheduler; import org.springframework.util.Assert; -import java.util.List; -import java.util.Queue; -import java.util.concurrent.*; -import java.util.concurrent.locks.ReentrantLock; - /** * MessageHandler that holds a buffer of correlated messages in a MessageStore. * This class takes care of correlated groups of messages that can be completed