Embedding Flux as a Servlet

The most common way users run Flux in an application server environment is to embed the engine in a servlet. Running Flux as a servlet allows you to easily integrate the engine into your application server environment and works well across all supported application servers.

Servlet Code

To run the engine in a servlet, you simply need:

  • an init() method to initialize the engine and its configuration
  • a destroy() method that shuts down Flux when the servlet shuts down

Typical code for running Flux in a servlet might look something like:

import flux.Engine;
import flux.Factory;
import flux.Configuration;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
public class Servlet extends HttpServlet {
//   The Flux engine.
  private Engine flux;
//   Starts Flux when your servlet is initialized.  public void init() throws ServletException {
    try {
//      Start a Flux engine instance.//      First, create a factory.
      Factory fluxFactory = Factory.makeInstance();
//      Make the engine available remotely
      Configuration config = fluxFactory.makeConfiguration();
//      Next, create a Flux instance.
      flux = fluxFactory.makeEngine(config);
//      Finally, start the Flux engine.
    // try
    catch (Exception e) {
      throw new ServletException(e.getMessage());
    // catch
    System.out.println("*** Flux has been started. ***");
  // init()
//  Shuts down Flux when your servlet is destroyed.
  public void destroy() {
    try {
//      Stop Flux and release its resources.
    // try
    catch (Exception e) {
    // catch
  // destroy()
  public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
    doPost(request, response);
  // doGet
  public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
    PrintWriter out = response.getWriter();
    try {
      out.println("Flux has been started in this servlet\!");
    // try
    catch (Exception e) {
      out.println("An error occured.");
    // catch
  // doPost()
// class Servlet
Was this article helpful?
0 out of 0 found this helpful



Please sign in to leave a comment.