[jboss-svn-commits] JBL Code SVN: r18735 - labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common.

[jboss-svn-commits at lists.jboss.org]

Author: mingjin
Date: 2008-03-06 11:58:54 -0500 (Thu, 06 Mar 2008)
New Revision: 18735

Modified:
   labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common/DroolsObjectInputStream.java
   labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common/DroolsObjectOutputStream.java
Log:
fine tuning.

Modified: labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common/DroolsObjectInputStream.java
===================================================================
--- labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common/DroolsObjectInputStream.java	2008-03-06 16:47:35 UTC (rev 18734)
+++ labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common/DroolsObjectInputStream.java	2008-03-06 16:58:54 UTC (rev 18735)
@@ -136,6 +136,7 @@
         dataInput    = new DroolsInternalInputStream(inputStream, classLoader);
         setClassLoader(classLoader);
         extractorFactory = ClassFieldExtractorCache.getInstance();
+        readStreamHeader();
     }
 
     public DroolsObjectInputStream(ObjectInput inputStream) throws IOException {

Modified: labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common/DroolsObjectOutputStream.java
===================================================================
--- labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common/DroolsObjectOutputStream.java	2008-03-06 16:47:35 UTC (rev 18734)
+++ labs/jbossrules/branches/ming-serialization/drools-core/src/main/java/org/drools/common/DroolsObjectOutputStream.java	2008-03-06 16:58:54 UTC (rev 18735)
@@ -28,7 +28,7 @@
     }
     public DroolsObjectOutputStream(ObjectOutput dataOutput) throws IOException {
         this.dataOutput   = dataOutput;
-//        writeStreamHeader();
+        writeStreamHeader();
     }
 
     private void writeNull() throws IOException {
@@ -58,7 +58,7 @@
         } else if (clazz.isArray()) {
             writeArray(object, clazz, handle);
         } else if (Serializable.class.isAssignableFrom(clazz)) {
-            writeSerializable((Serializable) object, clazz, handle);
+            writeSerializable((Serializable) object, handle);
         } else {
             throw new NotSerializableException("Unsupported class: " + clazz);
         }
@@ -200,7 +200,7 @@
         externalizable.writeExternal(this);
     }
 
-    private void writeSerializable(Serializable serializable, Class clazz, int handle) throws IOException {
+    private void writeSerializable(Serializable serializable, int handle) throws IOException {
         writeRecordType(RT_SERIALIZABLE);
         writeHandle(handle);
         dataOutput.writeObject(serializable);