Приветствую. Столкнулся со следующей проблемой. Есть два класса: класс веб-сервлета и класс обработки сообщений 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.
Подскажите, пожалуйста, в чем причина и как ее исправить?
Айфон мало держит заряд, разбираемся с проблемой вместе с AppLab
Перевод документов на английский язык: Важность и ключевые аспекты
Допустим, пользователь открыл одну и ту же страницу в двух вкладка (страница обрабатывается ViewScoped бином)Пользователь повзаимодействовал...
Как проверить есть ли в ResultSet поле с заданным именем? То есть, перед тем, как сделать
Пишу для курсовой программку на java с UIВстал вопрос о прикручивании help (инструкции, о программе и т