Monday, 15 September 2014

MULE FTP : Create Directory If Not Exist

FTP and SFTP endpoints of mule , does not create directory on the fly , if the directory does not exist at ftp location .
It throws error like this :
ERROR 2007-11-05 15:24:29,192 [connector.ftp.0.receiver.1] org.mule.impl.DefaultExceptionStrategy: Caught exception in Exception Strategy: Failed to change working directory to /IN. Ftp error: 550 Failed to change working directory to /IN. Ftp error: 550
        at org.mule.providers.ftp.FtpMessageReceiver.listFiles(
        at org.mule.providers.ftp.FtpMessageReceiver.poll(
There is an Open Issue for this functionality .

To implement this functionality for FTP , we have to create a custom FTPDispatcher and integrate it in the mule ftp connector .

So first change mule ftp connector to have CustomFTPMessageDispatcher like this:
<ftp:connector name="ftp_con">
  <service-overrides dispatcherFactory="CustomFtpMessageDispatcherFactory"></service-overrides>
    <flow name="sftpExampleFlow1" doc:name="sftpExampleFlow1">
        <file:inbound-endpoint path="E:/ftp" responseTimeout="10000" doc:name="File"/>
        <ftp:outbound-endpoint host="localhost" port="21" responseTimeout="10000" doc:name="FTP" connector-ref="ftp_con"
        outputPattern="custom/path/myFile.txt" path="/home/ftp" 
And here's the DispatcherFactory class .

import org.mule.api.MuleException;
import org.mule.api.endpoint.OutboundEndpoint;
import org.mule.api.transport.MessageDispatcher;
import org.mule.transport.ftp.FtpMessageDispatcherFactory;

public class CustomFtpMessageDispatcherFactory extends FtpMessageDispatcherFactory
 /** {@inheritDoc} */
    public MessageDispatcher create(OutboundEndpoint endpoint) throws MuleException
        return new CustomFtpMessageDispatcher(endpoint);

And here's the FTPMessageDispacther , which will first create a directory if the outputPattern has it .


import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.mule.api.MuleEvent;
import org.mule.api.endpoint.OutboundEndpoint;
import org.mule.api.transport.DispatchException;
import org.mule.config.i18n.CoreMessages;
import org.mule.model.streaming.CallbackOutputStream;
import org.mule.transport.ConnectException;
import org.mule.transport.ftp.FtpConnector;
import org.mule.transport.ftp.FtpMessageDispatcher;

public class CustomFtpMessageDispatcher extends FtpMessageDispatcher

 Log logger = LogFactory.getLog(CustomFtpMessageDispatcher.class);

 public CustomFtpMessageDispatcher(OutboundEndpoint endpoint)


 protected void doDispatch(MuleEvent event) throws Exception
  Object data = event.getMessage().getPayload();
  String outputPattern = (String) endpoint.getProperty(FtpConnector.PROPERTY_OUTPUT_PATTERN);
  String basePath = endpoint.getEndpointURI().getPath();
  OutputStream out = null;
  if (basePath.endsWith("/"))
   basePath = basePath.substring(0, basePath.length() - 1);

  if (outputPattern != null && outputPattern.contains("/"))
    if (outputPattern.startsWith("/"))
     outputPattern = outputPattern.substring(1, outputPattern.length());
    String dirs[] = outputPattern.split("/", -1);
    final FtpConnector connector = (FtpConnector) endpoint.getConnector();
    final FTPClient client = connector.getFtp(endpoint.getEndpointURI());
    for (int i = 0; i < dirs.length - 1; i++)
      if (!dirs[i].isEmpty())
       basePath = basePath + "/" + dirs[i];
       if (!client.changeWorkingDirectory(basePath))

     } catch (Exception e)
      logger.error("Error Creating dir on ftp" + e.getMessage());
    String filename = dirs[dirs.length - 1];
    out = client.storeFileStream(filename);
    if (out == null)
     throw new IOException("FTP operation failed: " + client.getReplyString());

    out = new CallbackOutputStream(out, new CallbackOutputStream.Callback()
     public void onClose() throws Exception
       if (!client.completePendingCommand())
        throw new IOException("FTP Stream failed to complete pending request");
      } finally
       connector.releaseFtp(endpoint.getEndpointURI(), client);
   catch (ConnectException ce)
             // Don't wrap a ConnectException, otherwise the retry policy will not go into effect.
             throw ce;
         catch (Exception e)
             throw new DispatchException(CoreMessages.streamingFailedNoStream(), event, (OutboundEndpoint)endpoint, e);

   out = connector.getOutputStream(getEndpoint(), event);

   if (data instanceof InputStream)
    InputStream is = ((InputStream) data);
    IOUtils.copy(is, out);
   } else
    byte[] dataBytes;
    if (data instanceof byte[])
     dataBytes = (byte[]) data;
    } else
     dataBytes = data.toString().getBytes(event.getEncoding());
    IOUtils.write(dataBytes, out);
  } finally


