review feedback
This commit is contained in:
parent
f6db6ff068
commit
5b05e9cda0
|
@ -53,11 +53,11 @@ public class SubscriptionRegistry {
|
||||||
private static final Logger ourLog = LoggerFactory.getLogger(SubscriptionRegistry.class);
|
private static final Logger ourLog = LoggerFactory.getLogger(SubscriptionRegistry.class);
|
||||||
private final ActiveSubscriptionCache myActiveSubscriptionCache = new ActiveSubscriptionCache();
|
private final ActiveSubscriptionCache myActiveSubscriptionCache = new ActiveSubscriptionCache();
|
||||||
@Autowired
|
@Autowired
|
||||||
SubscriptionCanonicalizer<IBaseResource> mySubscriptionCanonicalizer;
|
private SubscriptionCanonicalizer<IBaseResource> mySubscriptionCanonicalizer;
|
||||||
@Autowired
|
@Autowired
|
||||||
ISubscriptionDeliveryChannelNamer mySubscriptionDeliveryChannelNamer;
|
private ISubscriptionDeliveryChannelNamer mySubscriptionDeliveryChannelNamer;
|
||||||
@Autowired
|
@Autowired
|
||||||
SubscriptionChannelRegistry mySubscriptionChannelRegistry;
|
private SubscriptionChannelRegistry mySubscriptionChannelRegistry;
|
||||||
@Autowired
|
@Autowired
|
||||||
private IInterceptorBroadcaster myInterceptorBroadcaster;
|
private IInterceptorBroadcaster myInterceptorBroadcaster;
|
||||||
|
|
||||||
|
|
|
@ -26,11 +26,11 @@ public class SubscriptionChannelRegistry {
|
||||||
private final Multimap<String, String> myActiveSubscriptionByChannelName = MultimapBuilder.hashKeys().arrayListValues().build();
|
private final Multimap<String, String> myActiveSubscriptionByChannelName = MultimapBuilder.hashKeys().arrayListValues().build();
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
SubscriptionDeliveryHandlerFactory mySubscriptionDeliveryHandlerFactory;
|
private SubscriptionDeliveryHandlerFactory mySubscriptionDeliveryHandlerFactory;
|
||||||
@Autowired
|
@Autowired
|
||||||
SubscriptionChannelFactory mySubscriptionDeliveryChannelFactory;
|
private SubscriptionChannelFactory mySubscriptionDeliveryChannelFactory;
|
||||||
@Autowired
|
@Autowired
|
||||||
ModelConfig myModelConfig;
|
private ModelConfig myModelConfig;
|
||||||
|
|
||||||
public void add(ActiveSubscription theActiveSubscription) {
|
public void add(ActiveSubscription theActiveSubscription) {
|
||||||
if (!myModelConfig.isSubscriptionMatchingEnabled()) {
|
if (!myModelConfig.isSubscriptionMatchingEnabled()) {
|
||||||
|
|
Loading…
Reference in New Issue