Skip to content

Instantly share code, notes, and snippets.

@ullgren
Last active December 11, 2015 11:18
Show Gist options
  • Save ullgren/4592770 to your computer and use it in GitHub Desktop.
Save ullgren/4592770 to your computer and use it in GitHub Desktop.
import org.mule.api.MuleMessage;
import org.mule.api.transformer.TransformerException;
import org.mule.api.transport.PropertyScope;
import org.mule.transformer.AbstractMessageTransformer;
public class InsertProperty extends AbstractMessageTransformer {
@Override
public Object transformMessage(MuleMessage message, String outputEncoding)
throws TransformerException {
// Set MyId
message.setProperty("MyId", "test", PropertyScope.INVOCATION);
return message;
}
}
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:http="http://www.mulesoft.org/schema/mule/http" 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" version="EE-3.3.2" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
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 ">
<flow name="qxtenddemoFlow1" doc:name="qxtenddemoFlow1">
<http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" doc:name="HTTP"/>
<custom-transformer class="InsertProperty" doc:name="Insert"/>
<logger level="ERROR" doc:name="Logger"/>
<custom-transformer class="ReadMyId" doc:name="Read"/>
</flow>
</mule>
import org.apache.log4j.Logger;
import org.mule.api.MuleMessage;
import org.mule.api.transformer.TransformerException;
import org.mule.api.transport.PropertyScope;
import org.mule.transformer.AbstractMessageTransformer;
public class ReadMyId extends AbstractMessageTransformer {
Logger log = Logger.getLogger(ReadMyId.class);
@Override
public Object transformMessage(MuleMessage message, String outputEncoding)
throws TransformerException {
// Get and log MyId
log.info("MyId is : " + message.getProperty("MyId", PropertyScope.INVOCATION));
return message;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment