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
;
}
}