<property expression="wso2:vault-lookup('Username')" name="UserName" scope="default" type="STRING" xmlns:ns="http://org.apache.synapse/xsd"/>
C:\Work\WSO2\wso2esb-4.9.0\repository\conf\security>ciphertool.bat -Dconfigure 'ciphertool.bat' is not recognized as an internal or external command, operable program or batch file. C:\Work\WSO2\wso2esb-4.9.0\repository\conf\security>cd ciphertool.bat The system cannot find the path specified. C:\Work\WSO2\wso2esb-4.9.0\repository\conf\security>cd C:\Work\WSO2\wso2esb-4.9.0\bin C:\Work\WSO2\wso2esb-4.9.0\bin>ciphertool.bat -Dconfigure 'ant' is not recognized as an internal or external command, operable program or batch file. Using CARBON_HOME: C:\Work\WSO2\wso2esb-4.9.0 Using JAVA_HOME: C:\Program Files\Java\jdk1.8.0_151 [Please Enter Primary KeyStore Password of Carbon Server : ] Primary KeyStore of Carbon Server is initialized Successfully Protected Token [UserManager.AdminUser.Password] is updated in repository/conf/user-mgt.xml successfully Protected Token [Carbon.Security.KeyStore.KeyPassword] is updated in repository/conf/carbon.xml successfully Protected Token [Server.Service.Connector.keystorePass] is updated in repository/conf/tomcat/catalina-server.xml successfully Protected Token [Carbon.Security.TrustStore.Password] is updated in repository/conf/carbon.xml successfully Protected Token [Carbon.Security.KeyStore.Password] is updated in repository/conf/carbon.xml successfully Protected Token [Datasources.WSO2_CARBON_DB.Configuration.Password] is updated in repository/conf/datasources/master-datasources.xml successfully Encryption is done Successfully Encryption is done Successfully Encryption is done Successfully Encryption is done Successfully Encryption is done Successfully Encryption is done Successfully Secret Configurations are written to the property file successfully C:\Work\WSO2\wso2esb-4.9.0>
<data name="DynamicDS" transports="http https local"> <config enableOData="false" id="DynamicQueryEmp"> <property name="driverClassName">com.mysql.jdbc.Driver</property> <property name="url">jdbc:mysql://localhost:3306/emp</property> <property name="username">root</property> <property name="password">root</property> </config> <query id="DynaminQuery" useConfig="DynamicQueryEmp"> <sql>select id, name, address from emp :filterQuery</sql> <result defaultNamespace="http://shriwithjava.blogspot.co.nz/" element="employees" rowName="employee"> <element column="id" name="id" xsdType="xs:string"/> <element column="name" name="name" xsdType="xs:string"/> <element column="address" name="address" xsdType="xs:string"/> </result> <param name="filterQuery" sqlType="QUERY_STRING"/> </query> <operation name="getEmployees"> <call-query href="DynaminQuery"> <with-param name="filterQuery" query-param="filterQuery"/> </call-query> </operation> </data>
package poc.ntlm; import java.io.IOException; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; import org.apache.commons.httpclient.NTCredentials; import org.apache.commons.httpclient.auth.AuthScope; import org.apache.commons.httpclient.methods.GetMethod; public class NLTMSecurity { public static void main(String[] args) throws HttpException, IOException { System.out.println("started"); String result = invokeService(); System.out.println("output : " + result); } public static String invokeService() throws HttpException, IOException { String responseString = null; try { HttpClient client = new HttpClient(); String URL = "http://XXX.XXX.XXX/XX/XXX/2011/OrganizationData.svc/ListSet?$select=ListId,ListName,StateCode"; GetMethod getMethod = new GetMethod(URL); NTCredentials credentials = new NTCredentials("USER_NAME", "PASSWORD", "HOST_NAME", "DOMAIN"); client.getState().setCredentials(new AuthScope(null, -1, null), credentials); int status = client.executeMethod(getMethod); System.out.println("Status : " + status); responseString = getMethod.getResponseBodyAsString(); System.out.println("responseString : " + responseString); } catch (Exception e) { System.out.println(e); } return responseString; } }
import org.apache.synapse.MessageContext; import org.apache.synapse.mediators.AbstractMediator; public class NTLMSecurityMediator extends AbstractMediator { public boolean mediate(MessageContext context) { context.setProperty("Response", responseString ); context.setProperty("HTTP_STATUS", status ); return true; } }
<EmployeeDetails xmlns="http://shriwithjava.blogspot.co.nz/"> <EmployeeData> <EmployeeId>201</EmployeeId> <EmployeeName>Shri</EmployeeName> <EmployeeAddress>Auckland</EmployeeAddress> <Department>IT</Department> </EmployeeData> <EmployeeData> <EmployeeId>202</EmployeeId> <EmployeeName>Bhajan</EmployeeName> <EmployeeAddress>Wellington</EmployeeAddress> <Department>IT</Department> </EmployeeData> </EmployeeDetails>
package org.wso2.custom; import java.io.BufferedReader; import java.io.FileReader; import java.io.IOException; import org.apache.synapse.MessageContext; import org.apache.synapse.mediators.AbstractMediator; public class CustomMediator extends AbstractMediator { private static String Response = "StaticResponse"; private static String ResponseXml = ""; private static String FileName = ""; private static String FilePath = "F:\\Shri Kant\\WSO2\\wso2esb-4.0.3\\repository\\conf\\stub\\StubXml\\"; public boolean mediate(MessageContext context) { // TODO Implement your mediation logic here //FileName=context.getProperty("").toString(); FileName=(String)context.getProperty("FileName"); BufferedReader br = null; try { String sCurrentLine; br = new BufferedReader(new FileReader(FilePath+FileName+".xml")); while ((sCurrentLine = br.readLine()) != null) { ResponseXml+= sCurrentLine; } context.setProperty(Response, ResponseXml); System.out.println(context.getSoapAction()+" : This is the SOAP Action"); System.out.println(context.getConfiguration()+" : This is the getConfiguration"); System.out.println(context.getMessageID()+" : This is the getMessageID"); System.out.println(context.getTracingState()+" : This is the getTracingState"); System.out.println(context.getWSAAction()+" : This is the getWSAAction"); System.out.println(context.getWSAMessageID()+" : This is the getWSAMessageID"); System.out.println(context.getClass()+" : This is the getClass"); System.out.println(context.getContextEntries()+" : This is the getContextEntries"); System.out.println(context.getEnvelope()+" : This is the getEnvelope"); System.out.println(context.getEnvironment()+" : This is the getEnvironment"); System.out.println(context.getFaultSequence()+" : This is the getFaultSequence"); System.out.println(context.getFaultStack()+" : This is the getFaultStack"); System.out.println(context.getPropertyKeySet()+" : This is the getPropertyKeySet"); System.out.println(context.getServiceLog()+" : This is the getServiceLog"); System.out.println(context.isDoingGET()+" : This is the isDoingGET"); System.out.println(context.isDoingMTOM()+" : This is the isDoingMTOM"); System.out.println(context.isDoingPOX()+" : This is the isDoingPOX"); System.out.println(context.isDoingSWA()+" : This is the isDoingSWA"); System.out.println(context.isFaultResponse()+" : This is the isFaultResponse"); System.out.println(context.isSOAP11()+" : This is the isSOAP11"); System.out.println(context.isResponse()+" : This is the isResponse"); } catch (IOException e) { e.printStackTrace(); } finally { Response=""; try { if (br != null){ br.close(); } } catch (IOException ex) { ex.printStackTrace(); } } return true; } }
<localEntry key="StaticServiceScript" src="file:repository/conf/stub/StaticTransformResponse.js"/> <proxy name="MyCustomProxy" transports="http" startOnLoad="true" statistics="enable" trace="disable"> <target inSequence="MyCustom_IN" outSequence="MyCustom_OUT" faultSequence="CommonFaultHandler"/> <publishWSDL key="MyCustom_wsdl"/> </proxy> <localEntry key="MyCustom_wsdl" src="file:repository/conf/employee/OverseaseEmployee.wsdl"/> <sequence name="MyCustom_IN"> <property name="FileName" value="StaticEmployeeDetails" action="set"/> <class name="org.wso2.custom.CustomMediator"/> <property name="StaticResponse" action="set" expression="get-property('StaticResponse')"/> <script language="js" key="StaticServiceScript" function="sendStaticResponse"/> <property name="RESPONSE" value="true"/> <header name="To" action="remove"/> <send/> <drop/> </sequence>
<x><![CDATA[ function sendStaticResponse(mc) { var StaticResponse = new XML(mc.getProperty("StaticResponse")); mc.setPayloadXML(StaticResponse); } ]]></x>
<data name="EmployeeDetailsNZ" enableBatchRequests="false" enableBoxcarring="false" serviceStatus="active"> <description>This provides Employee details</description> <config id="EMPDS"> <property name="org.wso2.ws.dataservice.driver">oracle.jdbc.driver.OracleDriver</property> <property name="org.wso2.ws.dataservice.protocol">jdbc:oracle:thin:SYSTEM/SYSTEM@localhost:1521/xe</property> <property name="org.wso2.ws.dataservice.user">SYSTEM</property> <property name="org.wso2.ws.dataservice.password">SYSTEM</property> <property name="org.wso2.ws.dataservice.minpoolsize"></property> <property name="org.wso2.ws.dataservice.maxpoolsize"></property> <property name="org.wso2.ws.dataservice.validation_query"></property> </config> <query id="EmpDetailsQuery" useConfig="EMPDS"> <sql>select * from EMP_DETAILS_NZ where DEPARTMENT_V=?</sql> <result element="EmployeeDetails" rowName="EmployeeData" defaultNamespace="http://shriwithjava.blogspot.co.nz/"> <element name="EmployeeId" column="EMP_ID_N" xsdType="xs:string" /> <element name="EmployeeName" column="EMP_NAME_V" xsdType="xs:string" /> <element name="EmployeeAddress" column="EMP_ADD_V" xsdType="xs:string" /> <element name="Department" column="DEPARTMENT_V" xsdType="xs:string" /> </result> <param name="Department" paramType="SCALAR" sqlType="STRING" type="IN" /> </query> <operation name="getEmployeeDetails"> <description></description> <call-query href="EmpDetailsQuery"> <with-param name="Department" query-param="Department" /> </call-query> </operation> </data>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:shr="http://shriwithjava.blogspot.co.nz/"> <soapenv:Header/> <soapenv:Body> <shr:getEmployeeDetails> <shr:Department>IT</shr:Department> </shr:getEmployeeDetails> </soapenv:Body> </soapenv:Envelope>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"> <soapenv:Body> <EmployeeDetails xmlns="http://shriwithjava.blogspot.co.nz/"> <EmployeeData> <EmployeeId>201</EmployeeId> <EmployeeName>Shri</EmployeeName> <EmployeeAddress>Auckland</EmployeeAddress> <Department>IT</Department> </EmployeeData> <EmployeeData> <EmployeeId>202</EmployeeId> <EmployeeName>Bhajan</EmployeeName> <EmployeeAddress>Wellington</EmployeeAddress> <Department>IT</Department> </EmployeeData> </EmployeeDetails> </soapenv:Body> </soapenv:Envelope>
<definitions> <proxy name="OverseasEmpDetailsProxy" transports="http" startOnLoad="true" trace="disable" statistics="enable"> <target inSequence="OverseasEmpDetails_IN" outSequence="OverseasEmpDetails_OUT" faultSequence="CommonFaultHandler"/> <publishWSDL key="OverseasEmpDetails_wsdl"/> </proxy> <localEntry key="OverseasEmpDetails_wsdl" src="file:repository/conf/employee/OverseaseEmployee.wsdl"/> <sequence name="OverseasEmpDetails_IN"> <clone> <target> <endpoint key="NZEmployeeDetails_EPR"/> </target> <target> <endpoint key="INDEmployeeDetails_EPR"/> </target> <target> <endpoint key="USAEmployeeDetails_EPR"/> </target> </clone> </sequence> <sequence name="OverseasEmpDetails_OUT"> <aggregate> <completeCondition> <messageCount min="-1" max="-1"/> </completeCondition> <onComplete xmlns:shr="http://shriwithjava.blogspot.co.nz/" expression="//shr:EmployeeDetails/shr:EmployeeData"> <send/> </onComplete> </aggregate> </sequence> <endpoint name="NZEmployeeDetails_EPR"> <address uri="http://localhost:9763/services/EmployeeDetailsNZ"> <timeout> <duration>10000</duration> <responseAction>fault</responseAction> </timeout> <suspendOnFailure> <errorCodes>101500,101501,101506,101507,101508</errorCodes> <progressionFactor>0.0</progressionFactor> </suspendOnFailure> <markForSuspension> <errorCodes>101504,101505</errorCodes> </markForSuspension> </address> </endpoint> <endpoint name="INDEmployeeDetails_EPR"> <address uri="http://localhost:9763/services/EmployeeDetailsIndia"> <timeout> <duration>10000</duration> <responseAction>fault</responseAction> </timeout> <suspendOnFailure> <errorCodes>101500,101501,101506,101507,101508</errorCodes> <progressionFactor>0.0</progressionFactor> </suspendOnFailure> <markForSuspension> <errorCodes>101504,101505</errorCodes> </markForSuspension> </address> </endpoint> <endpoint name="USAEmployeeDetails_EPR"> <address uri="http://localhost:9763/services/EmployeeDetailsUSA"> <timeout> <duration>10000</duration> <responseAction>fault</responseAction> </timeout> <suspendOnFailure> <errorCodes>101500,101501,101506,101507,101508</errorCodes> <progressionFactor>0.0</progressionFactor> </suspendOnFailure> <markForSuspension> <errorCodes>101504,101505</errorCodes> </markForSuspension> </address> </endpoint> <sequence name="CommonFaultHandler"> <log level="custom"> <property name="MESSAGE" value="Executing default "fault" sequence"/> <property name="ERROR_CODE" expression="get-property('ERROR_CODE')"/> <property name="ERROR_MESSAGE" expression="get-property('ERROR_MESSAGE')"/> </log> <header name="To" action="remove"/> <drop/> </sequence> </definitions>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:shr="http://shriwithjava.blogspot.co.nz/"> <soapenv:Header/> <soapenv:Body> <shr:getEmployeeDetails> <shr:Department>IT</shr:Department> </shr:getEmployeeDetails> </soapenv:Body> </soapenv:Envelope>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"> <soapenv:Body> <EmployeeDetails xmlns="http://shriwithjava.blogspot.co.nz/"> <EmployeeData> <EmployeeId>201</EmployeeId> <EmployeeName>Shri</EmployeeName> <EmployeeAddress>Auckland</EmployeeAddress> <Department>IT</Department> </EmployeeData> <EmployeeData> <EmployeeId>202</EmployeeId> <EmployeeName>Bhajan</EmployeeName> <EmployeeAddress>Wellington</EmployeeAddress> <Department>IT</Department> </EmployeeData> <EmployeeData> <EmployeeId>004</EmployeeId> <EmployeeName>Viru</EmployeeName> <EmployeeAddress>Kanpur</EmployeeAddress> <Department>IT</Department> </EmployeeData> <EmployeeData> <EmployeeId>111</EmployeeId> <EmployeeName>Tahseen</EmployeeName> <EmployeeAddress>New York</EmployeeAddress> <Department>IT</Department> </EmployeeData> <EmployeeData> <EmployeeId>113</EmployeeId> <EmployeeName>JD</EmployeeName> <EmployeeAddress>Washington</EmployeeAddress> <Department>IT</Department> </EmployeeData> </EmployeeDetails> </soapenv:Body> </soapenv:Envelope>