cloud.orbit.actors.runtime

Class JavaMessageSerializer

java.lang.Object

cloud.orbit.actors.runtime.JavaMessageSerializer

All Implemented Interfaces:

ActorExtension, MessageSerializer, Startable

Direct Known Subclasses:

JavaSerializationCloner

public class JavaMessageSerializer
extends Object
implements MessageSerializer

A message serializer that uses java serialization.

Constructor Summary

Constructors

Constructor and Description
JavaMessageSerializer()

Method Summary

Modifier and Type	Method and Description
protected ObjectInput	createObjectInput(BasicRuntime runtime, InputStream in)
protected ObjectOutput	createObjectOutput(BasicRuntime runtime, OutputStream outputStream)
Message	deserializeMessage(BasicRuntime runtime, InputStream inputStream)
void	serializeMessage(BasicRuntime runtime, OutputStream outputStream, Message message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cloud.orbit.lifecycle.Startable

start, stop

Constructor Detail

JavaMessageSerializer

public JavaMessageSerializer()

Method Detail

deserializeMessage

public Message deserializeMessage(BasicRuntime runtime,
                                  InputStream inputStream)
                           throws Exception

Specified by:

deserializeMessage in interface MessageSerializer

Throws:

Exception

serializeMessage

public void serializeMessage(BasicRuntime runtime,
                             OutputStream outputStream,
                             Message message)
                      throws Exception

Specified by:

serializeMessage in interface MessageSerializer

Throws:

Exception

createObjectOutput

protected ObjectOutput createObjectOutput(BasicRuntime runtime,
                                          OutputStream outputStream)
                                   throws IOException

Throws:

IOException

createObjectInput

protected ObjectInput createObjectInput(BasicRuntime runtime,
                                        InputStream in)
                                 throws IOException

Throws:

IOException