private final String name;
private final EventService eventService;
private final ConcurrentMap<MessageListener, String> registeredIds = new ConcurrentHashMap<MessageListener, String>();
TopicProxySupport(String name, NodeEngine nodeEngine, TopicService service) {
super(nodeEngine, service);
<BUG>service.getAtomicLongContainer(name);
</BUG>
this.name = name;
eventService = nodeEngine.getEventService();
}

private final String name;
private final EventService eventService;
private final ConcurrentMap<MessageListener, String> registeredIds = new ConcurrentHashMap<MessageListener, String>();
TopicProxySupport(String name, NodeEngine nodeEngine, TopicService service) {
super(nodeEngine, service);
service.getTopicStatsContainer(name);
this.name = name;
eventService = nodeEngine.getEventService();
}
