Как создать ActiveMQ HTTP слушатель, используя Java

Question

Я использовал следующий код, чтобы прочитать сообщение activemq. Мне нужно реализовать activemq слушатель, используя REST.

Это сообщение читать демо-класс

public class ActiveMQConsumer {

    public static void main(String args[]) {
         String url = "http://localhost:8161/api/message?destination=queue://test.queue&readTimeout=10000&type=queue&clientId=test";

         RestClient client = new RestClient(userName, password);
         String activeMQResponse = client.get(url);
         System.out.println(activeMQResponse);
     }
}

Это пружинный класс подключения HTTP.

public class RestClient {

    private String server = "";
    private RestTemplate rest;
    private HttpHeaders headers;
    private HttpStatus status;

    public RestClient(String userName, String password) {
        this.rest = new RestTemplate();
        this.headers = createHeaders(userName, password);
    }

    public HttpHeaders createHeaders(String username, String password) {
        return new HttpHeaders() {
            {
                String auth = username + ":" + password;
                byte[] encodedAuth = Base64.encodeBase64(auth.getBytes(Charset.forName("US-ASCII")));
                String authHeader = "Basic " + new String(encodedAuth);
                set("Authorization", authHeader);
                set("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
                set("Accept", "*/*");
            }
        };
    }

    public String get(String uri) {
        HttpEntity<String> requestEntity = new HttpEntity<String>("", headers);
        ResponseEntity<String> responseEntity = rest.exchange(server + uri, HttpMethod.GET, requestEntity, String.class);
        this.setStatus(responseEntity.getStatusCode());
        return responseEntity.getBody();
    }   

    public HttpStatus getStatus() {
        return status;
    }

    public void setStatus(HttpStatus status) {
        this.status = status;
    }
}

Answer 1

Прежде всего, я бы не использовал RestClient для связи с каким-либо брокером, поскольку это не просто http-связь. Это mqtt или же amqt протокол не http, Хорошо, я вижу, что активный mq предоставляет http api, но все же я предлагаю использовать другой подход.

Используйте компонент apache-camel activemq. Тогда вы просто создадите маршрут как:

from("activemq:queue:your_queue")
  .process(e -> {...}) // your processing of message goes here.

Подробнее о том, как создавать маршруты, можно узнать здесь. Хорошо, что у верблюда отличная поддержка, а также отличная документация.

Если это требование, что вы должны потреблять сообщения от отдыха, то я бы, вероятно, использовал unirest.