Boa noite pessoal,
Vejam o seguinte código:
Controller
@WebServlet("/testConcurrency")
public class TestConcurrency extends HttpServlet {
private static final long serialVersionUID = -6124392524678396101L;
@EJB(name="bs/UsuarioBS/local")
private UsuarioBSLocal usuarioBS;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
String emailStr = request.getParameter("email");
System.out.println("[Inicio] usuarioBS.testConcurrency();");
try {
usuarioBS.testConcurrency(emailStr);
} catch (BusinessException e) {
e.printStackTrace();
}
System.out.println("[Fim] usuarioBS.testConcurrency();");
}
}
BS
@Stateless(name="business/UsuarioBS")
public class UsuarioBS implements UsuarioBSLocal {
private Logger log = Logger.getLogger(UsuarioBS.class);
@EJB(name="dao/EmailDAO/local")
private EmailDAOLocal emailDAO;
@Override
public void testConcurrency(String emailStr) throws BusinessException {
try {
boolean existeEmail = emailDAO.existeEmail(emailStr);
System.out.println("Existe email ["+ emailStr +"]? " + existeEmail);
if (!existeEmail) {
Email email = new Email(emailStr);
email.setPessoa(new Pessoa(1l));
email.setTipoEmail(TipoEmail.PRINCIPAL);
try {
System.out.println("Waiting...");
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
emailDAO.inserir(email);
System.out.println("Email ["+ emailStr +"] inserido!");
}
} catch (DAOException e) {
e.printStackTrace();
}
}
}
Se eu chamar duas vezes a url /[email protected] em menos de 5 segundos ele irá inserir o email duas vezes, o que não pode ocorrer.
Ps: o Thread.sleep() está somente para ilustrar o problema. Em outros lugares de minha aplicação eu também chamo o método emailDAO.existeEmail().
Como eu posso resolver isso?
Muito obrigado.