TopicEvent topicEvent = (TopicEvent) event;
Message message = new Message(topicEvent.name, nodeEngine.toObject(topicEvent.data));
incrementReceivedMessages(topicEvent.name);
((MessageListener) listener).onMessage(message);
}
<BUG>public TopicContainer getAtomicLongContainer(String name) {
</BUG>
return ConcurrencyUtil.getOrPutSynchronized(topicContainers, name, topicContainers, topicConstructor);
}
public void incrementPublishes(String topicName) {

TopicEvent topicEvent = (TopicEvent) event;
Message message = new Message(topicEvent.name, nodeEngine.toObject(topicEvent.data));
incrementReceivedMessages(topicEvent.name);
((MessageListener) listener).onMessage(message);
}
public TopicStatsContainer getTopicStatsContainer(String name) {
return ConcurrencyUtil.getOrPutSynchronized(topicContainers, name, topicContainers, topicConstructor);
}
public void incrementPublishes(String topicName) {
