Redis Connector

Click the popup and check for available updates. 

Click the Connector version checkbox and click Next and follow the instructions provided by the user interface. 

Restart Studio when prompted. 

After restarting, when creating a flow and using the Object Store Connector, if you have several versions of the connector installed, you may be asked which version you would like to use. Pick one of these.

Create a new Mule Project by clicking File > New > Mule Project.

In the new project dialog box, the only thing you are required to enter is a name for your new project. Click on Finish.

Navigate through the project’s structure and double-click on src/main/app/project-name.xml to open it. The steps below are all performed on this file:

Go to the palette and search for "Http", then drag and drop a new Http Connector on canvas. This element shall be the entry point for the flow and will provide the key and value to be set for that key.

Go to the palette and search for "Redis", then drag and drop a new Redis connector after "Http" connector. This element is going to send data to the Redis server.

Go to the palette and search for "Set Payload", then drag and drop a new Set Payload element after the "Redis" connector. This element shall create the response for the incoming HTTP request.

Double click on the flow’s top margin to open its properties, and change the name of the flow to "set-flow".

Double click on the HTTP Connector to open its properties.

Double click on Redis and set its properties as below:

Double click on Set Payload and set its properties as below.

If you configured Redis global element with placeholder values ( as explained within Configuring section) you must now provide values for these placeholders. Open /src/main/app/mule-app.properties and provide values for following properties: config.host, config.port and config.connectionTimeout

Deploy the app.

Once the app is running, send an HTTP request to it to trigger it’s flow. To do this, use the CURL command line utility or an HTTP client app (such as Postman) to send a POST request with content-type application/x-www-form-urlencoded and a body in urlencoded format to localhost:8081/value. The request’s body should contain a key and a value. For this you can use the following CURL command: curl -X POST -d "key=test-key" -d "value=test-value" localhost:8081/value.

Congratulations! You have just set a value for a key into the redis server.

Add the redis namespace to the mule element as follows:

  
1

  
xmlns:redis="http://www.mulesoft.org/schema/mule/redis"

Add the location of the redis schema referred to by the "redis" namespace:

  
1

  
http://www.mulesoft.org/schema/mule/redis http://www.mulesoft.org/schema/mule/sfdc-composite/current/mule-redis.xsd

Add the HTTP namespace to the mule element as follows:

  
1

  
xmlns:http="http://www.mulesoft.org/schema/mule/http"

Add the location of the HTTP schema referred to by the HTTP namespace:

  
1

  
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd

Add a redis:config element to your project, then configure its attributes as follows:

  
1

  
<redis:config name="Redis__Configuration" host="${config.host}" connectionTimeout="${config.connectionTimeout}" port="${config.port}" doc:name="Redis: Configuration"/>

Add a http:listener-config element to your project, then configure its attributes as follows:

  
1

  
<http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>

Add an empty flow element to your project as follows:

  
1
2

  
<flow name="set-flow">
</flow>

Within the flow element add an http:listener element as follows:

  
1

  
<http:listener config-ref="HTTP_Listener_Configuration" path="/value" doc:name="Set value HTTP endpoint"/>

Within the flow element add a redis:set after the http:listener as follows:

  
1

  
<redis:set config-ref="Redis__Configuration" key="#[payload.key]" value="#[payload.value]" doc:name="Set value for key into Redis"/>

Within the flow element add a set-payload element after redis:set as follows:

  
1

  
<set-payload value="Value successfully set." doc:name="Set value response"/>

When you’re done, the XML file should look like this:

  
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

  
<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:redis="http://www.mulesoft.org/schema/mule/redis" xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:apachekafka="http://www.mulesoft.org/schema/mule/apachekafka" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
        xmlns:spring="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/apachekafka http://www.mulesoft.org/schema/mule/apachekafka/current/mule-apachekafka.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd
http://www.mulesoft.org/schema/mule/redis http://www.mulesoft.org/schema/mule/redis/current/mule-redis.xsd">
    <redis:config name="Redis__Configuration" host="${config.host}" connectionTimeout="${config.connectionTimeout}" port="${config.port}" doc:name="Redis: Configuration"/>
    <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>
    <flow name="set-flow">
        <http:listener config-ref="HTTP_Listener_Configuration" path="/value" doc:name="Set value HTTP endpoint"/>
        <redis:set config-ref="Redis__Configuration" key="#[payload.key]" value="#[payload.value]" doc:name="Set value for key into Redis"/>
        <set-payload value="Successfully set value: #[payload.value] to key: #[payload.key]" doc:name="Set value response"/>
    </flow>
</mule>