\Event::listen('Illuminate\Database\Events\QueryExecuted', function ($query) {
\Illuminate\Support\Facades\Log::info($query->sql);
\Illuminate\Support\Facades\Log::info($query->bindings);
\Illuminate\Support\Facades\Log::info($query->time);
});
\DB::listen(function($sql, $bindings, $time) {
Log::info($sql);
Log::info($bindings);
Log::info($time);
});
sudo yum install php56# This file allows to restrict SSL behavior in Mule. If the file doesn't exist or a property is not defined, # default values of the current security provider will be used. # Cipher suites that will be enabled in SSL. If this property is set, SSL sockets will # only use cipher suites that are provided in this list and supported by the current security provider. #enabledCipherSuites=TLS_KRB5_WITH_3DES_EDE_CBC_MD5, \ # SSL_DH_anon_WITH_DES_CBC_SHA, \ # TLS_DH_anon_WITH_AES_128_CBC_SHA, \ # TLS_DHE_RSA_WITH_AES_128_CBC_SHA, \ # SSL_DHE_RSA_EXPORT_WITH_DES40_CBC_SHA, \ # SSL_DHE_RSA_WITH_3DES_EDE_CBC_SHA, \ # TLS_DHE_RSA_WITH_AES_256_CBC_SHA, \ # TLS_KRB5_WITH_3DES_EDE_CBC_SHA, \ # TLS_KRB5_WITH_DES_CBC_MD5, \ # TLS_KRB5_EXPORT_WITH_DES_CBC_40_MD5, \ # SSL_DHE_DSS_EXPORT_WITH_DES40_CBC_SHA, \ # SSL_DHE_DSS_WITH_DES_CBC_SHA, \ # TLS_KRB5_WITH_DES_CBC_SHA, \ # SSL_RSA_WITH_NULL_MD5, \ # TLS_DHE_DSS_WITH_AES_256_CBC_SHA, \ # SSL_DH_anon_WITH_3DES_EDE_CBC_SHA, \ # TLS_RSA_WITH_AES_128_CBC_SHA, \ # SSL_DHE_RSA_WITH_DES_CBC_SHA, \ # TLS_DH_anon_WITH_AES_256_CBC_SHA, \ # TLS_KRB5_EXPORT_WITH_DES_CBC_40_SHA, \ # SSL_DH_anon_EXPORT_WITH_DES40_CBC_SHA, \ # SSL_RSA_WITH_NULL_SHA, \ # TLS_RSA_WITH_AES_256_CBC_SHA, \ # SSL_RSA_WITH_DES_CBC_SHA, \ # TLS_EMPTY_RENEGOTIATION_INFO_SCSV, \ # SSL_RSA_EXPORT_WITH_DES40_CBC_SHA, \ # TLS_DHE_DSS_WITH_AES_128_CBC_SHA, \ # SSL_DHE_DSS_WITH_3DES_EDE_CBC_SHA, \ # SSL_RSA_WITH_3DES_EDE_CBC_SHA # Protocols that will be enabled in SSL. If this property is set, SSL sockets will only use protocols # that are provided in this list and supported by the current security provider. #enabledProtocols=TLSv1,TLSv1.1,TLSv1.2 enabledProtocols=TLSv1.2
import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.util.ArrayList; import java.util.Arrays; import java.util.HashSet; import java.util.List; import java.util.Set; public class XMLGeneratorImpl { public static final String GET_METHOD = "get"; public static final String IS_METHOD = "is"; public static final String EMPTY = ""; public static final String START_TAG = "<"; public static final String END_TAG = ">"; public static final String SLASH = "/"; private boolean trimPackageNames; private static final Set<Class> WRAPPER_TYPES = new HashSet(Arrays.asList( Boolean.class, Character.class, Byte.class, Short.class, Integer.class, Long.class, Float.class, Double.class, Void.class, String.class)); private enum ObjectFormat { PRIMITIVE, OBJECT, LIST, MAP, SET, ARRAY; } public String toXML(Object input) { ObjectFormat format = getFormat(input); return convertToXml(input, format); } private String convertToXml(Object input, ObjectFormat format) { StringBuilder xml = new StringBuilder(); String objectName = getObjectName(input); switch (format) { case OBJECT: xml.append(START_TAG).append(objectName).append(END_TAG); xml.append(getXMLFromObject(input)); xml.append(START_TAG).append(SLASH).append(objectName) .append(END_TAG); break; case ARRAY: xml.append(getXMLFromArray(input)); break; case LIST: xml.append(getXMLFromList(input)); break; case PRIMITIVE: xml.append(getXMLFromPrimitive(null, input)); break; default: throw new IllegalArgumentException("Unsupported request object"); } return xml.toString(); } private String getXMLFromPrimitive(String key, Object input) { StringBuilder xml = new StringBuilder(); String xmlTag = key == null ? getObjectName(input) : key; xml.append(START_TAG).append(xmlTag).append(END_TAG) .append(input.toString()).append(START_TAG).append(SLASH) .append(xmlTag).append(END_TAG); return xml.toString(); } private String getXMLFromObject(Object input) { StringBuilder xml = new StringBuilder(); List<Method> methods = getAllowedMethods(input); for (Method method : methods) { xml.append(getXMLValue(input, method)); } return xml.toString(); } private String getXMLFromArray(Object input) { StringBuilder xml = new StringBuilder(); Object[] objects = (Object[]) input; for (Object object : objects) { ObjectFormat of = getFormat(object); xml.append(convertToXml(object, of)); } return xml.toString(); } private String getXMLFromList(Object input) { StringBuilder xml = new StringBuilder(); List objects = (List) input; for (Object object : objects) { ObjectFormat of = getFormat(object); xml.append(convertToXml(object, of)); } return xml.toString(); } private List<Method> getAllowedMethods(Object input) { List<Method> getters = new ArrayList<Method>(); Method[] methods = input.getClass().getDeclaredMethods(); for (Method method : methods) { if (isGetterMethod(method)) { getters.add(method); } } return getters; } private boolean isGetterMethod(Method method) { boolean getter = false; if (method.getName().startsWith(GET_METHOD) || method.getName().startsWith(IS_METHOD)) { getter = true; } return getter; } private String getXMLValue(Object input, Method method) { StringBuilder xml = new StringBuilder(); try { Object value = method.invoke(input, null); String xmlTagName = getObjectName(null, method); if (value != null) { ObjectFormat of = getFormat(value); switch (of) { case PRIMITIVE: xml.append(START_TAG).append(xmlTagName).append(END_TAG) .append(value).append(START_TAG).append(SLASH) .append(xmlTagName).append(END_TAG); break; case OBJECT: xml.append(convertToXml(value, of)); break; case LIST: case MAP: case SET: case ARRAY: xml.append(START_TAG).append(xmlTagName).append(END_TAG) .append(convertToXml(value, of)).append(START_TAG) .append(SLASH).append(xmlTagName).append(END_TAG); break; } } } catch (IllegalArgumentException e) { // TODO: handle exception } catch (IllegalAccessException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InvocationTargetException e) { // TODO Auto-generated catch block e.printStackTrace(); } return xml.toString(); } private ObjectFormat getFormat(Object input) { ObjectFormat format = ObjectFormat.OBJECT; Class clazz = input.getClass(); if (isWrapperType(clazz)) { format = ObjectFormat.PRIMITIVE; } else if (clazz.getName().contains("List")) { format = ObjectFormat.LIST; } return format; } private boolean isWrapperType(Class clazz) { return WRAPPER_TYPES.contains(clazz); } private String getXMLTagName(Method method) { String xmlTagName = null; if (method.getName().startsWith(GET_METHOD)) { xmlTagName = method.getName().substring(3); } else { xmlTagName = method.getName().substring(2); } return xmlTagName; } public boolean isTrimPackageNames() { return trimPackageNames; } public void setTrimPackageNames(boolean trimPackageNames) { this.trimPackageNames = trimPackageNames; } private String getObjectName(Object input) { return getObjectName(input, null); } private String getObjectName(Object input, Method method) { String xmlTagName = EMPTY; if (input != null) { xmlTagName = input.getClass().getName(); if (trimPackageNames && xmlTagName.indexOf(".") != -1) { xmlTagName = xmlTagName .substring(xmlTagName.lastIndexOf(".") + 1); } } else if (method != null) { xmlTagName = getXMLTagName(method); if (trimPackageNames && xmlTagName.indexOf(".") != -1) { xmlTagName = xmlTagName .substring(xmlTagName.lastIndexOf(".") + 1); } } return xmlTagName; } }
com.controller.test; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.servlet.ModelAndView; @Controller("HelloWordController") @RequestMapping("/hello") public class HelloWorldController { @RequestMapping(value = "/world", method = RequestMethod.GET) public ModelAndView helloWord() { return new ModelAndView("HelloWorld"); } }
on_close: The
Hibernate session obtains a connection when it first needs to perform some JDBC access
and maintains that connection until the session is closed.
ConnectionProvider is consulted to see if it supports this
setting (supportsAggressiveRelease()). If not, the release mode is reset
to ConnectionReleaseMode.AFTER_TRANSACTION. This setting is only safe in environments where
we can either re-acquire the same underlying JDBC connection each time you make a call into
ConnectionProvider.getConnection() or in auto-commit environments where
it does not matter if we re-establish the same connection<property name="show_sql">true</property> <property name="format_sql">true</property> <property name="use_sql_comments">true</property>
package com.expressionsplitterrouter; public abstract class Fruit { private String shape; public String getShape() { return shape; } public void setShape(String shape) { this.shape = shape; } }
package com.expressionsplitterrouter; public class Apple extends Fruit { private String type; public String getType() { return type; } public void setType(String type) { this.type = type; } }
package com.expressionsplitterrouter; public class Banana extends Fruit { private String form; public String getForm() { return form; } public void setForm(String form) { this.form = form; } }
package com.expressionsplitterrouter; import java.util.ArrayList; import java.util.List; public class FruitBowl { private List<Fruit> fruit; public List<Fruit> getFruit() { return fruit; } public void setFruit(List<Fruit> fruit) { this.fruit = fruit; } public void addFruit(Fruit fruit){ if (this.fruit == null) { this.fruit = new ArrayList<Fruit>(); } this.fruit.add(fruit); } }
package com.expressionsplitterrouter; public class CreateFruitComponent { public FruitBowl createFruit(String start) { FruitBowl bowl = new FruitBowl(); Apple apple = new Apple(); apple.setShape("Round"); apple.setType("Green"); Banana banana = new Banana(); banana.setShape("Lengthy"); banana.setForm("Yellow"); bowl.addFruit(apple); bowl.addFruit(banana); apple = new Apple(); apple.setShape("Rectangular Square"); apple.setType("Red"); bowl.addFruit(apple); return bowl; } }
package com.expressionsplitterrouter; public class AppleComponent { public void displayApple(Apple apple) { System.out.println("Apple Component"); System.out.println(apple.getShape() + "," + apple.getType()); } }
package com.expressionsplitterrouter; public class BananaComponent { public void displayBanana(Banana banana) { System.out.println("BananaComponent"); System.out.println(banana.getShape() + "," + banana.getForm()); } }
<?xml version="1.0" encoding="UTF-8"?> <mule xmlns="http://www.mulesource.org/schema/mule/core/2.2" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:stdio="http://www.mulesource.org/schema/mule/stdio/2.2" xmlns:vm="http://www.mulesource.org/schema/mule/vm/2.2" xsi:schemaLocation=" http://www.mulesource.org/schema/mule/core/2.2 http://www.mulesource.org/schema/mule/core/2.2/mule.xsd http://www.mulesource.org/schema/mule/stdio/2.2 http://www.mulesource.org/schema/mule/stdio/2.2/mule-stdio.xsd http://www.mulesource.org/schema/mule/vm/2.2 http://www.mulesource.org/schema/mule/vm/2.2/mule-vm.xsd"> <stdio:connector name="stdioIN" promptMessage="Press any key to continue" /> <model name="ExpressionSplitterRouterModel"> <service name="CreateMsgService"> <inbound> <stdio:inbound-endpoint connector-ref="stdioIN" system="IN" /> </inbound> <component class="com.expressionsplitterrouter.CreateFruitComponent" /> <outbound> <expression-splitter-router expression="fruit" evaluator="bean"> <vm:outbound-endpoint path="banana-channel"> <payload-type-filter expectedType="com.expressionsplitterrouter.Banana" /> </vm:outbound-endpoint> <vm:outbound-endpoint path="apple-channel"> <payload-type-filter expectedType="com.expressionsplitterrouter.Apple" /> </vm:outbound-endpoint> </expression-splitter-router> </outbound> </service> <service name="BananaService"> <inbound> <vm:inbound-endpoint path="banana-channel"/> </inbound> <component class="com.expressionsplitterrouter.BananaComponent"/> </service> <service name="AppleService"> <inbound> <vm:inbound-endpoint path="apple-channel"/> </inbound> <component class="com.expressionsplitterrouter.AppleComponent"/> </service> </model> </mule>
package com.expressrecipienttransformers; public class CreateXmlMessageComponent { public String createMessage(String msg) { StringBuilder sb = new StringBuilder(); sb.append("<message>"); sb.append("<recipientList>"); sb.append("<recipient>vm://display-message-channel</recipient>"); sb.append("<recipient>vm://compute-message-channel</recipient>"); sb.append("</recipientList>"); sb.append("<info>"); sb.append("Hi there"); sb.append("</info>"); sb.append("</message>"); return sb.toString(); } }
package com.expressrecipienttransformers; public class DisplayMessageComponent { public void displayMessage(String msg) { System.out.println("Into displaymessage"); System.out.println(msg); } }
package com.expressrecipienttransformers; public class ComputeMsgComponent { public void compute(String msg) { System.out.println("Into compute component"); System.out.println(msg.length()); } }
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns="http://www.mulesource.org/schema/mule/core/2.2"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:stdio="http://www.mulesource.org/schema/mule/stdio/2.2"
xmlns:vm="http://www.mulesource.org/schema/mule/vm/2.2"
xsi:schemaLocation="
http://www.mulesource.org/schema/mule/core/2.2 http://www.mulesource.org/schema/mule/core/2.2/mule.xsd
http://www.mulesource.org/schema/mule/stdio/2.2 http://www.mulesource.org/schema/mule/stdio/2.2/mule-stdio.xsd
http://www.mulesource.org/schema/mule/vm/2.2 http://www.mulesource.org/schema/mule/vm/2.2/mule-vm.xsd">
<stdio:connector name="stdioIN" promptMessage="Press any key to continue" />
<model name="expression-recipient-list-model">
<service name="expression-recipient-list-serviec">
<inbound>
<stdio:inbound-endpoint
connector-ref="stdioIN" system="IN" />
</inbound>
<component
class="com.expressrecipienttransformers.CreateXmlMessageComponent"></component>
<outbound>
<expression-recipient-list-router
expression="/message/recipientList/recipient"
evaluator="xpath" />
</outbound>
</service>
<service name="DisplayService">
<inbound>
<vm:inbound-endpoint path="display-message-channel" />
</inbound>
<component
class="com.expressrecipienttransformers.DisplayMessageComponent" />
</service>
<service name="ComputeService">
<inbound>
<vm:inbound-endpoint path="compute-message-channel" />
</inbound>
<component
class="com.expressrecipienttransformers.ComputeMsgComponent" />
</service>
</model>
</mule
package com.expressiontransformers; public class GameData { private String gameName; private int year; public String getGameName() { return gameName; } public void setGameName(String gameName) { this.gameName = gameName; } public int getYear() { return year; } public void setYear(int year) { this.year = year; } }
package com.expressiontransformers; public class GamingInfo { private int gameId; private GameData gameData; public int getGameId() { return gameId; } public void setGameId(int gameId) { this.gameId = gameId; } public GameData getGameData() { return gameData; } public void setGameData(GameData gameData) { this.gameData = gameData; } }
package com.expressiontransformers; public class CreateGamingInfoComponent { public GamingInfo create(String msg) { GamingInfo info = new GamingInfo(); info.setGameId(1); GameData data = new GameData(); data.setGameName("Cricket"); data.setYear(2010); info.setGameData(data); return info; } }
package com.expressiontransformers; public class GamingComponent { public void addGame(Integer gameId, GameData data) { System.out.println(gameId); System.out.println(data.getGameName()); System.out.println(data.getYear()); } }
<?xml version="1.0" encoding="UTF-8"?> <mule xmlns="http://www.mulesource.org/schema/mule/core/2.2" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:stdio="http://www.mulesource.org/schema/mule/stdio/2.2" xmlns:vm="http://www.mulesource.org/schema/mule/vm/2.2" xsi:schemaLocation=" http://www.mulesource.org/schema/mule/core/2.2 http://www.mulesource.org/schema/mule/core/2.2/mule.xsd http://www.mulesource.org/schema/mule/stdio/2.2 http://www.mulesource.org/schema/mule/stdio/2.2/mule-stdio.xsd http://www.mulesource.org/schema/mule/vm/2.2 http://www.mulesource.org/schema/mule/vm/2.2/mule-vm.xsd"> <stdio:connector name="stdioIN" promptMessage="Press any key to Continue" /> <model name="RestaurantServiceE"> <service name="ExpressionFilterService"> <inbound> <stdio:inbound-endpoint system="IN" connector-ref="stdioIN" /> </inbound> <component class="com.expressiontransformers.CreateGamingInfoComponent" /> <outbound> <pass-through-router> <vm:outbound-endpoint path="displayGamingInfo-channel" /> </pass-through-router> </outbound> </service> <service name="DisplayInfoService"> <inbound> <vm:inbound-endpoint path="displayGamingInfo-channel"> <expression-transformer> <return-argument expression="gameId" evaluator="bean" /> <return-argument expression="gameData" evaluator="bean" /> </expression-transformer> </vm:inbound-endpoint> </inbound> <component class="com.expressiontransformers.GamingComponent" /> </service> </model> </mule>
<?xml version="1.0" encoding="UTF-8"?> <mule xmlns="http://www.mulesource.org/schema/mule/core/2.2" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:http="http://www.mulesource.org/schema/mule/http/2.2" xmlns:https="http://www.mulesource.org/schema/mule/https/2.2" xmlns:saaj="http://www.mulesource.org/schema/mule/saaj/2.2" xmlns:vm="http://www.mulesource.org/schema/mule/vm/2.2" xmlns:mule-xml="http://www.mulesource.org/schema/mule/xml/2.2" xmlns:management="http://www.mulesource.org/schema/mule/management/2.2" xmlns:spring="http://www.springframework.org/schema/beans" xsi:schemaLocation=" http://www.mulesource.org/schema/mule/http/2.2 http://www.mulesource.org/schema/mule/http/2.2/mule-http.xsd http://www.mulesource.org/schema/mule/https/2.2 http://www.mulesource.org/schema/mule/https/2.2/mule-https.xsd http://www.mulesource.org/schema/mule/saaj/2.2 http://www.mulesource.org/schema/mule/saaj/2.2/mule-saaj.xsd http://www.mulesource.org/schema/mule/core/2.2 http://www.mulesource.org/schema/mule/core/2.2/mule.xsd http://www.mulesource.org/schema/mule/vm/2.2 http://www.mulesource.org/schema/mule/vm/2.2/mule-vm.xsd http://www.mulesource.org/schema/mule/xml/2.2 http://www.mulesource.org/schema/mule/xml/2.2/mule-xml.xsd http://www.mulesource.org/schema/mule/management/2.2 http://www.mulesource.org/schema/mule/management/2.2/mule-management.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> <!-- Mule Management Console Configurations START............ Register the Mx4j Console............................... Register the JMX Console................................ Register Log4j Console.................................. --> <management:jmx-default-config port="1098" registerMx4jAdapter="true"> <management:credentials> <spring:entry key="vijay" value="vijay123" /> </management:credentials> </management:jmx-default-config> <management:jmx-log4j /> <!-- Mule Management Console Configurations END. --> </mule>
<?xml version="1.0" encoding="UTF-8"?> <mule xmlns="http://www.mulesource.org/schema/mule/core/2.2" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:http="http://www.mulesource.org/schema/mule/http/2.2" xmlns:https="http://www.mulesource.org/schema/mule/https/2.2" xmlns:saaj="http://www.mulesource.org/schema/mule/saaj/2.2" xmlns:vm="http://www.mulesource.org/schema/mule/vm/2.2" xmlns:mule-xml="http://www.mulesource.org/schema/mule/xml/2.2" xmlns:management="http://www.mulesource.org/schema/mule/management/2.2" xmlns:spring="http://www.springframework.org/schema/beans" xsi:schemaLocation=" http://www.mulesource.org/schema/mule/http/2.2 http://www.mulesource.org/schema/mule/http/2.2/mule-http.xsd http://www.mulesource.org/schema/mule/https/2.2 http://www.mulesource.org/schema/mule/https/2.2/mule-https.xsd http://www.mulesource.org/schema/mule/saaj/2.2 http://www.mulesource.org/schema/mule/saaj/2.2/mule-saaj.xsd http://www.mulesource.org/schema/mule/core/2.2 http://www.mulesource.org/schema/mule/core/2.2/mule.xsd http://www.mulesource.org/schema/mule/vm/2.2 http://www.mulesource.org/schema/mule/vm/2.2/mule-vm.xsd http://www.mulesource.org/schema/mule/xml/2.2 http://www.mulesource.org/schema/mule/xml/2.2/mule-xml.xsd http://www.mulesource.org/schema/mule/management/2.2 http://www.mulesource.org/schema/mule/management/2.2/mule-management.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> <!-- Mule Management Console Configurations START............ Register the Mx4j Console............................... Register the JMX Console................................ Register Log4j Console.................................. --> <management:jmx-default-config port="1098" registerMx4jAdapter="true"> <management:credentials> <spring:entry key="vijay" value="vijay123" /> </management:credentials> </management:jmx-default-config> <management:jmx-log4j /> <!-- Mule Management Console Configurations END. --> <spring:beans> <spring:import resource="transformers.xml" /> </spring:beans> <custom-transformer class="com.restaurantsrevice.transformers.DocumentToSOAPFaultTransformer" name="faultTransformer"> <spring:property name="propagateHeaders" value="false" /> </custom-transformer> <model name="RestaurantServiceModel"> <!-- Default Service Exception Strategy --> <default-service-exception-strategy> <vm:outbound-endpoint path="exception-channel" /> </default-service-exception-strategy> <service name="RestaurantService"> <inbound> <http:inbound-endpoint address="http://localhost:8080/RestaurantService" synchronous="true"> <transformers> <!-- Transform Incoming Soap Message to XML String --> <saaj:soap-message-to-document-transformer /> <mule-xml:dom-to-xml-transformer returnClass="java.lang.String" /> </transformers> </http:inbound-endpoint> </inbound> <outbound> <pass-through-router> <vm:outbound-endpoint path="router-channel" synchronous="true" /> </pass-through-router> </outbound> <async-reply> <vm:inbound-endpoint path="success-response-channel" synchronous="true" /> <vm:inbound-endpoint path="exception-response-channel" synchronous="true" /> <single-async-reply-router /> </async-reply> </service> <service name="RouterService"> <inbound> <vm:inbound-endpoint path="router-channel" synchronous="true" /> </inbound> <log-component /> <outbound> <filtering-router> <vm:outbound-endpoint path="request-processing-channel" synchronous="true"> <transformer ref="addFoodRequestTransformer" /> </vm:outbound-endpoint> <wildcard-filter pattern="*AddFoodRequest*" /> </filtering-router> </outbound> </service> <service name="RequestProcessingService"> <inbound> <vm:inbound-endpoint path="request-processing-channel" synchronous="true" /> </inbound> <component class="org.restaurantservice.RestaurantService"></component> <outbound> <filtering-router> <vm:outbound-endpoint path="success-response-channel"> <transformers> <transformer ref="addFoodResponseTransformer" /> <!-- Transform XML to SOAP response --> <mule-xml:xml-to-dom-transformer returnClass="org.w3c.dom.Document" /> <saaj:document-to-soap-message-transformer propagateHeaders="false" /> </transformers> </vm:outbound-endpoint> <payload-type-filter expectedType="com.services.restaurantservice.AddFoodResponse" /> </filtering-router> </outbound> </service> <service name="ExceptionService"> <inbound> <vm:inbound-endpoint path="exception-channel" synchronous="true" /> </inbound> <component class="com.services.restaurantservice.components.ExceptionHandler" /> <outbound> <filtering-router> <vm:outbound-endpoint path="exception-response-channel" synchronous="true"> <transformers> <transformer ref="FoodAdditionFailedExceptionMap" /> <!-- Transform to Document Object --> <mule-xml:xml-to-dom-transformer returnClass="org.w3c.dom.Document" /> <!-- Transform to SOAP Fault --> <transformer ref="faultTransformer" /> </transformers> </vm:outbound-endpoint> <payload-type-filter expectedType="com.services.restaurantservice.webservice.FoodAdditionFailed" /> </filtering-router> <filtering-router> <vm:outbound-endpoint path="exception-response-channel" synchronous="true"> <transformers> <transformer ref="IncompleteRequestExceptionMap" /> <!-- Transform to Document Object --> <mule-xml:xml-to-dom-transformer returnClass="org.w3c.dom.Document" /> <!-- Transform to SOAP Fault --> <transformer ref="faultTransformer" /> </transformers> </vm:outbound-endpoint> <payload-type-filter expectedType="com.services.restaurantservice.webservice.IncompleteRequest" /> </filtering-router> </outbound> </service> </model> </mule>Java Code to transform to Soap Fault:
package com.restaurantsrevice.transformers; import javax.xml.namespace.QName; import javax.xml.soap.Detail; import javax.xml.soap.MessageFactory; import javax.xml.soap.Name; import javax.xml.soap.SOAPBody; import javax.xml.soap.SOAPException; import javax.xml.soap.SOAPFactory; import javax.xml.soap.SOAPFault; import javax.xml.soap.SOAPHeader; import javax.xml.soap.SOAPHeaderElement; import javax.xml.soap.SOAPMessage; import org.mule.api.MuleMessage; import org.mule.api.transformer.TransformerException; import org.mule.module.saaj.SaajUtils; import org.mule.module.saaj.i18n.SaajMessages; import org.mule.transformer.AbstractMessageAwareTransformer; import org.w3c.dom.Document; public class DocumentToSOAPFaultTransformer extends AbstractMessageAwareTransformer { private boolean propagateHeaders = true; private String headerURI = "http://www.mulesource.org/schema/mule/saaj/2.2"; private String headerPrefix = "mule-saaj"; private SOAPFactory soapFactory; private MessageFactory messageFactory; public DocumentToSOAPFaultTransformer() throws Exception { soapFactory = SOAPFactory.newInstance(); messageFactory = MessageFactory.newInstance(); } public void setPropagateHeaders(boolean propagateHeaders) { this.propagateHeaders = propagateHeaders; } public void setHeaderURI(String headerURI) { this.headerURI = headerURI; } public void setHeaderPrefix(String headerPrefix) { this.headerPrefix = headerPrefix; } public Object transform(MuleMessage muleMessage, String s) throws TransformerException { Document document = (Document) muleMessage.getPayload(); SOAPMessage soapMessage; try { soapMessage = messageFactory.createMessage(); SOAPBody body = soapMessage.getSOAPBody(); addFault(body, document); if (propagateHeaders) { propagateHeaders(muleMessage, soapMessage); } soapMessage.saveChanges(); } catch (SOAPException ex) { throw new TransformerException(SaajMessages .failedToBuildSOAPMessage()); } if (logger.isDebugEnabled()) { logger.debug("Transformation result: " + SaajUtils.getSOAPMessageAsString(soapMessage)); } return SaajUtils.getSOAPMessageAsBytes(soapMessage); } void propagateHeaders(MuleMessage muleMessage, SOAPMessage soapMessage) throws SOAPException { for (Object n : muleMessage.getPropertyNames()) { String propertyName = (String) n; SOAPHeader header = soapMessage.getSOAPHeader(); Name name = soapFactory.createName(propertyName, headerPrefix, headerURI); SOAPHeaderElement headerElement = header.addHeaderElement(name); headerElement.addTextNode(muleMessage.getProperty(propertyName) .toString()); } } private void addFault(SOAPBody soapBody, Document document) throws SOAPException { org.w3c.dom.Element docElement = document.getDocumentElement(); QName qName = new QName(docElement.getLocalName()); SOAPFault soapFault = soapBody.addFault(qName, docElement .getTextContent()); Detail detail = soapFault.addDetail(); detail.addChildElement(soapFactory.createElement(docElement)); } }