import java.util.concurrent.locks.ReentrantLock;
public class TopicService implements ManagedService, RemoteService, EventPublishingService, ClientProtocolService {
public static final String SERVICE_NAME = "hz:impl:topicService";
private final Lock[] orderingLocks = new Lock[1000];
private NodeEngine nodeEngine;
<BUG>private final ConcurrentMap<String, TopicContainer> topicContainers = new ConcurrentHashMap<String, TopicContainer>();

private final ConcurrencyUtil.ConstructorFunction<String, TopicContainer> topicConstructor = new ConcurrencyUtil.ConstructorFunction<String, TopicContainer>() {

public TopicContainer createNew(String mapName) {

return new TopicContainer();
</BUG>
}

import java.util.concurrent.locks.ReentrantLock;
public class TopicService implements ManagedService, RemoteService, EventPublishingService, ClientProtocolService {
public static final String SERVICE_NAME = "hz:impl:topicService";
private final Lock[] orderingLocks = new Lock[1000];
private NodeEngine nodeEngine;
private final ConcurrentMap<String, TopicStatsContainer> topicContainers = new ConcurrentHashMap<String, TopicStatsContainer>();
private final ConcurrencyUtil.ConstructorFunction<String, TopicStatsContainer> topicConstructor = new ConcurrencyUtil.ConstructorFunction<String, TopicStatsContainer>() {
public TopicStatsContainer createNew(String mapName) {
return new TopicStatsContainer();
}
