com.mulesoft.mule.runtime.module.cluster.internal.serialization

Class ClusterDistributedObjectSerializer

java.lang.Object

com.mulesoft.mule.runtime.module.cluster.internal.serialization.ClusterDistributedObjectSerializer

All Implemented Interfaces:

com.hazelcast.nio.serialization.Serializer, com.hazelcast.nio.serialization.StreamSerializer<ClusterDistributedObject<Object>>

public final class ClusterDistributedObjectSerializer
extends Object
implements com.hazelcast.nio.serialization.StreamSerializer<ClusterDistributedObject<Object>>

A custom StreamSerializer to handle instances of ClusterDistributedObject

It receives and returns instances of ClusterDistributedObject although it actually writes instances of DistributedValue, this allows each application to use its own ObjectSerializer although this instance is shared across all of them

Since:

3.7.0

Constructor Summary

Constructors

Constructor and Description
ClusterDistributedObjectSerializer()

Method Summary

Modifier and Type	Method and Description
static void	configureInto(com.hazelcast.client.config.ClientConfig hzClientConfig)
static void	configureInto(com.hazelcast.config.Config hazelcastConfig) Registers this StreamSerializer into the given hazelcastConfig
void	destroy()
int	getTypeId()
ClusterDistributedObject<Object>	read(com.hazelcast.nio.ObjectDataInput in) Reads a DistributedValue and returns it as a ClusterDistributedObject
void	write(com.hazelcast.nio.ObjectDataOutput out, ClusterDistributedObject object) Writes the DistributedValue which results of invoking ClusterDistributedObject.serialize() on object

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterDistributedObjectSerializer

public ClusterDistributedObjectSerializer()

Method Detail

configureInto

public static void configureInto(com.hazelcast.config.Config hazelcastConfig)

Registers this StreamSerializer into the given hazelcastConfig

Parameters:

hazelcastConfig - the Config of the HazelcastInstance in which this serializer lives

configureInto

public static void configureInto(com.hazelcast.client.config.ClientConfig hzClientConfig)

write

public void write(com.hazelcast.nio.ObjectDataOutput out,
                  ClusterDistributedObject object)
           throws IOException

Writes the DistributedValue which results of invoking ClusterDistributedObject.serialize() on object

Specified by:

write in interface com.hazelcast.nio.serialization.StreamSerializer<ClusterDistributedObject<Object>>

Throws:

IOException

read

public ClusterDistributedObject<Object> read(com.hazelcast.nio.ObjectDataInput in)
                                      throws IOException

Reads a DistributedValue and returns it as a ClusterDistributedObject

Specified by:

read in interface com.hazelcast.nio.serialization.StreamSerializer<ClusterDistributedObject<Object>>

Throws:

IOException

getTypeId

public int getTypeId()

Specified by:

getTypeId in interface com.hazelcast.nio.serialization.Serializer

destroy

public void destroy()

Specified by:

destroy in interface com.hazelcast.nio.serialization.Serializer