MessageBus

package com.qozix.messages;

import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

/**
 * Created by michaeldunn on 8/8/16.
 */
public class MessageBus {


  private Map<Object, List<Actor>> mListeners = new HashMap<>();

  public <T> void subscribe(T message, Actor actor) {
    if (mListeners.containsKey(message)) {
      mListeners.get(message).add(actor);
    } else {
      List<Actor> listeners = new LinkedList<>();
      listeners.add(actor);
      mListeners.put(message, listeners);
    }
  }

  public <T> void unsubscribe(T message, Actor actor) {
    if (mListeners.containsKey(message)) {
      mListeners.get(message).remove(actor);
    }
  }

  public <T> void publish(T message, Object data) {
    if (mListeners.containsKey(message)) {
      for (Actor actor : mListeners.get(message)) {
        actor.translateAndReact(data);
      }
    }
  }


}