[rules-users] Drools and serialize

[clement.pernot]

Thank you for all your tips.

I think I have found the solution. (the project run)
Now for test that, I try to make a project who can un-serialize this.

There it is:

package com.sample;

import java.io.FileOutputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.Serializable;

import org.drools.KnowledgeBase;
import org.drools.KnowledgeBaseFactory;
import org.drools.builder.KnowledgeBuilder;
import org.drools.builder.KnowledgeBuilderError;
import org.drools.builder.KnowledgeBuilderErrors;
import org.drools.builder.KnowledgeBuilderFactory;
import org.drools.builder.ResourceType;
import org.drools.io.ResourceFactory;
import org.drools.marshalling.Marshaller;
import org.drools.marshalling.MarshallerFactory;
import org.drools.marshalling.ObjectMarshallingStrategy;
import org.drools.runtime.StatefulKnowledgeSession;


/**
 * This is a sample class to launch a rule.
 */
public class test{

	 private static void compileRuleBase2( String drlPath, String rbPath )
throws Exception {
	        KnowledgeBuilder kBuilder =
KnowledgeBuilderFactory.newKnowledgeBuilder();
	        kBuilder.add( ResourceFactory.newFileResource( drlPath ),
ResourceType.DRL );
	        if( kBuilder.hasErrors() ){
	            for( KnowledgeBuilderError err: kBuilder.getErrors() ){
	                System.err.println( err.toString() );
	            }
	            throw new IllegalStateException( "DRL errors" );
	        }
	        KnowledgeBase kBase = KnowledgeBaseFactory.newKnowledgeBase(); 
	        kBase.addKnowledgePackages( kBuilder.getKnowledgePackages() );
	        
	        try {
			// load up the knowledge base
			KnowledgeBase kbase = readKnowledgeBase();
			StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
	
			// go !
			Message message = new Message();
			message.setMessage("Hello World");
			message.setStatus(Message.HELLO);
			
			ksession.insert(message);
			
		 	ObjectMarshallingStrategy oms =
MarshallerFactory.newIdentityMarshallingStrategy();
	        Marshaller marshaller = MarshallerFactory.newMarshaller(
ksession.getKnowledgeBase(), new ObjectMarshallingStrategy[]{ oms } );

		    OutputStream os = new FileOutputStream( rbPath );
		    ObjectOutputStream oos = new ObjectOutputStream( os );
			marshaller.marshall( os, ksession );
			  
	        oos.close();
	
			ksession.fireAllRules();

			
		} catch (Throwable t) {
			t.printStackTrace();
		}
	        

	    }
	
	public static final void main(String[] args) {
		try{
			compileRuleBase2("Sample.drl", "drools_compiled_file_with_fact" );
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	private static KnowledgeBase readKnowledgeBase() throws Exception {
		KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
		 
		kbuilder.add(ResourceFactory.newClassPathResource("Sample.drl"),
ResourceType.DRL);
		KnowledgeBuilderErrors errors = kbuilder.getErrors();
		if (errors.size() > 0) {
			for (KnowledgeBuilderError error: errors) {
				System.err.println(error);
			}
			throw new IllegalArgumentException("Could not parse knowledge.");
		}
		KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
		kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
		return kbase;
	}

	public static class Message implements Serializable{
		
		public static final int HELLO = 0;
		public static final int GOODBYE = 1;

		private String message;

		private int status;

		public String getMessage() {
			return this.message;
		}

		public void setMessage(String message) {
			this.message = message;
		}

		public int getStatus() {
			return this.status;
		}

		public void setStatus(int status) {
			this.status = status;
		}
		
	}

}

--
View this message in context: http://drools.46999.n3.nabble.com/Drools-and-serialize-tp3161882p3162316.html
Sent from the Drools: User forum mailing list archive at Nabble.com.