WSO2: потоковый процессор - PullRequest
Новая
       12

WSO2: потоковый процессор

0 голосов
/ 30 октября 2018

Как я могу настроить @sink для вызова веб-API на основе мыла? где я могу указать действие мыла? ссылка, которую я нашел в Интернете, не работает должным образом? 

    @sink(type='http',publisher.url='http://localhost:8009/foo', method='{POST}',headers="'content-type:xml','content-length:94'", client.bootstrap.configuration="'client.bootstrap.socket.timeout:20', 'client.bootstrap.worker.group.size:10'", client.pool.configuration="'client.connection.pool.count:10','client.max.active.connections.per.pool:1'", @map(type='xml', @payload('{<events>
    <event>
        <symbol>WSO2</symbol>
        <price>55.6</price>
        <volume>100</volume>
    </event>
</events>,
POST,
Content-Length:24#Content-Location:USA#Retry-After:120}')))

1 Ответ

0 голосов
/ 03 ноября 2018

Ниже приведен пример конфигурации, как вы можете вызвать конечную точку SOAP. Здесь мы используем HTTP-приемник с XML source mapper . Надеюсь, что это соответствует вашим требованиям. 

@App:name("SiddhiAppSOAPTest")
@App:description("Description of the plan")

-- Please refer to https://docs.wso2.com/display/SP400/Quick+Start+Guide on getting started with SP editor. 

define stream inputStream(attr1 int);

@sink(type='http', publisher.url='http://localhost:8280/services/echo', method='POST',headers="'Content-Type:text/xml','SOAPAction:urn:echoInt'",
@map(type='xml', enclosing.element="<soapenv:Envelope xmlns:echo='http://echo.services.core.carbon.wso2.org' xmlns:soapenv='http://schemas.xmlsoap.org/soap/envelope/'>",
    @payload( "<soapenv:Header/><soapenv:Body><echo:echoInt><in>{{attr1}}</in></echo:echoInt></soapenv:Body>")
)
)
define stream outputStream (attr1 int);

from inputStream
select *
insert into outputStream;

Как вы можете заметить, я определил SOAPAction как заголовок HTTP, а также как Content-Type.

...