MessageSerializer.java
50079dc163e1SHCS_url

MessageSerializer.java
View Options

			package utils;

			import java.io.ByteArrayInputStream;
			import java.io.ByteArrayOutputStream;
			import java.io.IOException;
			import java.io.ObjectInputStream;
			import java.io.ObjectOutputStream;
			import java.util.logging.Level;
			import java.util.logging.Logger;

			import framework.reply.ReplyDecryption;
			import framework.request.RequestDecryption;

			public class MessageSerializer {

			private static final Logger LOGGER = Logger.getLogger(MessageSerializer.class.getName());

			private static byte[] serialize(Object obj) throws IOException {
			ByteArrayOutputStream baos = new ByteArrayOutputStream();
			ObjectOutputStream oos = new ObjectOutputStream(baos);

			oos.writeObject(obj);
			return baos.toByteArray();
			}

			private static Object deserialize(byte[] bytes) throws IOException {
			ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
			ObjectInputStream ois = new ObjectInputStream(bais);

			Object object = null;
			try {
			object = ois.readObject();
			} catch (ClassNotFoundException e) {
			LOGGER.log(Level.SEVERE, null, e);
			}

			return object;
			}

			public static byte[] serializeRequest(RequestDecryption request) throws IOException {
			return serialize(request);
			}

			public static RequestDecryption deserializeRequestDecryption(byte[] array) throws IOException {
			return (RequestDecryption) deserialize(array);
			}


			public static byte[] serializeReply(ReplyDecryption reply) throws IOException {
			return serialize(reply);
			}

			public static ReplyDecryption deserializeReplyDecryption(byte[] array) throws IOException {
			return (ReplyDecryption) deserialize(array);
			}

			}