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

Class ClusterDistributedObject<T>

java.lang.Object

com.mulesoft.mule.runtime.module.cluster.internal.serialization.ClusterDistributedObject<T>

Type Parameters:

T - the type of the distributed value

All Implemented Interfaces:

Serializable

public final class ClusterDistributedObject<T>
extends Object
implements Serializable

A wrapper object to link a value which is going to be distributed in the cluster with the ObjectSerializer that should be use to share it.

This class allows to switch between the serialized/deserialized representations of such value through the serialize() and deserialize(SerializationProtocol) methods. Notice however, that this is an immutable object so each of those methods will return a new instance.

Instances of this class are to be created through the forSerializedValue(byte[]) and forValue(Object, SerializationProtocol) factory methods.

Since:

3.7.0

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
static <T> ClusterDistributedObject<T>	createSerializedForValue(T value, org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol) Creates an instance for the given serialized with serializationProtocol
ClusterDistributedObject	deserialize(org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol) Creates a new instance of ClusterDistributedObject holding a deserialized representation of the distributedValue
static <T> ClusterDistributedObject<T>	forSerializedValue(byte[] bytes) Create an instance from the given serialized bytes
static <T> ClusterDistributedObject<T>	forValue(T value, org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol) Creates an instance for the given which should be serialized with serializationProtocol
Object	getValue() Returns the value on its current representation.
DistributedValue	serialize() Creates a new instance of DistributedValue holding a serialized representation of its value
void	setSerializationProtocol(org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol)

Methods inherited from class java.lang.Object

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

Method Detail

forValue

public static <T> ClusterDistributedObject<T> forValue(T value,
                                                       org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol)

Creates an instance for the given which should be serialized with serializationProtocol

Parameters:

value - the value to distribute

serializationProtocol - the SerializationProtocol to use with serialize()

Returns:

a new ClusterDistributedObject

forSerializedValue

public static <T> ClusterDistributedObject<T> forSerializedValue(byte[] bytes)

Create an instance from the given serialized bytes

Parameters:

bytes - the bytes of a serialized value

Returns:

a new ClusterDistributedObject

createSerializedForValue

public static <T> ClusterDistributedObject<T> createSerializedForValue(T value,
                                                                       org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol)

Creates an instance for the given serialized with serializationProtocol

Parameters:

value - the value to distribute

serializationProtocol - the SerializationProtocol to use with serialize()

Returns:

a new ClusterDistributedObject

serialize

public DistributedValue serialize()

Creates a new instance of DistributedValue holding a serialized representation of its value

Returns:

a new DistributedValue

deserialize

public ClusterDistributedObject deserialize(org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol)

Creates a new instance of ClusterDistributedObject holding a deserialized representation of the distributedValue

Parameters:

serializationProtocol - the ObjectSerializer to be used for deserializing

Returns:

a new ObjectSerializer

getValue

public Object getValue()

Returns the value on its current representation. Could be the value itself or a serialized byte[]

Returns:

an actual value or a byte[]

setSerializationProtocol

public void setSerializationProtocol(org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol)