Embedding Baleen

Whilst Baleen is generally used as a standalone server, it is possible to embed Baleen pipelines within other applications. The following shows a very simple instance of this, although it is possible to control and configure Baleen to a much greater extent than shown. For full details of how to use each class, refer to the JavaDoc

This code demonstrates running Baleen from a Java application:

public class EmbeddedPipeline{

	public static void main(String[] args) throws Exception {
		String yaml = new String(Files.readAllBytes(Paths.get(args[0])));
		
		PipelineBuilder builder = new PipelineBuilder("My Embedded Pipeline", yaml);
		BaleenPipeline pipeline = builder.createNewPipeline();
		
		pipeline.run();
	}

}

The pipeline will continue running until pipeline.destroy() is called - note that you may need to do this from a different thread.