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
