ricston-git

public class GetImageListComponent implements Callable {

	@Override
	public Object onCall(MuleEventContext eventContext) throws Exception {
		File folder = new File("images");
		File[] listOfFiles = folder.listFiles(new FileFilter() {
			@Override
			public boolean accept(File pathname) {
				return pathname.isFile();
			}

ricston-git

---
{
  functionsOnObjects: {
    getUniqueKeys: getUniqueKeys,
    getKeys: getKeys
  },
  functionsOnStrings: {
    substring: substringFunc
  },
  functionsOnArrays: {

ricston-git

public class FaultInterceptor extends AbstractSoapInterceptor {

    public FaultInterceptor() {
        super(Phase.MARSHAL);
    }

    @Override
    public void handleMessage(SoapMessage message) throws Fault {
        Fault fault = (Fault) message.getContent(Exception.class);

ricston-git

public class QuerySingleFileProcessor implements Callable, Startable {
	
	private SftpConnector sftpConnector;
	private ImmutableEndpoint immutableEndpoint;
	
	private SftpReceiverRequesterUtil util;

	@Inject
	private MuleContext muleContext;

ricston-git

@Override                                                                                         
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException         
{                                                                                                 
   muleContext = getMuleContext(jobExecutionContext);                                            
    if (muleContext.isPrimaryPollingInstance() ||                                                 
        TRUE.equals(jobExecutionContext.getJobDetail().getJobDataMap().get(PROPERTY_JOB_DYNAMIC)))
    {                                                                                             
        doExecute(jobExecutionContext);                                                           
    }                                                                                             
}

ricston-git

<servicenow:config name="ServiceNow" username="${servicenow.username}" password="${servicenow.password}" serviceEndpoint="${servicenow.serviceEndpoint}" doc:name="ServiceNow">
    <servicenow:connection-pooling-profile initialisationPolicy="INITIALISE_ONE" exhaustedAction="WHEN_EXHAUSTED_GROW"/>
</servicenow:config>
	
<flow name="servicenow-usecaseFlow" doc:name="servicenow-usecaseFlow">
    <http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" doc:name="HTTP"/>
    <servicenow:insert config-ref="ServiceNow" type="ALM_ASSET" doc:name="Insert Asset">
	<servicenow:insert-request>
            <servicenow:insert-request key="quantity">#{new java.math.BigInteger(10)}</servicenow:insert-request>
            <servicenow:insert-request key="model">Apple MacBook Pro</servicenow:insert-request>

ricston-git

package com.ricston.xml;

import java.io.IOException;
import java.io.InputStream;

import org.apache.xerces.dom.DOMInputImpl;
import org.mule.util.IOUtils;
import org.w3c.dom.ls.LSInput;
import org.w3c.dom.ls.LSResourceResolver;

ricston-git

<amqp:endpoint exchangeName="main-exchange" queueName="queue1" exchangeDurable="true" name="AMQP_0_9_queue1" responseTimeout="10000" doc:name="AMQP-0-9" routingKey="rk-q1" exchangeType="direct" exchange-pattern="request-response"/>
<amqp:endpoint exchangeName="main-exchange" queueName="queue2" name="AMQP_0_9_queue2" responseTimeout="10000" doc:name="AMQP-0-9" exchangeDurable="true" routingKey="rk-q2" exchangeType="direct"/>
<amqp:connector name="AMQP_0_9_Connector" validateConnections="true" username="administrator" password="password" doc:name="AMQP-0-9 Connector" ackMode="MANUAL"/>
<flow name="rabbitmq-receiveFromServer-queuetestFlow">
    <amqp:inbound-endpoint   responseTimeout="10000" exchange-pattern="request-response"  doc:name="AMQP-MSG-FROM-QUEUE1" ref="AMQP_0_9_queue1" connector-ref="AMQP_0_9_Connector"/>
    <byte-array-to-object-transformer returnClass="java.lang.String" doc:name="Byte Array to Object"/>
    <logger message="Message from Queue1: #[payload]" level="INFO" doc:name="Logger: Incoming 

ricston-git

<amqp:endpoint exchangeName="main-exchange" queueName="queue1" exchangeDurable="true" name="AMQP_0_9_queue1" responseTimeout="10000" doc:name="AMQP-0-9" routingKey="rk-q1" exchangeType="direct" exchange-pattern="request-response"/>
<amqp:endpoint exchangeName="main-exchange" queueName="queue2" name="AMQP_0_9_queue2" responseTimeout="10000" doc:name="AMQP-0-9" exchangeDurable="true" routingKey="rk-q2" exchangeType="direct"/>
<amqp:connector name="AMQP_0_9_Connector" validateConnections="true" username="administrator" password="password" doc:name="AMQP-0-9 Connector"/>
<flow name="rabbitmq-receiveFromServer-queuetestFlow">
    <amqp:inbound-endpoint   responseTimeout="10000" exchange-pattern="request-response"  doc:name="AMQP-MSG-FROM-QUEUE1" ref="AMQP_0_9_queue1" connector-ref="AMQP_0_9_Connector"/>
    <byte-array-to-object-transformer returnClass="java.lang.String" doc:name="Byte Array to Object"/>
    <logger message="Message from Queue1: #[payload]" level="INFO" doc:name="Logger: Incoming from RabbitMQ"/>

ricston-git

package com.ricston.scattergather;

import java.util.List;
import java.util.Map;

import org.apache.log4j.Logger;
import org.mule.api.MuleContext;
import org.mule.api.MuleEvent;
import org.mule.api.MuleException;
import org.mule.api.context.MuleContextAware;