2014-07-01 120 views
1

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&amp;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 ...

感謝

回答