Skip to content

Instantly share code, notes, and snippets.

<os:retrieve key="userId" />
<os:store key="state">
<os:value>
<![CDATA[#[
output application/json
---
{ "id": attributes.queryParams.id,
"timestamp": now(),
"name": payload.name
}
]]]>
<os:contains id="#[userId]" objectStore="tokensStore" />
@OnException(SalesforceSessionExpiredExceptionSalesforceSocketConnectionExceptionEnricher.class)
@OutputResolver(output = ApexSoapMetadataCategoryResolver.class)
public XMLStreamReader invokeApexSoapMethod(@Connection AbstractConfig connection,
@DisplayName("Apex Class Method Name") @MetadataKeyId(ApexSoapMetadataCategoryResolver.class) String soapMethodName,
@Content @TypeResolver(ApexSoapMetadataCategoryResolver.class) XMLStreamReader input)
throws SalesforceException, SoapCallException {
SalesforceConnector connector = new SalesforceConnector();
connector.setConfig(connection);
connector.initialize();
// TODO: Accessing the Message or Event is no longer permitted in SDK operations.
public XMLStreamReader invokeApexSoapMethod(String soapMethodName, XMLStreamReader input, MuleEvent event) {
...
}
<sftp:config name="sftp">
<sftp:connection host="#[payload.host]" username="#[payload.user]" password="#[payload.password]" />
</sftp:config>
<flow name="sftpMultitenant" >
<http:listener config-ref="HTTP_Listener_config" path="/multitenant"/>
<set-variable variableName="content" value="#[payload]" />
<file:read path="recipients.csv" outputMimeType="application/csv" />
<foreach>
<sftp:config name="sftp">
<sftp:connection username="muletest1" password="muletest1" host="127.0.0.100" port="${SFTP_PORT}" workingDir="${workingDir}">
<sftp:sftp-proxy-config host="localhost" port="${proxyPort}" protocol="HTTP"/>
</sftp:connection>
</sftp:config>
<ftp:config name="ftp">
  <ftp:connection username="anonymous" password="password" host="localhost" port="${ftpPort}" workingDir="${workingDir}"/>
</ftp:config>
<sftp:config name="sftp">
  <sftp:connection username="anonymous" password="password" host="localhost" port="${ftpPort}" workingDir="${workingDir}"/>
</sftp:config>
<flow name="useTheForceBatch">
<http:listener path="/forceWielders" config-ref="forceListener" />
<batch:job name="forceJob">
....
</batch:job>
</flow>
<batch:job name="forceJob">
<batch:input>
<http:listener path="/forceWielders" config-ref="forceListener" />
<ee:transform>
<ee:message>
<ee:set-payload><![CDATA[%dw 2.0
output application/java
---
payload
}]]></ee:set-payload>