Я изучаю инструмент потокового процессора WSO2 и хотел бы выполнить следующие действия:
- Использовать существующую очередь на сервере EMS в качестве источника JMS для сиддхи.
На данный момент все, что у меня есть, это определение @source в редакторе:
- получатель события очереди JMS
@ source (type = 'jms' ,@map ( type = 'json'),
factory.initial = 'com.tibco.tibjms.naming.TibjmsInitialContextFactory', provider.url = 'tcp: // localhost: 7072',
connection.factory.jndi .name = 'QueueConnectionFactory',
connection.factory.type = 'queue',
connection.username = 'JNDI_username',
connection.password = 'JNDI_password', пункт назначения = 'queue_name')
определить поток jmsInputStream (строка имени, количество двойное)
Я немного растерялся из-за шагов, которые я должен сделать для достижения sh успешного соединения между сервером EMS и потоком WSO2 Процессор.
Кто-нибудь когда-нибудь пытался это сделать? Любой совет, который я должен принять во внимание? Должен ли я скопировать jar-файл EMS в определенную папку потокового процессора WSO2?
Заранее спасибо за отзыв :)