Subversion Repositories Integrator Subversion

Rev

Blame | Last modification | View Log | Download | RSS feed

package br.com.sl.domain.dto.robo;

import java.util.ArrayList;
import java.util.List;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;

import javax.inject.Singleton;

import org.springframework.stereotype.Service;

@Singleton
@Service
public class AlertaPadraoService {

        private static final Queue<String> FILA_ALERTAS = new ConcurrentLinkedQueue<>();
       
    public static void novoAlerta(String mensagem) {
        FILA_ALERTAS.add(mensagem);
    }

    public static List<String> consumirAlertas() {
        List<String> alertas = new ArrayList<>();
        String msg;
        while ((msg = FILA_ALERTAS.poll()) != null) {
            alertas.add(msg);
        }
        return alertas;
    }

}