Как мне связать apache MQ с сервером wso2 BAM? (нет ESB, что делает его простым)

Я пытаюсь получить простую веб-статистику с помощью BAM-сервера wso2, я его установил, понимаю, как определяются события, хранятся в базе данных casssandra и т. д., но мне не хватает самого главного: как передать сами события в сервер БАМ?

У меня есть запрограммированные системы, в которых файлы json хранятся в файле («очередь»), и мой процесс Java считывает и обрабатывает их каждые 30 секунд, я думал, что это будет похоже, но правда в том, что я довольно потерян.

Порт 7611 — TCP, прослушивание.
Должен ли я отправлять серверу BAM события через него?

Любая помощь будет принята с благодарностью!


queue wso2 wso2bam
person Cristina    schedule 15.04.2013    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Насколько я знаю, WSO2 BAM не поддерживается напрямую для apache mq. вам нужно использовать ESB или CEP для отправки событий в BAM через экономию (затем вы можете использовать apache mq для отправки событий в ESB/CEP, и через любой из этих продуктов вы можете отправлять события в BAM).

Но вы можете использовать API REST для отправки событий в BAM, что является более простым подходом. Пожалуйста, обратитесь к документу [1]. Я думаю, что будущие версии BAM будут поддерживать jms (к сведению, см. [2]).

[1] http://docs.wso2.org/wiki/display/BAM220/REST+API

[2] WSO2 BAM с JMS

Спасибо,

Мохан

person Mohanadarshan    schedule 16.04.2013
comment
Большое спасибо! Наконец-то мне удалось отправить и определение srtream, и события, просто используя curl, как описано в документах . wso2.org/wiki/display/BAM220/REST+API . Теперь мне нужно создать некоторую java, чтобы выбрать данные из очереди вывода apache MQ и таким образом передать их на сервер BAM :)) - person Cristina; 16.04.2013

arrow_upward
0
arrow_downward

BAM может получать события либо через REST API, либо через Thrift API. 7611 — это незащищенный порт Thrift, а 7711 — защищенный порт Thrift по умолчанию. Поскольку в настоящее время у BAM нет готового агента данных для Apache MQ, вам придется написать его самостоятельно. Если вы хотите публиковать события непосредственно в BAM с помощью Java, вы можете использовать компонент DataBridge в кодовой базе WSO2. (т.е. используйте https://svn.wso2.org/repos/wso2/carbon/platform/branches/4.1.0/components/data-bridge/org.wso2.carbon.databridge.agent.thrift/4.1.1)

person Maninda    schedule 16.04.2013
comment
Спасибо, Манинда, у меня были некоторые проблемы с использованием библиотек databridge.agent, порт 7611 прослушивался, но отклонял любое TCP-соединение, я пытался использовать пример класса VariableKeyValueAgent из carbon svn, но не смог найти org.wso2. carbon.databridge.agent.thrift.AsyncDataPublisher для импорта... к счастью, есть простой способ отправки событий и определений потока агенту данных сервера BAM с помощью curl, который работает, и я могу начать с него :) - person Cristina; 16.04.2013