Commit 212546bc authored by Jared Tan's avatar Jared Tan Committed by GitHub

Revert "fix #2092. (#2648)"

This reverts commit 235a5228.
parent 318a921c
......@@ -21,9 +21,7 @@ import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.google.common.collect.Multimap;
import com.google.common.collect.Multimaps;
import com.google.common.collect.Ordering;
import com.google.common.collect.Sets;
import com.google.common.collect.TreeMultimap;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import org.slf4j.Logger;
......@@ -56,7 +54,7 @@ import java.util.function.Function;
public class NotificationControllerV2 implements ReleaseMessageListener {
private static final Logger logger = LoggerFactory.getLogger(NotificationControllerV2.class);
private final Multimap<String, DeferredResultWrapper> deferredResults =
Multimaps.synchronizedSetMultimap(TreeMultimap.create(String.CASE_INSENSITIVE_ORDER, Ordering.natural()));
Multimaps.synchronizedSetMultimap(HashMultimap.create());
private static final Splitter STRING_SPLITTER =
Splitter.on(ConfigConsts.CLUSTER_NAMESPACE_SEPARATOR).omitEmptyStrings();
private static final Type notificationsTypeReference =
......
......@@ -7,7 +7,6 @@ import com.ctrip.framework.apollo.core.dto.ApolloConfigNotification;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.lang.NonNull;
import org.springframework.web.context.request.async.DeferredResult;
import java.util.List;
......@@ -16,7 +15,7 @@ import java.util.Map;
/**
* @author Jason Song(song_s@ctrip.com)
*/
public class DeferredResultWrapper implements Comparable<DeferredResultWrapper> {
public class DeferredResultWrapper {
private static final ResponseEntity<List<ApolloConfigNotification>>
NOT_MODIFIED_RESPONSE_LIST = new ResponseEntity<>(HttpStatus.NOT_MODIFIED);
......@@ -65,9 +64,4 @@ public class DeferredResultWrapper implements Comparable<DeferredResultWrapper>
public DeferredResult<ResponseEntity<List<ApolloConfigNotification>>> getResult() {
return result;
}
@Override
public int compareTo(@NonNull DeferredResultWrapper deferredResultWrapper) {
return this == deferredResultWrapper ? 0 : 1;
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment