djuang1

%dw 2.0
output application/xml
ns soapenv http://schemas.xmlsoap.org/soap/envelope/
ns tem http://tempuri.org/

---
{
    soapenv#Envelope: {
        soapenv#Header:null,
        soapenv#Body : (

djuang1

%dw 2.0
output application/json
---
payload mapObject (value, key) -> {
    // key to compare needs to be set to String type
    (if (key as String =="provisioned") {
        // if key = "provisioned", change the value to true
        "provisioned": true
    } else if (key as String =="key1"){
        // leaving this blank will remove the element

djuang1

package com.dejim;

import java.util.List;

import org.mule.api.MuleEventContext;
import org.mule.api.lifecycle.Callable;

import multichain.command.IssueCommand;
import multichain.command.MultiChainCommand;
import multichain.command.MultichainException;

djuang1

<flow name="query-dbFlow1">
        <http:listener config-ref="HTTP_Listener_Configuration" path="/query" doc:name="HTTP"/>
        <set-variable variableName="query" value="#[message.payloadAs(java.lang.String)]" doc:name="Variable"/>
        <db:select config-ref="MySQL_Configuration" doc:name="Database">
            <db:dynamic-query><![CDATA[#[flowVars.query]]]></db:dynamic-query>
        </db:select>
        <json:object-to-json-transformer doc:name="Object to JSON"/>
</flow>

djuang1

import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;

import java.text.DateFormat;
import java.text.SimpleDateFormat;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.TimeZone;

djuang1

Verifying my Blockstack ID is secured with the address 1EE5XFMKdtmXb34BMAxxrhh4FTKLgVT4vP https://explorer.blockstack.org/address/1EE5XFMKdtmXb34BMAxxrhh4FTKLgVT4vP

djuang1

<http:listener-config name="user-api-httpListenerConfig" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>
<ee:object-store-caching-strategy name="Caching_Strategy" keyGenerationExpression="#[flowVars.userID]" doc:name="Caching Strategy"/>
<db:mysql-config name="MySQL_Configuration" host="${db.host}" port="${db.port}" user="${db.user}" database="${db.db}" doc:name="MySQL Configuration" password="Mule1379"/>

<flow name="get:/user/{id}:user-api-config">
    <timer-interceptor doc:name="Timer"/>
    <logger message="Query parameter user_id = #[message.inboundProperties.'http.query.params'.id]" level="INFO" doc:name="Logger"/>
    <set-variable variableName="userID" value="#[id]" doc:name="Variable"/>
    <ee:cache cachingStrategy-ref="Caching_Strategy" doc:name="Cache">
        <logger message="SubFlow - variable userID = #[flowVars.userID]" level="INFO" doc:name="Logger"/>

djuang1

<sfdc:config name="Salesforce" username="${sfdc.user}" password="${sfdc.password}" securityToken="${sfdc.token}" doc:name="Salesforce"/>
<flow name="salesforce-exampleFlow">
    <sfdc:subscribe-topic config-ref="Salesforce" doc:name="Salesforce (Streaming)" topic="/ContactTopic"/>
    <logger message="Received Event : #[payload.Id] - #[payload.FirstName] #[payload.LastName]" level="INFO" doc:name="Logger"/>
    <sfdc:query-single config-ref="Salesforce" query="dsql:SELECT AccountId,Email,FirstName,HomePhone,Id,LastName FROM Contact WHERE Id = '#[payload.Id]'" doc:name="Salesforce"/>
    <json:object-to-json-transformer doc:name="Object to JSON"/>
    <logger message="#[payload]" level="INFO" doc:name="Logger"/>
</flow>

djuang1

<http:request-config name="HTTP_Request_Configuration" host="feeds.feedburner.com" port="80" basePath="/" doc:name="HTTP Request Configuration"/>

<flow name="flowTest">
  <poll doc:name="Poll">
  <fixed-frequency-scheduler frequency="1" timeUnit="MINUTES"/>
  <http:request config-ref="HTTP_Request_Configuration" path="TechCrunch" method="GET" doc:name="HTTP"/>
  </poll>  	    
  <rss:feed-splitter doc:name="Feed Splitter"/>
  <logger message="#[payload.title]" level="INFO" doc:name="Logger"/>
  <rss:entry-last-updated-filter lastUpdate="now" doc:name="Update Last Updated Date"/>

djuang1

<file:connector name="File_First" autoDelete="true" streaming="true" validateConnections="true" doc:name="File" />
 
<http:request-config name="Dropbox_HTTPS_Request_Configuration" protocol="HTTPS" host="content.dropboxapi.com" port="443" basePath="/" doc:name="HTTP Request Configuration">
    <tls:context>
        <tls:key-store type="jks" path="keystore.jks" keyPassword="<password>" password="<password>"/>
    </tls:context>
</http:request-config>
 
<flow name="upload-first-floor">
    <file:inbound-endpoint path="${file.first}"  responseTimeout="30000" doc:name="Retrieve File" connector-ref="File_First" pollingFrequency="30000" fileAge="20000">