Какой процессор сообщений использовать с хранилищем HL7 в прокси WSO2?

Я пытался использовать org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcessorс хранилищем данных hl7 (org.wso2.carbon.business.messaging.hl7.store.jpa.JPAStore) в WSO2 EI(6.1.1) прокси.

Я правильно отправил в магазин сообщение HL7, но при активации процессора для пересылки сообщения я получаю следующую ошибку:

TID: [-1] [] [2017-11-16 13:46:55,504] ERROR {org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter} -  Error in executing task: null {org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter}
java.lang.NullPointerException
    at org.apache.synapse.message.processor.impl.forwarder.ForwardingService.setMessageConsumer(ForwardingService.java:799)
    at org.apache.synapse.message.processor.impl.forwarder.ForwardingService.init(ForwardingService.java:323)
    at org.apache.synapse.message.processor.impl.forwarder.ForwardingService.execute(ForwardingService.java:189)
    at org.wso2.carbon.mediation.ntask.NTaskAdapter.execute(NTaskAdapter.java:98)
    at org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:67)
    at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

Хранилище сообщений:

<messageStore class="org.wso2.carbon.business.messaging.hl7.store.jpa.JPAStore" name="HL7MsgStore" xmlns="http://ws.apache.org/ns/synapse">
    <parameter name="openjpa.ConnectionURL">jdbc:sqlserver://127.0.0.1;databaseName=HL7Store;instanceName=SQLEXPRESS;sendStringParametersAsUnicode=false</parameter>
    <parameter name="openjpa.ConnectionDriverName">com.microsoft.sqlserver.jdbc.SQLServerDriver</parameter>
    <parameter name="openjpa.jdbc.DBDictionary">org.apache.openjpa.jdbc.sql.SQLServerDictionary</parameter>
    <parameter name="openjpa.ConnectionUserName">hl7Store</parameter>
    <parameter name="openjpa.ConnectionPassword">xxxxxxxx</parameter>
</messageStore>

Обработчик сообщений:

<messageProcessor class="org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcessor" 
messageStore="HL7MsgStore" name="ProcessorHl7Store" targetEndpoint="to-ep" xmlns="http://ws.apache.org/ns/synapse"/>
    <parameter name="client.retry.interval">10000</parameter>
    <parameter name="max.delivery.attempts">1</parameter>
    <parameter name="member.count">1</parameter>
    <parameter name="message.processor.reply.sequence">reply-seq</parameter>
    <parameter name="message.processor.fault.sequence">fault-seq</parameter>
    <parameter name="max.delivery.drop">Disabled</parameter>
    <parameter name="interval">10000</parameter>
    <parameter name="is.active">false</parameter>
</messageProcessor>

0 ответов

Другие вопросы по тегам