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 <#> <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/2001/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/2001/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/2001/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 >= 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
