Build MSF4J with WSO2 Carbon Kernel 5.1.0

MSF4J supports standalone mode as well as the OSGi mode. Unlike other WSO2 products, MSF4J is not released as a typical server. But you can build up your own server by installing the MSF4J feature in to the Carbon Kernel.

You can used the pom based approach to install the MSF4J feature into the Kernel 5.1.0

You can find the full source in the https://github.com/thusithathilina/msf4j-product/tree/master

Steps

Copy the following pom.xml and carbon.product file to a some directory

Run “mvn clean install” inside the directory.

If the build is success, you can find the build product inside the target folder. You can run the server by executing the wso2carbon-kernel-5.1.0/bin/carbon.sh file in the target directory.

	<project xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>org.wso2.sample</groupId>
	<artifactId>sample-feature-installation</artifactId>
	<version>1.0.0</version>
	<packaging>pom</packaging>
	<name>New feature</name>
	<properties>
	<carbon.messaging.version>1.0.6</carbon.messaging.version>
	<carbon.transport.http.netty.version>2.1.4</carbon.transport.http.netty.version>
	<carbon.metrics.version>2.0.0</carbon.metrics.version>
	<msf4j.version>2.1.0-SNAPSHOT</msf4j.version>
	<carbon.feature.plugin.version>2.1.0</carbon.feature.plugin.version>
	<carbon.kernel.version>5.1.0</carbon.kernel.version>
	<osgi.api.version>6.0.0</osgi.api.version>
	<carbon.jndi.version>1.0.0</carbon.jndi.version>
	<carbon.cache.version>1.0.0</carbon.cache.version>
	<carbon.deployment.version>5.0.0</carbon.deployment.version>
	<carbon.datasources.version>1.0.0</carbon.datasources.version>
	</properties>
	<dependencies>
	<dependency>
	<groupId>org.wso2.carbon</groupId>
	<artifactId>org.wso2.carbon.kernel.feature</artifactId>
	<version>${carbon.kernel.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon</groupId>
	<artifactId>org.wso2.carbon.runtime.feature</artifactId>
	<version>${carbon.kernel.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon</groupId>
	<artifactId>org.wso2.carbon.launcher</artifactId>
	<version>${carbon.kernel.version}</version>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon.jndi</groupId>
	<artifactId>org.wso2.carbon.jndi.feature</artifactId>
	<version>${carbon.jndi.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon.caching</groupId>
	<artifactId>org.wso2.carbon.caching.feature</artifactId>
	<version>${carbon.cache.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon.datasources</groupId>
	<artifactId>org.wso2.carbon.datasource.core.feature</artifactId>
	<version>${carbon.datasources.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon.messaging</groupId>
	<artifactId>org.wso2.carbon.messaging.feature</artifactId>
	<version>${carbon.messaging.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon.transport</groupId>
	<artifactId>org.wso2.carbon.transport.http.netty.feature</artifactId>
	<version>${carbon.transport.http.netty.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon.metrics</groupId>
	<artifactId>org.wso2.carbon.metrics.core.feature</artifactId>
	<version>${carbon.metrics.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon.metrics</groupId>
	<artifactId>org.wso2.carbon.metrics.jdbc.core.feature</artifactId>
	<version>${carbon.metrics.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.wso2.carbon.metrics</groupId>
	<artifactId>org.wso2.carbon.metrics.das.core.feature</artifactId>
	<version>${carbon.metrics.version}</version>
	<type>zip</type>
	</dependency>
	<dependency>
	<groupId>org.osgi</groupId>
	<artifactId>org.osgi.core</artifactId>
	<version>${osgi.api.version}</version>
	</dependency>
	<!-- MSF4J -->
	<dependency>
	<groupId>org.wso2.msf4j</groupId>
	<artifactId>org.wso2.msf4j.feature</artifactId>
	<version>${msf4j.version}</version>
	<type>zip</type>
	</dependency>
	</dependencies>
	<build>
	<plugins>
	<plugin>
	<groupId>org.apache.maven.plugins</groupId>
	<artifactId>maven-dependency-plugin</artifactId>
	<inherited>false</inherited>
	<executions>
	<execution>
	<id>unpack-equinox-executable</id>
	<phase>package</phase>
	<goals>
	<goal>unpack</goal>
	</goals>
	<configuration>
	<artifactItems>
	<artifactItem>
	<groupId>org.eclipse.equinox</groupId>
	<artifactId>org.eclipse.equinox.executable</artifactId>
	<version>3.5.0.v20110530-7P7NFUFFLWUl76mart</version>
	<type>zip</type>
	<overWrite>true</overWrite>
	<outputDirectory>target</outputDirectory>
	</artifactItem>
	</artifactItems>
	</configuration>
	</execution>
	</executions>
	</plugin>
	<plugin>
	<groupId>org.wso2.carbon.maven</groupId>
	<artifactId>carbon-feature-plugin</artifactId>
	<version>${carbon.feature.plugin.version}</version>
	<executions>
	<execution>
	<id>p2-repo-generation</id>
	<phase>package</phase>
	<goals>
	<goal>generate-repo</goal>
	</goals>
	<configuration>
	<targetRepository>file:${basedir}/target/p2-repo</targetRepository>
	<features>
	<feature>
	<id>org.wso2.carbon.kernel.feature</id>
	<version>${carbon.kernel.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.runtime.feature</id>
	<version>${carbon.kernel.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.caching.feature</id>
	<version>${carbon.cache.version}</version>
	</feature>
	<feature>
	<id>org.wso2.msf4j.feature</id>
	<version>${msf4j.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.messaging.feature</id>
	<version>${carbon.messaging.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.transport.http.netty.feature</id>
	<version>${carbon.transport.http.netty.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.jndi.feature</id>
	<version>${carbon.jndi.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.metrics.core.feature</id>
	<version>${carbon.metrics.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.metrics.jdbc.core.feature</id>
	<version>${carbon.metrics.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.metrics.das.core.feature</id>
	<version>${carbon.metrics.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.datasource.core.feature</id>
	<version>${carbon.datasources.version}</version>
	</feature>
	</features>
	</configuration>
	</execution>
	<execution>
	<id>publishing products</id>
	<phase>package</phase>
	<goals>
	<goal>publish-product</goal>
	</goals>
	<configuration>
	<productConfigurationFile>${basedir}/carbon.product
	</productConfigurationFile>
	<executable>
	${basedir}/target/org.eclipse.equinox.executable_3.5.0.v20110530-7P7NFUFFLWUl76mart
	</executable>
	<repositoryURL>file:${basedir}/target/p2-repo</repositoryURL>
	</configuration>
	</execution>
	<execution>
	<id>materialize-product</id>
	<phase>package</phase>
	<goals>
	<goal>generate-profile</goal>
	</goals>
	<configuration>
	<productConfigurationFile>${basedir}/carbon.product
	</productConfigurationFile>
	<repositoryURL>file:${basedir}/target/p2-repo</repositoryURL>
	<targetPath>
	file:${basedir}/target/wso2carbon-kernel-${carbon.kernel.version}/osgi
	</targetPath>
	<profile>profiles/default</profile>
	</configuration>
	</execution>
	<execution>
	<id>feature-installation</id>
	<phase>package</phase>
	<goals>
	<goal>install</goal>
	</goals>
	<configuration>
	<profile>profiles/default</profile>
	<repositoryURL>file:${basedir}/target/p2-repo</repositoryURL>
	<destination>
	${basedir}/target/wso2carbon-kernel-${carbon.kernel.version}/osgi
	</destination>
	<deleteOldProfileFiles>true</deleteOldProfileFiles>
	<features>
	<feature>
	<id>org.wso2.carbon.kernel.feature.group</id>
	<version>${carbon.kernel.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.caching.feature.group</id>
	<version>${carbon.cache.version}</version>
	</feature>
	<feature>
	<id>org.wso2.msf4j.feature.group</id>
	<version>${msf4j.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.messaging.feature.group</id>
	<version>${carbon.messaging.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.transport.http.netty.feature.group</id>
	<version>${carbon.transport.http.netty.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.jndi.feature.group</id>
	<version>${carbon.jndi.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.metrics.core.feature.group</id>
	<version>${carbon.metrics.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.metrics.jdbc.core.feature.group</id>
	<version>${carbon.metrics.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.metrics.das.core.feature.group</id>
	<version>${carbon.metrics.version}</version>
	</feature>
	<feature>
	<id>org.wso2.carbon.datasource.core.feature.group</id>
	<version>${carbon.datasources.version}</version>
	</feature>
	</features>
	</configuration>
	</execution>
	</executions>
	</plugin>
	<plugin>
	<groupId>org.apache.maven.plugins</groupId>
	<artifactId>maven-antrun-plugin</artifactId>
	<executions>
	<execution>
	<phase>package</phase>
	<configuration>
	<tasks>
	<replace dir="target/wso2carbon-kernel-${carbon.kernel.version}/osgi" token="false"
	value="true">
	<include name="**/bundles.info" />
	</replace>
	</tasks>
	</configuration>
	<goals>
	<goal>run</goal>
	</goals>
	</execution>
	<execution>
	<id>clean_target</id>
	<phase>install</phase>
	<configuration>
	<target>
	<delete dir="target/archive-tmp" />
	<delete dir="target/dependency-maven-plugin-markers" />
	<delete dir="target/org.eclipse.equinox.executable-3.5.0.v20110530-7P7NFUFFLWUl76mart" />
	<delete dir="target/p2-repo" />
	<delete file="target/tmp" />
	<delete dir="target/wso2carbon-kernel-${carbon.kernel.version}" />
	<delete dir="target/antrun" />
	</target>
	</configuration>
	<goals>
	<goal>run</goal>
	</goals>
	</execution>
	</executions>
	</plugin>
	</plugins>
	</build>
	<pluginRepositories>
	<pluginRepository>
	<id>wso2-nexus</id>
	<name>WSO2 Public Repository</name>
	<url>http://maven.wso2.org/nexus/content/groups/wso2-public/</url>
	<releases>
	<enabled>true</enabled>
	<updatePolicy>daily</updatePolicy>
	<checksumPolicy>ignore</checksumPolicy>
	</releases>
	</pluginRepository>
	<pluginRepository>
	<id>wso2-releases</id>
	<name>WSO2 Releases Repository</name>
	<url>http://maven.wso2.org/nexus/content/repositories/releases/</url>
	<releases>
	<enabled>true</enabled>
	<updatePolicy>daily</updatePolicy>
	<checksumPolicy>ignore</checksumPolicy>
	</releases>
	</pluginRepository>
	<pluginRepository>
	<id>wso2-snapshots</id>
	<name>WSO2 Snapshot Repository</name>
	<url>http://maven.wso2.org/nexus/content/repositories/snapshots/</url>
	<snapshots>
	<enabled>true</enabled>
	<updatePolicy>daily</updatePolicy>
	</snapshots>
	<releases>
	<enabled>false</enabled>
	</releases>
	</pluginRepository>
	</pluginRepositories>
	<repositories>
	<repository>
	<id>wso2-nexus</id>
	<name>WSO2 Public Repository</name>
	<url>http://maven.wso2.org/nexus/content/groups/wso2-public/</url>
	<releases>
	<enabled>true</enabled>
	<updatePolicy>daily</updatePolicy>
	<checksumPolicy>ignore</checksumPolicy>
	</releases>
	</repository>
	<repository>
	<id>wso2-releases</id>
	<name>WSO2 Releases Repository</name>
	<url>http://maven.wso2.org/nexus/content/repositories/releases/</url>
	<releases>
	<enabled>true</enabled>
	<updatePolicy>daily</updatePolicy>
	<checksumPolicy>ignore</checksumPolicy>
	</releases>
	</repository>
	<repository>
	<id>wso2-snapshots</id>
	<name>WSO2 Snapshot Repository</name>
	<url>http://maven.wso2.org/nexus/content/repositories/snapshots/</url>
	<snapshots>
	<enabled>true</enabled>
	<updatePolicy>daily</updatePolicy>
	</snapshots>
	<releases>
	<enabled>false</enabled>
	</releases>
	</repository>
	</repositories>
	</project>

view raw pom.xml hosted with ❤ by GitHub

	<?xml version="1.0" encoding="UTF-8"?>
	<?pde version="3.5"?>
	<product name="Carbon Product" uid="carbon.product.id" id="carbon.product" application="carbon.application"
	version="5.1.0" useFeatures="true" includeLaunchers="true">
	<configIni use="default">
	</configIni>
	<launcherArgs>
	</launcherArgs>
	<plugins>
	</plugins>
	<features>
	<feature id="org.wso2.carbon.runtime" version="5.1.0"/>
	</features>
	<configurations>
	<plugin id="org.eclipse.core.runtime" autoStart="true" startLevel="4" />
	<plugin id="org.eclipse.equinox.common" autoStart="true" startLevel="2" />
	<plugin id="org.eclipse.equinox.ds" autoStart="true" startLevel="2" />
	<plugin id="org.eclipse.equinox.p2.reconciler.dropins" autoStart="true" startLevel="4" />
	<plugin id="org.eclipse.equinox.simpleconfigurator" autoStart="true" startLevel="1" />
	<property name="org.eclipse.update.reconcile" value="false" />
	<plugin id="org.eclipse.update.configurator" autoStart="true" startLevel="4"/>
	<property name="org.eclipse.equinox.simpleconfigurator.useReference" value="true" />
	</configurations>
	</product>

view raw carbon.product hosted with ❤ by GitHub

Add a Microservice to the Server

You can build the stockquote bundle sample as mentioned inhttps://github.com/wso2/msf4j/tree/master/samples/stockquote/bundleThen copy the bundle to wso2carbon-kernel-5.1.0/osgi/dropins directory and start the server.

To invoke the deployed service use below curl command

curl http://localhost:9090/stockquote/IBM

MSF4J will Support JAX-RS Sub-Resource and Running Multiple Microservice Runners

WSO2 MSF4J will will support JAX-RS sub resources and running multiple microservice runners in its’ next release along with some great features.

JAX-RS Sub-Resource

You can try out the sub-resources with the latest MSF4J snapshot version. https://github.com/wso2/msf4j/tree/master/samples/subresource is the MSF4J Sub resource sample that demonstrate how to use sub-resource with MSF4J.

Running Multiple MicroservicesRunners

In previous MSF4J versions we only support running a single MicroservicesRunner in a single JVM. With the next release you can run several MicroservicesRunners in a single JVM.

Following code segment shows a simple sample of the usage.

	public class Application {
	public static void main(String[] args) {
	new MicroservicesRunner()
	.deploy(new HelloService())
	.start();
	new MicroservicesRunner(8081)
	.deploy(new CalculationService())
	.start();
	}
	}

view raw multiple-micorservice-runners.java hosted with ❤ by GitHub

Tryout the new features in the MSF4J and provide your feedback. Also please do raise issues in JIRA/Github if you encounter anything.

WSO2 Microservices Framework for Java (WSO2 MSF4J) 2.0.0 Released

We are pleased to announce the release of WSO2 Microservices Framework for Java (WSO2 MSF4J) 2.0.0. The distribution, source and tag location for this release is available here.

WSO2 MSF4J is a lightweight, high performance microservices runtime. It also provides a very simple programming model for developing Java based microservices.

This release of the WSO2 MSF4J includes the following key features. For further details please refer to the Product Page.

What’s New in This Release

• Spring support MSF4J now supports Spring annotations and runtime
• Swagger support 
  Generate Swagger definitions for your microservices and annotate services using Swagger annotations
• Exception mapper supportAllows mapping of Java exceptions to custom HTTP responses
• Streaming output support 
  Provides full control over streaming to the service developer
• FormParam and FormDataParam annotation support 
  Provides support to handle x-form-application-urlencoded and multipart/form-data requests with form submission
• FormParamIterator support
  Provides full control to the developer over form field processing
• Circuit breaker supportNygard’s circuit breaker pattern is supported via Netflix Hystrix
• Improved thread model and transport architecture
  Netty and execution thread pools can now be customized according to the required service characteristics

In addition to the above features, MSF4J supports analysis with visualization with WSO2 Data Analytics Server (DAS), and includes a set of comprehensive samples which demonstrate how to use MSF4J features & build Microservices Architecture (MSA) based solutions. This release also includes several bug fixes to the previous version of MSF4J. To find out more, visit the MSF4J product page.

How you can contribute

We welcome contributors: head over to wso2.com/community to find out more. If you have any suggestions or are interested in WSO2 MSF4J 2.0.0 discussions, please join the dev@wso2.org or architecture@wso2.org mailing lists.

Reporting Issues

Please report issues and documentation errors regarding WSO2 MSF4J 2.0.0 through the public issue tracking system

Face Recognition in Video with JavaCV

Few weeks ago some random guy asked me whether I can help him to do face recognition in a video. At that time I didn’t had much free time so couldn’t look much into that. In this weekend suddenly I recall that and wanted to check on that.
There can be lot of improvements to be done for this. But for someone who just wanna give a shot here is the code

	import org.bytedeco.javacpp.opencv_core;
	import org.bytedeco.javacpp.opencv_objdetect;
	import org.bytedeco.javacv.CanvasFrame;
	import org.bytedeco.javacv.FFmpegFrameGrabber;
	import org.bytedeco.javacv.FFmpegFrameRecorder;
	import org.bytedeco.javacv.Frame;
	import org.bytedeco.javacv.FrameGrabber;
	import org.bytedeco.javacv.FrameRecorder;
	import org.bytedeco.javacv.OpenCVFrameConverter;
	import java.util.logging.Level;
	import java.util.logging.Logger;
	import static org.bytedeco.javacpp.helper.opencv_objdetect.cvHaarDetectObjects;
	import static org.bytedeco.javacpp.opencv_core.*;
	import static org.bytedeco.javacpp.opencv_imgproc.*;
	public class HelloWC {
	// Training file
	private static final String CASCADE_FILE =
	"/home/thusitha/Desktop/opencv/opencv-3.1.0/data/haarcascades_cuda/haarcascade_frontalface_alt.xml";
	public static void main(String[] args) {
	try {
	FFmpegFrameGrabber grabber = new FFmpegFrameGrabber("mytestvideo.mp4"); // Your video input file
	grabber.start();
	Frame grabbedImage = grabber.grab();
	CanvasFrame canvasFrame = new CanvasFrame("Video with JavaCV");
	canvasFrame.setCanvasSize(grabbedImage.imageWidth, grabbedImage.imageHeight);
	grabber.setFrameRate(grabber.getFrameRate());
	FFmpegFrameRecorder recorder = new FFmpegFrameRecorder("videowithfacedetection.mp4", grabber.getImageWidth(),
	grabber.getImageHeight()); // specify your path
	recorder.setFormat("mp4");
	recorder.setFrameRate(30);
	recorder.setVideoBitrate(10 * 1024 * 1024);
	recorder.start();
	OpenCVFrameConverter.ToIplImage toIplImage = new OpenCVFrameConverter.ToIplImage();
	while (canvasFrame.isVisible() && (grabbedImage = grabber.grab()) != null) {
	IplImage convert = toIplImage.convert(grabbedImage);
	IplImage grayImage = IplImage.create(convert.width(), convert.height(), IPL_DEPTH_8U, 1);
	cvCvtColor(convert, grayImage, CV_BGR2GRAY);
	opencv_core.CvMemStorage storage = opencv_core.CvMemStorage.create();
	opencv_objdetect.CvHaarClassifierCascade cascade =
	new opencv_objdetect.CvHaarClassifierCascade(cvLoad(CASCADE_FILE));
	opencv_core.CvSeq faces = cvHaarDetectObjects(grayImage, cascade, storage, 1.1, 1, 0);
	for (int i = 0; i < faces.total(); i++) {
	opencv_core.CvRect r = new opencv_core.CvRect(cvGetSeqElem(faces, i));
	cvRectangle(convert, cvPoint(r.x(), r.y()), cvPoint(r.x() + r.width(), r.y() + r.height()),
	opencv_core.CvScalar.BLUE, 5, CV_AA, 0);
	}
	canvasFrame.showImage(toIplImage.convert(convert));
	recorder.record(toIplImage.convert(convert));
	}
	recorder.stop();
	grabber.stop();
	canvasFrame.dispose();
	} catch (FrameGrabber.Exception ex) {
	Logger.getLogger(HelloWC.class.getName()).log(Level.SEVERE, null, ex);
	} catch (FrameRecorder.Exception ex) {
	Logger.getLogger(HelloWC.class.getName()).log(Level.SEVERE, null, ex);
	}
	}
	}

view raw HelloWC.java hosted with ❤ by GitHub

FormParam with MSF4J

In JAX-RS, we can use @FormParam annotation to bind HTML form parameters value to a Java method.

Next MSF4J supports below content types for FormParam

1. application/x-www-form-urlencoded
2. multipart/form-data

For the application/x-www-form-urlencoded

This is pretty much similar to the QueryParam. MSF4J reads the Request body and get the decode the encoded values and pass the values to the service.

E.g.

Sample service for application/x-www-form-urlencoded content type

@POST

@Path("/formParam")

public Response testFormParam(@FormParam("age") int age, @FormParam("name") String name) {

  System.out.println("Name " + name);

  System.out.println("Age" + age);

  return Response.ok().entity("Name and age " + name + ", " + age).build();

}

Parameters should be based on http://docs.oracle.com/javaee/7/api/javax/ws/rs/FormParam.html

For the multipart/form-data

@POST

@Path("/formParam")

@Consumes({MediaType.APPLICATION_FORM_URLENCODED, MediaType.MULTIPART_FORM_DATA})

public Response testFormParam(@FormParam("age") int age, @FormParam("name") String name) {

  System.out.println("Name " + name);

  System.out.println("Age" + age);

  return Response.ok().entity("Name and age " + name + ", " + age).build();

}

If a user wants, MSF4J will not process the stream but rather directly pass an FormParamIterator which can be used to retrieve the parameter values.

FormParam name must be ‘form’ and the type must be FormParamIterator

E.g.

Sample service for multipart/form-data content-type with file upload

@POST

@Path("/simpleFormStreaming")

@Consumes(MediaType.MULTIPART_FORM_DATA)

public Response simpleFormStreaming(@Context FormParamIterator formParamIterator) {

  try {

      while (formParamIterator.hasNext()) {

          FormItem item = formParamIterator.next();

          if (item.isFormField()) {

              System.out.println(item.getFieldName() + " - " + StreamUtil.asString(item.openStream()));

          } else {

           Files.copy(file.toPath(), Paths.get(System.getProperty("java.io.tmpdir"), file.getName()));           

}

      }

  } catch (FileUploadException e) {

      log.error("Error while uploading the file " + e.getMessage(), e);

  } catch (IOException e) {

      log.error("Unable to upload the file " + e.getMessage(), e);

  }

  return Response.ok().entity("Request completed").build();

}

If you like use non streaming mode then you can directly get File objects in a file upload. Here rather than @FormParam you need to use @FormDataParam annotation. This annotation can be used with all FormParam supported data types plus File and bean types as well as with InpuStreams.

If you wanna upload set of files. Then a sample service would be like as follows

@POST

@Path("/multipleFiles")

@Consumes(MediaType.MULTIPART_FORM_DATA)

public Response multipleFiles(@FormDataParam("files") List<File> files) {

  files.forEach(file -> {

      try {

          Files.copy(file.toPath(), Paths.get("/tmp", "tst", file.getName()));

      } catch (IOException e) {

          log.error("Error while Copying the file " + e.getMessage(), e);

      }

  });

  return Response.ok().entity("Request completed").build();

}

You can use more complex times with combination of primitives, beans and files as follows

@POST

@Path("/complexForm")

@Consumes(MediaType.MULTIPART_FORM_DATA)

public Response complexForm(@FormDataParam("file") File file,

                      @FormDataParam("id") int id,

                      @FormDataParam("people") List<Person> personList,

                      @FormDataParam("company") Company animal) {

  System.out.println("First Person in List " + personList.get(0).getName());

  System.out.println("Id " + id);

  System.out.println("Company " + animal.getType());

  try {

          Files.copy(file.toPath(), Paths.get(System.getProperty("java.io.tmpdir"), file.getName()));

  } catch (IOException e) {

      log.error("Error while Copying the file " + e.getMessage(), e);

  }

  return Response.ok().entity("Request completed").build();

}

If you like to get the InputStream of a file then you can go ahead like below example. There FileInfo bean will hold the filename and the content type attributes of the particular inputstream. Note that attribute names must be equal when you use InpuStream. Here I’ve used ‘file’ for the both params.

@POST

@Path("/streamFile")

@Consumes(MediaType.MULTIPART_FORM_DATA)

public Response multipleFiles(@FormDataParam("file") FileInfo fileInfo,

                            @FormDataParam("file") InputStream inputStream) {

  try {

      Files.copy(inputStream, Paths.get(System.getProperty("java.io.tmpdir"), fileInfo.getFileName()));

  } catch (IOException e) {

      log.error("Error while Copying the file " + e.getMessage(), e);

      return Response.status(Response.Status.INTERNAL_SERVER_ERROR).build();

  } finally {

      IOUtils.closeQuietly(inputStream);

  }

  return Response.ok().entity("Request completed").build();

}

Tryout with latest msf4j

You can try out these scenarios with the latest msf4j snapshot. In order to do so get the msf4j source from the https://github.com/wso2/msf4j and build it with maven.