package com.llgc.publisher;

import java.util.Collection;
import java.util.Collections;
import java.util.LinkedList;
import java.util.Queue;

public class Subscriber {
  private Queue<String> topics;
  private Queue<Message> myMessages;

  public Subscriber() {
    topics = new LinkedList<String>();
    myMessages = new LinkedList<Message>();
  }

   public void listen(String newTopic) {
    topics.add(newTopic);
  }

  public void print() {
    while (!myMessages.isEmpty()) {
      Message newMessage = myMessages.poll();
      System.out.println("Topic : " + newMessage.getTopic() + System.lineSeparator() + newMessage.getPayLoad());
    }
  }
	
  public Collection<String> getTopics() {
    return Collections.unmodifiableCollection(topics);
  }
	
  public void addMessage(Message message) {
    myMessages.add(message);
  }
}