all。logstash with activeMQ/stomp
我正在使用logstash-1.4.2來使用存儲在我的activeMQ中(使用stomp plubgin)的消息。
我acitveMQ.xml配置文件,我也行:
<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
,當我跑我的logstash,我有這樣的錯誤:
在我logstashconfig.conf,我有:
input {
stomp {
password => "admin"
user => "admin"
}
}
output {
file {
path => "C:\logstash\logstash-1.4.2\cosumedfromstomp.txt"
}
}
如果我從rabbitMQ中消耗,使用下面的logstashconfig.conf,這是正確的(這裏是我的rabbitMQ vers離子的配置):
input {
rabbitmq {
host => "amqp"
queue => "elasticsearch"
key => "elasticsearch"
exchange => "elasticsearch"
type => "all"
durable => true
auto_delete => false
exclusive => false
format => "json_event"
debug => false
}
}
output {
file {
path => "C:\logstash\logstash-1.4.2\cosumedfromstomp.txt"
}
}
我沒有麻煩我的rabbitMQ版本的logstash,創建的文本文件看起來是正確的。
我的問題是:
1,我配置我的腳踏輸入錯誤嗎?因爲我的配置中沒有「隊列」名稱,可能是錯誤的? 2,或者如果問題是我沒有創建跺腳正確插件,如果是這樣的原因,它不會是約logstash ...
感謝