org.eclipse.ditto.services.connectivity.mapping

Class DefaultMessageMapperFactory

java.lang.Object

org.eclipse.ditto.services.connectivity.mapping.DefaultMessageMapperFactory

All Implemented Interfaces:

MessageMapperFactory

@Immutable
public final class DefaultMessageMapperFactory
extends Object
implements MessageMapperFactory

Encapsulates responsibility for instantiating MessageMapper objects.

As the message mapper instantiation is usually triggered by an actor, there are only limited possibilities of logging fine grained errors and at the same time keep all responsibility for mapper instantiation behavior away of the actor.

Due to this, the factory can be instantiated with a reference to the actors log adapter and will log problems to the debug and warning level (no info and error). Setting a log adapter does not change factory behaviour!

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
Optional<MessageMapper>	mapperOf(String mapperId, org.eclipse.ditto.model.connectivity.MappingContext mappingContext) Creates an configures a MessageMapper instance of the given context.
static DefaultMessageMapperFactory	of(org.eclipse.ditto.model.connectivity.ConnectionId connectionId, akka.actor.ActorSystem actorSystem, MappingConfig mappingConfig, akka.event.LoggingAdapter log) Creates a new factory and returns the instance
MessageMapperRegistry	registryOf(org.eclipse.ditto.model.connectivity.MappingContext defaultContext, org.eclipse.ditto.model.connectivity.PayloadMappingDefinition payloadMappingDefinition) Creates a MessageMapperRegistry.

Methods inherited from class java.lang.Object

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

Method Detail

of

public static DefaultMessageMapperFactory of(org.eclipse.ditto.model.connectivity.ConnectionId connectionId,
                                             akka.actor.ActorSystem actorSystem,
                                             MappingConfig mappingConfig,
                                             akka.event.LoggingAdapter log)

Creates a new factory and returns the instance

Parameters:

connectionId - ID of the connection.

actorSystem - the actor system to use for mapping config + dynamicAccess.

mappingConfig - the configuration of the mapping behaviour.

log - the log adapter used for debug and warning logs.

Returns:

the new instance.

Throws:

NullPointerException - if any argument is null.

mapperOf

public Optional<MessageMapper> mapperOf(String mapperId,
                                        org.eclipse.ditto.model.connectivity.MappingContext mappingContext)

Description copied from interface: MessageMapperFactory

Creates an configures a MessageMapper instance of the given context. It is possible, that there is no mapper available for a specific context.

Specified by:

mapperOf in interface MessageMapperFactory

Parameters:

mapperId - the id of this mapper

mappingContext - the mapping context containing the type and configuration of the mapper

Returns:

the mapper

registryOf

public MessageMapperRegistry registryOf(org.eclipse.ditto.model.connectivity.MappingContext defaultContext,
                                        org.eclipse.ditto.model.connectivity.PayloadMappingDefinition payloadMappingDefinition)

Description copied from interface: MessageMapperFactory

Creates a MessageMapperRegistry. Mappers that are not available will not be added to the registry.

Specified by:

registryOf in interface MessageMapperFactory

Parameters:

defaultContext - the context used to instantiate the default mapper

payloadMappingDefinition - the mapping definitions used to instantiate the registry mapper

Returns:

the registry

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object