package net.engio.mbassy.messages;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.ReentrantReadWriteLock;

/**
 *
 * @author bennidi
 *         Date: 5/24/13
 */
public abstract class AbstractMessage implements IMessage{

    private Map<Class, Integer> handledByListener = new HashMap<Class, Integer>();
    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();


    @Override
    public void reset() {
        lock.writeLock().lock();
        try {
            handledByListener.clear();
        }finally {
            lock.writeLock().unlock();
        }
    }

    @Override
    public void handled(Class listener) {
        lock.writeLock().lock();
        try {
            Integer count = handledByListener.get(listener);
            if(count == null){
                handledByListener.put(listener, 1);
            }
            else{
                handledByListener.put(listener, count + 1);
            }
        }finally {
            lock.writeLock().unlock();
        }
    }

    @Override
    public int getTimesHandled(Class listener) {
        lock.readLock().lock();
        try {
            return handledByListener.containsKey(listener)
                ? handledByListener.get(listener)
                : 0;
        }finally {
            lock.readLock().unlock();
        }
    }
}