package chat.server.moquette;

import java.util.concurrent.atomic.AtomicLong;

public class MessageMetricsCollector {

    private AtomicLong readMsgs = new AtomicLong();
    private AtomicLong wroteMsgs = new AtomicLong();

    public Metrics computeMetrics() {
        Metrics metrics = new Metrics();
        
        metrics.incrementRead(readMsgs.get());
        metrics.incrementWrote(wroteMsgs.get());
        
        return metrics;
    }

    public void sumReadMessages(long count) {
        readMsgs.getAndAdd(count);
    }

    public void sumWroteMessages(long count) {
        wroteMsgs.getAndAdd(count);
    }
    
}