Commit 2b48b3d0 authored by Jason Song's avatar Jason Song Committed by GitHub

Merge pull request #2684 from ctripcorp/revert-2648-#2092

parents 318a921c 212546bc
...@@ -21,9 +21,7 @@ import com.google.common.collect.Lists; ...@@ -21,9 +21,7 @@ import com.google.common.collect.Lists;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.google.common.collect.Multimap; import com.google.common.collect.Multimap;
import com.google.common.collect.Multimaps; import com.google.common.collect.Multimaps;
import com.google.common.collect.Ordering;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
import com.google.common.collect.TreeMultimap;
import com.google.gson.Gson; import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken; import com.google.gson.reflect.TypeToken;
import org.slf4j.Logger; import org.slf4j.Logger;
...@@ -56,7 +54,7 @@ import java.util.function.Function; ...@@ -56,7 +54,7 @@ import java.util.function.Function;
public class NotificationControllerV2 implements ReleaseMessageListener { public class NotificationControllerV2 implements ReleaseMessageListener {
private static final Logger logger = LoggerFactory.getLogger(NotificationControllerV2.class); private static final Logger logger = LoggerFactory.getLogger(NotificationControllerV2.class);
private final Multimap<String, DeferredResultWrapper> deferredResults = 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 = private static final Splitter STRING_SPLITTER =
Splitter.on(ConfigConsts.CLUSTER_NAMESPACE_SEPARATOR).omitEmptyStrings(); Splitter.on(ConfigConsts.CLUSTER_NAMESPACE_SEPARATOR).omitEmptyStrings();
private static final Type notificationsTypeReference = private static final Type notificationsTypeReference =
......
...@@ -7,7 +7,6 @@ import com.ctrip.framework.apollo.core.dto.ApolloConfigNotification; ...@@ -7,7 +7,6 @@ import com.ctrip.framework.apollo.core.dto.ApolloConfigNotification;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
import org.springframework.lang.NonNull;
import org.springframework.web.context.request.async.DeferredResult; import org.springframework.web.context.request.async.DeferredResult;
import java.util.List; import java.util.List;
...@@ -16,7 +15,7 @@ import java.util.Map; ...@@ -16,7 +15,7 @@ import java.util.Map;
/** /**
* @author Jason Song(song_s@ctrip.com) * @author Jason Song(song_s@ctrip.com)
*/ */
public class DeferredResultWrapper implements Comparable<DeferredResultWrapper> { public class DeferredResultWrapper {
private static final ResponseEntity<List<ApolloConfigNotification>> private static final ResponseEntity<List<ApolloConfigNotification>>
NOT_MODIFIED_RESPONSE_LIST = new ResponseEntity<>(HttpStatus.NOT_MODIFIED); NOT_MODIFIED_RESPONSE_LIST = new ResponseEntity<>(HttpStatus.NOT_MODIFIED);
...@@ -65,9 +64,4 @@ public class DeferredResultWrapper implements Comparable<DeferredResultWrapper> ...@@ -65,9 +64,4 @@ public class DeferredResultWrapper implements Comparable<DeferredResultWrapper>
public DeferredResult<ResponseEntity<List<ApolloConfigNotification>>> getResult() { public DeferredResult<ResponseEntity<List<ApolloConfigNotification>>> getResult() {
return result; 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