одна synchronizedMap между двумя классами

170
19 декабря 2017, 18:04

Приветствую. Столкнулся со следующей проблемой. Есть два класса: класс веб-сервлета и класс обработки сообщений RabbitMQ. Сервлет принимает запрос, обрабатывает его, присылает сообщение в RabbitMQ, ждет результат (его кладет в Rabbit сторонний сервис) и возвращает его клиенту в ответе на запрос. При обработке запроса я кладу в synchronizedMap ответ на этот запрос и ID запроса в классе сервлета. Классу обработки сообщений Rabbit приходит ID запроса, для которого этот ответ. По сути, требуется только из synchronizedMap достать нужные ответ на запрос и отправить клиенту. Но, почему-то, в классе-обработчике сообщений нет объекта с таким ID, хотя в классе сервлета он есть. Вот код части класса сервлета:

@WebServlet({"/create_conf_link", "/invite_participant", "/get_conf_credentials", "/get_web_conf_credentials"})
public class VcmsServlet extends HttpServlet implements AutoCloseable {
    private static final long serialVersionUID = 1L;
private final VcmsWsMessageHandler mMessageHandler;
private volatile Map<String, HttpServletResponse> mResponses = Collections.synchronizedMap(new HashMap<String, HttpServletResponse>());
private Receiver mRabbitReceiver = null;
public VcmsServlet() 
{    
    super();
mMessageHandler = new VcmsWsMessageHandler(mResponses);
mRabbitReceiver = new Receiver(mMessageHandler, rcv_cfg)
}
protected void handleRequest(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException
{
    String corrID = java.util.UUID.randomUUID().toString();
    mResponses.put(corrID, response);

Тут видно как создается mResponses и чем заполняется. Класс VcmsWsMessageHandler:

public class VcmsWsMessageHandler implements IMessageHandler 
{
    public VcmsWsMessageHandler(Map<String, HttpServletResponse> responses) 
    {
        mResponses = responses;
    }
@Override
public void handle(final String inMethod, final String inMessage, final BasicProperties inProperties)
{
    String corrID = inProperties.getCorrelationId();
    LOG.info("VCMS response for " + corrID + ": " + inMessage);
    synchronized (mResponses)
    {
        HttpServletResponse response = mResponses.get(corrID);
    if(response == null)
        LOG.error("Failed to find response object for corrilcation ID " + corrID);
    try
    {
        response.setStatus(200);
        response.setContentType("application/json");
        response.setCharacterEncoding("UTF-8");
        response.getWriter().write(inMessage);
        mResponses.remove(corrID);
    }
    catch(IOException ex)
    {
        LOG.error("Error sending response");
        response.setStatus(HttpServletResponse.SC_CONFLICT);
    }
}
}
private volatile Map<String, HttpServletResponse> mResponses;
}

Собственно, проблема в том, что после добавления элемента в mResponses в классе VcmsServlet, не получается найти этот объект в классе VcmsWsMessageHandler. HttpServletResponse response = mResponses.get(corrID); возвращает null. Подскажите, пожалуйста, в чем причина и как ее исправить?

READ ALSO
Как обрабатывать устаревшую страницу?

Как обрабатывать устаревшую страницу?

Допустим, пользователь открыл одну и ту же страницу в двух вкладка (страница обрабатывается ViewScoped бином)Пользователь повзаимодействовал...

121
Autocomplete в Primefaces

Autocomplete в Primefaces

Пытаюсь реализовать autocompleteКод в xhtml файле:

173
Проверить на существование поля в ResultSet

Проверить на существование поля в ResultSet

Как проверить есть ли в ResultSet поле с заданным именем? То есть, перед тем, как сделать

196
Как сделать help java?

Как сделать help java?

Пишу для курсовой программку на java с UIВстал вопрос о прикручивании help (инструкции, о программе и т

218