Elasticsearch ActiveMQ River Configuration

Question

ActiveMQ 강을 구성하기 시작했습니다. 이미 (ActiveMQ plugin)이 설치되어 있지만 작동 방법에 대해 혼란 스럽습니다. 문서가 너무 짧았습니다. 실제로는 제작 단계를 정확히 따르고 있습니다. 새로운 강 그러나 나는 따르는 뒤에 오는 단계가 무엇인지 모른다?

참고 :

1. 은 내가의 ActiveMQ 서버를 설치하고 실행하고 난 큐에 메시지를 추진하기 위해 간단한 JMS 응용 프로그램을 사용하여 테스트했습니다.

2. 내가 사용하여 새 강 생성 : 이전의 강을 만든 후

   curl -XPUT 'localhost:9200/_river/myindex_river/_meta' -d '{ 
       "type" : "activemq", 
       "activemq" : { 
        "user" : "guest", 
        "pass" : "guest", 
        "brokerUrl" : "failover://tcp://localhost:61616", 
        "sourceType" : "queue", 
        "sourceName" : "elasticsearch", 
        "consumerName" : "activemq_elasticsearch_river_myindex_river", 
        "durable" : false, 
        "filter" : "" 
       }, 
       "index" : { 
        "bulk_size" : 100, 
        "bulk_timeout" : "10ms" 
       } 
   }' 
   

3. 을, 나는 그것이 curl -XGET 'localhost:9200/my_index/_status'를 사용하여 상태입니다 얻을 수 있습니다, 그것은 나에게 인덱스 상태가 아닌 만들어 강을 제공합니다.

elasticsearch를 사용하여 ActiveMQ 강 구성으로 올바른 길을 찾으려면 도움이 필요합니다.

Answer 1

나는 메일 링리스트에서 당신에게 말했다. index.index 값을 정의하거나 인덱스 이름 (쉽게)로 당신의 강 이름을 설정합니다

curl -XPUT 'localhost:9200/_river/my_index/_meta' -d ' 
{ 
    "type":"activemq", 
    "activemq":{ 
    "user":"guest", 
    "pass":"guest", 
    "brokerUrl":"failover://tcp://localhost:61616", 
    "sourceType":"queue", 
    "sourceName":"elasticsearch", 
    "consumerName":"activemq_elasticsearch_river_myindex_river", 
    "durable":false, 
    "filter":"" 
    }, 
    "index":{ 
    "bulk_size":100, 
    "bulk_timeout":"10ms" 
    } 
}' 

또는

curl -XPUT 'localhost:9200/_river/myindex_river/_meta' -d ' 
{ 
    "type":"activemq", 
    "activemq":{ 
    "user":"guest", 
    "pass":"guest", 
    "brokerUrl":"failover://tcp://localhost:61616", 
    "sourceType":"queue", 
    "sourceName":"elasticsearch", 
    "consumerName":"activemq_elasticsearch_river_myindex_river", 
    "durable":false, 
    "filter":"" 
    }, 
    "index":{ 
    "index":"my_index", 
    "bulk_size":100, 
    "bulk_timeout":"10ms" 
    } 
}' 

그것은 도움이 될 것입니다.

그렇지 않은 경우 로그에서 볼 수있는 내용으로 질문을 업데이트하십시오.