Please note that I was able to get through this by enabling sequential
mediation in Iterate mediator.

Thanks,

On Mon, May 22, 2017 at 3:45 PM, Gayan Yalpathwala <[email protected]> wrote:

> Hi team,
>
> I am getting an error similar to above, when PublishEvent mediator in the
> target sequence of an Iterate mediator. ESB version is 5.0.0.
> [2017-05-22 15:36:24,135] ERROR - PublishEventMediator Cannot mediate
> message. Failed to load event sink 'TestEventSink'. Error: Event sink
> "TestEventSink" not found.
>
> I can see the following jira too: https://wso2.org/jira/browse/
> ESBJAVA-4899.
> Is there a possible solution or a workaround for this?
>
> Thanks,
>
>
>
> On Thu, Sep 10, 2015 at 5:03 PM, Nadeeshaan Gunasinghe <
> [email protected]> wrote:
>
>> Hi Chanuka,
>> It seems you haven't defined the event sink. Make sure you have defined
>> one with the name eventSink14.
>> Regards
>>
>>
>> *Nadeeshaan Gunasinghe*
>> Software Engineer, WSO2 Inc. http://wso2.com
>> +94770596754 | [email protected] | Skype: nadeeshaan.gunasinghe
>> <#m_-8717959336583478941_m_86378577479624110_>
>> <http://www.facebook.com/nadeeshaan.gunasinghe>
>> <http://lk.linkedin.com/in/nadeeshaan>  <http://twitter.com/Nadeeshaan>
>> <http://nadeeshaan.blogspot.com/>
>> Get a signature like this: Click here!
>> <http://ws-promos.appspot.com/r?rdata=eyJydXJsIjogImh0dHA6Ly93d3cud2lzZXN0YW1wLmNvbS9lbWFpbC1pbnN0YWxsP3dzX25jaWQ9NjcyMjk0MDA4JnV0bV9zb3VyY2U9ZXh0ZW5zaW9uJnV0bV9tZWRpdW09ZW1haWwmdXRtX2NhbXBhaWduPXByb21vXzU3MzI1Njg1NDg3Njk3OTIiLCAiZSI6ICI1NzMyNTY4NTQ4NzY5NzkyIn0=>
>>
>> On Thu, Sep 10, 2015 at 8:55 AM, Chanuka Dissanayake <[email protected]>
>> wrote:
>>
>>> Hi,
>>>
>>> I'm retrieving data set from Salesforce through ESB by using the
>>> Salesforce connector [1]. My intention is here to pass the data set to
>>> DAS as a payload. Therefore I used 'iterate' mediator [2] to iterate
>>> the data and inside that I used publishEvent mediator to pass the data
>>> to DAS as wso2events. But I'm getting this error [3] during the
>>> operation. First I created a Sample static data and pass it successfully to
>>> the DAS without getting the error and using the same 'EventSink' (which
>>> is 'eventSink14'). Proxy source [4]. What can be the possible error here?
>>>
>>> Additionally: Also when I update the PublishEvent stream Pay load
>>> attributes and trying to add a receiver from DAS, It is not identifying
>>> the newly added Pay Load attribute(s) (which may be a bug). Because of that
>>> it'll categorize as a inactive receiver [5]. Need to change the Stream name
>>> or the version of the Stream as a workaround.
>>>
>>> [1] https://docs.wso2.com/display/ESBCONNECTORS/Salesforce+Connector
>>> [2] https://docs.wso2.com/display/ESB480/Iterate+Mediator
>>> [3]
>>>
>>> 2015-09-09 17:09:53,741] ERROR - PublishEventMediator Cannot mediate
>>> message. Failed to load event sink 'eventSink14'. Error: Event sink
>>> "eventSink14" not found
>>>
>>> [2015-09-09 17:09:53,741]  INFO - LogMediator To:
>>> http://www.w3.org/2005/08/addressing/anonymous, WSAction: , SOAPAction:
>>> , MessageID: urn:uuid:0877c7fb-3e22-41d3-83ab-629edc9b59e9, Direction:
>>> request, message = aaaaaaaaaaaaaaaaaa, Envelope: <?xml version='1.0'
>>> encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.
>>> xmlsoap.org/soap/envelope/"><soapenv:Body><queryResponse xmlns
>>> ="urn:partner.soap.sforce.com"><result xmlns:xsi="http://www.w3.org/2
>>> 001/XMLSchema-instance" xsi:type="QueryResult"><done>true</done><
>>> queryLocator xsi:nil="true"/><size>9</size></result></queryResponse></
>>> soapenv:Body></soapenv:Envelope>
>>>
>>> [2015-09-09 17:09:53,742] ERROR - PublishEventMediator Cannot mediate
>>> message. Failed to load event sink 'eventSink14'. Error: Event sink
>>> "eventSink14" not found
>>>
>>> [2015-09-09 17:09:53,743] ERROR - PublishEventMediator Cannot mediate
>>> message. Failed to load event sink 'eventSink14'. Error: Event sink
>>> "eventSink14" not found
>>>
>>> [2015-09-09 17:09:53,743]  INFO - LogMediator To:
>>> http://www.w3.org/2005/08/addressing/anonymous, WSAction: , SOAPAction:
>>> , MessageID: urn:uuid:e16bc0a2-586c-4aa7-9d34-f03773b09efb, Direction:
>>> request, message = aaaaaaaaaaaaaaaaaa, Envelope: <?xml version='1.0'
>>> encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.
>>> xmlsoap.org/soap/envelope/"><soapenv:Body><queryResponse xmlns
>>> ="urn:partner.soap.sforce.com"><result xmlns:xsi="http://www.w3.org/2
>>> 001/XMLSchema-instance" xsi:type="QueryResult"><done>true</done><
>>> queryLocator xsi:nil="true"/><size>9</size></result></queryResponse></
>>> soapenv:Body></soapenv:Envelope>
>>>
>>> [2015-09-09 17:09:53,744] ERROR - PublishEventMediator Cannot mediate
>>> message. Failed to load event sink 'eventSink14'. Error: Event sink
>>> "eventSink14" not found
>>>
>>> [2015-09-09 17:09:53,744] ERROR - PublishEventMediator Cannot mediate
>>> message. Failed to load event sink 'eventSink14'. Error: Event sink
>>> "eventSink14" not found
>>>
>>> [2015-09-09 17:09:53,746]  INFO - LogMediator To:
>>> http://www.w3.org/2005/08/addressing/anonymous, WSAction: , SOAPAction:
>>> , MessageID: urn:uuid:08a723ab-9232-43db-ab66-be3feeac6fc1, Direction:
>>> request, message = aaaaaaaaaaaaaaaaaa, Envelope: <?xml version='1.0'
>>> encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.
>>> xmlsoap.org/soap/envelope/"><soapenv:Body><queryResponse xmlns
>>> ="urn:partner.soap.sforce.com"><result xmlns:xsi="http://www.w3.org/2
>>> 001/XMLSchema-instance" xsi:type="QueryResult"><done>true</done><
>>> queryLocator xsi:nil="true"/><size>9</size></result></queryResponse></
>>> soapenv:Body></soapenv:Envelope>
>>>
>>> [4]
>>>
>>> <?xml version="1.0" encoding="UTF-8"?>
>>> <proxy xmlns="http://ws.apache.org/ns/synapse";
>>>        name="esbtoBamProxyEvent"
>>>        transports="https,http"
>>>        statistics="disable"
>>>        trace="disable"
>>>        startOnLoad="true">
>>>    <target>
>>>       <inSequence>
>>>          <salesforce.getUserInfo configKey="sf_auth"/>
>>>          <salesforce.describeGlobal/>
>>>          <salesforce.query>
>>>             <batchSize>2000</batchSize>
>>>             <queryString>SELECT Region__c, count(Id) FROM Account WHERE
>>> Deactivation_Date__c &gt;= TODAY Group by Region__c</queryString>
>>>          </salesforce.query>
>>>          <iterate xmlns:ns1="urn:partner.soap.sforce.com"
>>>                   xmlns:ns="http://org.apache.synapse/xsd";
>>>                   id="dateIterater"
>>>                   preservePayload="true"
>>>                   expression="$body/ns1:queryResponse
>>> /ns1:result/ns1:records">
>>>             <target>
>>>                <sequence>
>>>                   <log level="full">
>>>                      <property name="message" value="aaaaaaaaaaaaaaaaaa
>>> "/>
>>>                   </log>
>>>                   <publishEvent>
>>>                      <eventSink>eventSink14</eventSink>
>>>                      <streamName>publishEventStream123</streamName>
>>>                      <streamVersion>1.0.1</streamVersion>
>>>                      <attributes>
>>>                         <meta/>
>>>                         <correlation/>
>>>                         <payload>
>>>                            <attribute name="Name" type="STRING"
>>> defaultValue="" value="testValue"/>
>>>                            <attribute xmlns:nsa="urn:sobject.partner
>>> .soap.sforce.com"
>>>                                       xmlns:nsb="urn:partner.soap.sforce
>>> .com"
>>>                                       name="Region"
>>>                                       type="STRING"
>>>                                       defaultValue=""
>>>                                       expression="$body/nsb:records/nsa
>>> :Region__c/text()"/>
>>>                         </payload>
>>>                         <arbitrary/>
>>>                      </attributes>
>>>                   </publishEvent>
>>>                </sequence>
>>>             </target>
>>>          </iterate>
>>>          <log level="full"/>
>>>          <sequence key="sf_response_seq"/>
>>>          <respond/>
>>>       </inSequence>
>>>    </target>
>>>    <description/>
>>> </proxy>
>>>
>>>
>>>
>>> [5]
>>>
>>>
>>> Thanks & Regards,
>>> Chanuka.
>>> ​
>>> --
>>> Chanuka Dissanayake
>>> *Software Engineer | **WSO2 Inc.*; http://wso2.com
>>>
>>> Mobile: +94 71 33 63 596
>>> Email: [email protected]
>>>
>>> _______________________________________________
>>> Dev mailing list
>>> [email protected]
>>> http://wso2.org/cgi-bin/mailman/listinfo/dev
>>>
>>>
>>
>> _______________________________________________
>> Dev mailing list
>> [email protected]
>> http://wso2.org/cgi-bin/mailman/listinfo/dev
>>
>>
>
>
> --
> *Gayan Kaushalya Yalpathwala*
> Senior Software Engineer
> WSO2 Inc.; http://wso2.com
> lean.enterprise.middleware
>
> LK: +94 71 868 2704 <071%20868%202704>
> US: +1 650 695 2324 <+1%20650-695-2324>
>
> <http://asia14.wso2con.com/>
>



-- 
*Gayan Kaushalya Yalpathwala*
Senior Software Engineer
WSO2 Inc.; http://wso2.com
lean.enterprise.middleware

LK: +94 71 868 2704
US: +1 650 695 2324

<http://asia14.wso2con.com/>
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev

Reply via email to