package org.deeplearning4j.spark.util;

import akka.actor.ActorSystem;
import akka.serialization.Serialization;
import akka.serialization.SerializationExtension;
import akka.serialization.Serializer;

/**
 *
 * Test serialization
 *
 * @author Adam Gibson
 */
public class SerializationTester {


    /**
     * Testing akka serialization
     * @param system the system to test on
     * @param test the object to test
     */
    public static void testSerialization(ActorSystem system,Object test) throws Exception {
        // Get the Serialization Extension
        Serialization serialization = SerializationExtension.get(system);


        // Find the Serializer for it
        Serializer serializer = serialization.findSerializerFor(system);
        serializer.toBinary(test);


    }

    /**
     * Test serialization
     * @param test the object to test
     */
    public static void testSerialization(Object test) {
        ActorSystem as = ActorSystem.create("testserde");
        try {
            testSerialization(as, test);
        } catch (Exception e) {
            e.printStackTrace();
        }
        finally {
            as.shutdown();
        }
    }



}

@@ -630,18 +630,16 @@
 ystem);%0A
-%0A%0A
         
@@ -732,22 +732,20 @@
 izerFor(
-system
+test
 );%0A     

add serialization test for spark