@Test public void testRetrieveSubscriptionsByToken_not_found() throws Exception { assertNull(subscriptionManager.retrieveSubscriptionsByTopic("unknown")); }
public synchronized Set<Subscription> retrieveSubscriptionsByTopic(String topic) { return topicsSubscriptions.get(topic); }
SubscriptionManager { public synchronized Set<Subscription> retrieveSubscriptionsByTopic(String topic) { return topicsSubscriptions.get(topic); } }
SubscriptionManager { public synchronized Set<Subscription> retrieveSubscriptionsByTopic(String topic) { return topicsSubscriptions.get(topic); } private  SubscriptionManager(); }
SubscriptionManager { public synchronized Set<Subscription> retrieveSubscriptionsByTopic(String topic) { return topicsSubscriptions.get(topic); } private  SubscriptionManager(); static SubscriptionManager getInstance(); synchronized Set<Subscription> retrieveSubscriptionsByTopic(String topic); synchronized Map<Long, Subscription> retrieveSubscriptionsByToken(String clientSessionToken); synchronized Subscription addSubscription(Channel channel, String clientSessionToken, Long subscriptionId,
			String topic, Ack ackMode); synchronized boolean removeSubscription(String clientSessionToken, Long subscriptionId); synchronized boolean removeSubscriptions(String clientSessionToken); }
SubscriptionManager { public synchronized Set<Subscription> retrieveSubscriptionsByTopic(String topic) { return topicsSubscriptions.get(topic); } private  SubscriptionManager(); static SubscriptionManager getInstance(); synchronized Set<Subscription> retrieveSubscriptionsByTopic(String topic); synchronized Map<Long, Subscription> retrieveSubscriptionsByToken(String clientSessionToken); synchronized Subscription addSubscription(Channel channel, String clientSessionToken, Long subscriptionId,
			String topic, Ack ackMode); synchronized boolean removeSubscription(String clientSessionToken, Long subscriptionId); synchronized boolean removeSubscriptions(String clientSessionToken);  }