Post Comments And Suggestions !!!

Friday, 12 September 2014


Wirble is a set of enhancements for ruby(irb). Wirble enables several items mentioned on the RubyGarden "Irb Tips and Tricks" page, including tab-completion, history, and a built-in ri command, as well as colorized results and a couple other goodies.

Wirble even works with rvm , lets hack the trick to do so:

Step 1:
When we start irb prompt it first checks for .irbrc file in home folder. ~/.irbrc.

Step 2 :
To enable wirble in irb prompt, Open the ~/.irbrc file (Create a new one if Not present.), and Paste the contents of the below code.
require 'irb/completion'
 require 'irb/ext/save-history'
 require 'rubygems'
 unless Gem::Specification.find_all_by_name('wirble').any?
   puts "Installing Wirble"
   %x{gem install 'wirble' --no-ri --no-rdoc}
 require 'wirble'
# Initializing Wirble
# Customize according to your will.
colors = Wirble::Colorize.colors.merge({
  :object_class => :purple,
  :symbol => :purple,
  :symbol_prefix => :purple
Wirble::Colorize.colors = colors

Step 3:
Move out of the blog for a colourfull irb prompt and Njoy Coding in Ruby. Thanks to Santosh for writing this post .

Tuesday, 2 September 2014

Mule SFTP : Verify false Error

The following error might occur while using SFTP inbound or outbound endpoint in mule :
Error during login to x@ verify: false Error during login to x@ verify: false
 at org.mule.transport.sftp.SftpClient.logAndThrowLoginError(
 at org.mule.transport.sftp.SftpClient.login(
 at org.mule.transport.sftp.SftpConnectionFactory.createClient(
 at org.mule.transport.sftp.SftpConnector.createSftpClient(
 at org.mule.transport.sftp.SftpConnector.createSftpClient(
 at org.mule.transport.sftp.SftpReceiverRequesterUtil.getAvailableFiles(
 at org.mule.transport.sftp.SftpMessageReceiver.poll(
 at org.mule.transport.AbstractPollingMessageReceiver.performPoll(
 at org.mule.transport.PollingReceiverWorker.poll(
 at java.util.concurrent.ThreadPoolExecutor.runWorker(
 at java.util.concurrent.ThreadPoolExecutor$
Mule SFTP uses JSch to connect to SFTP location . This error occurs with particular Java JDK updates . You might get this error If you are using following versions of jdk :
This error does not occur if we use JDK version < java7u6 .

For more information please read this link.

Post Comments And Suggestions !!

Wednesday, 20 August 2014

JAXB Error : FWK005 parse may not be called while parsing

org.xml.sax.SAXException: FWK005 parse may not be called while parsing.
Above Error occurs because you might have SchemaFactory instance , which is shared by multiple threads. Like declaring it at class level , and using it in methods .
private SchemaFactory factory = SchemaFactory.newInstance(XMLConstants.W3C_XML_SCHEMA_NS_URI);
The SchemaFactory is not thread safe . It should always be initialized and accessed in local scope. So whenever you need SchemaFactory instance , just create it locally instead of using it at instance level.

Post Comments And Suggestions !!

Tuesday, 19 August 2014

How To Link Git Tag with Rails app

I use Git tags to manage the version numbers of my Rails apps.

Every time a new version is ready, I tag the current commit like this :
git tag -a v1.10 -m "FIXED PC-43/67/78"
I have created a ruby file in initializers which defines a constant to hold this information (in this case “v1.10”):
APP_VERSION = `git describe --always` unless defined? APP_VERSION
This constant simply contains the output of Git describe.
Now I can use it anywhere in my app where I would like to display the version number.

This post is written by Santosh.

Post Comments And Suggestions

Sunday, 17 August 2014

How to Print Full Stack Trace In Mule Flow

To print full exception stack trace in mule , you need to add a grrovy scripting element like this :
<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:scripting=""
 xmlns:http="" xmlns="" xmlns:doc="" xmlns:spring="" version="CE-3.3.1" xmlns:xsi="" xsi:schemaLocation=" ">
    <flow name="muleMavenSampleFlow1" doc:name="muleMavenSampleFlow1">
        <http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" doc:name="HTTP"/>
        <catch-exception-strategy doc:name="Catch Exception Strategy">
         <scripting:transformer doc:name="Print StackTrace">
    <scripting:script engine="Groovy">
                    <scripting:text><![CDATA[org.apache.log4j.Logger.getLogger("").error("Error Trace is : \n",exception)]]></scripting:text>

Post Comments And Suggestions !!

Wednesday, 16 July 2014

Mule Cron Job : Job Name Can Not be Empty Error

Writing cron job is very easy in mule.You might get error like this in mule application start up :
Caused by: org.mule.api.lifecycle.LifecycleException: Failed to start inbound endpoint "endpoint.quartz.test.job"
 at org.mule.endpoint.DefaultInboundEndpoint.start(
 at org.mule.construct.AbstractFlowConstruct.startIfStartable(
 at org.mule.construct.AbstractPipeline.doStart(
 at org.mule.construct.AbstractFlowConstruct$2.onTransition(
 at org.mule.construct.AbstractFlowConstruct$2.onTransition(
 at org.mule.lifecycle.AbstractLifecycleManager.invokePhase(
 at org.mule.construct.FlowConstructLifecycleManager.fireStartPhase(
 at org.mule.construct.AbstractFlowConstruct.start(
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at sun.reflect.NativeMethodAccessorImpl.invoke(
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(
 at java.lang.reflect.Method.invoke(
 at org.mule.lifecycle.phases.DefaultLifecyclePhase.applyLifecycle(
 at org.mule.lifecycle.RegistryLifecycleManager$RegistryLifecycleCallback.onTransition(
 at org.mule.lifecycle.RegistryLifecycleManager.invokePhase(
 at org.mule.lifecycle.RegistryLifecycleManager.fireLifecycle(
 at org.mule.registry.AbstractRegistryBroker.fireLifecycle(
 at org.mule.registry.MuleRegistryHelper.fireLifecycle(
 at org.mule.lifecycle.MuleContextLifecycleManager$MuleContextLifecycleCallback.onTransition(
 at org.mule.lifecycle.MuleContextLifecycleManager$MuleContextLifecycleCallback.onTransition(
 at org.mule.lifecycle.MuleContextLifecycleManager.invokePhase(
 at org.mule.lifecycle.MuleContextLifecycleManager.fireLifecycle(
 at org.mule.DefaultMuleContext.start(
 at org.mule.module.launcher.application.DefaultMuleApplication.start(
 ... 4 more
Caused by: org.mule.api.lifecycle.LifecycleException: Failed to start Quartz receiver
 at org.mule.lifecycle.AbstractLifecycleManager.invokePhase(
 at org.mule.transport.ConnectableLifecycleManager.fireStartPhase(
 at org.mule.transport.AbstractTransportMessageHandler.start(
 at org.mule.transport.AbstractConnector.registerListener(
 at org.mule.endpoint.DefaultInboundEndpoint.start(
 ... 27 more
Caused by: org.mule.api.endpoint.EndpointException: Failed to start Quartz receiver
 at org.mule.transport.quartz.QuartzMessageReceiver.doStart(
 at org.mule.transport.AbstractMessageReceiver.doStartHandler(
 at org.mule.transport.AbstractTransportMessageHandler$3.onTransition(
 at org.mule.lifecycle.AbstractLifecycleManager.invokePhase(
 ... 31 more
Caused by: java.lang.IllegalArgumentException: Job name cannot be empty.
 at org.quartz.JobDetail.setName(
 at org.mule.transport.quartz.QuartzMessageReceiver.doStart(
 ... 34 more

Here's the xml file :
<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:quartz="" xmlns="" xmlns:doc="" xmlns:spring="" version="CE-3.3.1" xmlns:xsi="" xsi:schemaLocation=" ">
    <flow name="crontestFlow1" doc:name="crontestFlow1">
        <quartz:inbound-endpoint jobName="test_job" cronExpression="0 0/100 * * * ?" responseTimeout="10000" doc:name="Price File Report Quartz Job" >
        <logger level="INFO" doc:name="Logger"/>

Notice that your jobName is not empty . The issue is with underscore . you can not have underscore in jobName property. Just remove underscore from jobName and it will run fine.You can not have white space characters in job name either

Here's the bug.

Post Comments And Suggestions !!