org.eclipse.ditto.services.connectivity.mapping

Class NormalizedMessageMapper

java.lang.Object

org.eclipse.ditto.services.connectivity.mapping.AbstractMessageMapper

org.eclipse.ditto.services.connectivity.mapping.NormalizedMessageMapper

All Implemented Interfaces:

MessageMapper

public final class NormalizedMessageMapper
extends AbstractMessageMapper

A message mapper implementation for normalized changes. Create- and modify-events are mapped to nested sparse JSON. All other signals and incoming messages are dropped.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELDS Config property to project parts from the mapping result.

Constructor Summary

Constructors

Constructor and Description
NormalizedMessageMapper()

Method Summary

Modifier and Type	Method and Description
void	doConfigure(MappingConfig mappingConfig, MessageMapperConfiguration configuration) Applies the mapper specific configuration.
String	getId() Returns a unique ID of this mapper that can be used in sources and targets to reference this mapper.
List<ExternalMessage>	map(org.eclipse.ditto.protocoladapter.Adaptable adaptable) Maps an Adaptable to an ExternalMessage
List<org.eclipse.ditto.protocoladapter.Adaptable>	map(ExternalMessage message) Maps an ExternalMessage to an Adaptable

Methods inherited from class org.eclipse.ditto.services.connectivity.mapping.AbstractMessageMapper

configure, getContentTypeBlacklist

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.ditto.services.connectivity.mapping.MessageMapper

findContentType, findContentType, getDefaultOptions

Field Detail

FIELDS

public static final String FIELDS

Config property to project parts from the mapping result.

See Also:

Constant Field Values

Constructor Detail

NormalizedMessageMapper

public NormalizedMessageMapper()

Method Detail

getId

public String getId()

Description copied from interface: MessageMapper

Returns a unique ID of this mapper that can be used in sources and targets to reference this mapper.

Specified by:

getId in interface MessageMapper

Overrides:

getId in class AbstractMessageMapper

Returns:

a unique ID of this mapper.

doConfigure

public void doConfigure(MappingConfig mappingConfig,
                        MessageMapperConfiguration configuration)

Description copied from class: AbstractMessageMapper

Applies the mapper specific configuration.

Overrides:

doConfigure in class AbstractMessageMapper

Parameters:

mappingConfig - the service configuration for the mapping.

configuration - the mapper specific configuration configured in scope of a single connection.

map

public List<org.eclipse.ditto.protocoladapter.Adaptable> map(ExternalMessage message)

Description copied from interface: MessageMapper

Maps an ExternalMessage to an Adaptable

Parameters:

message - the ExternalMessage to map

Returns:

the mapped Adaptable or an empty List if the ExternalMessage should not be mapped after all

map

public List<ExternalMessage> map(org.eclipse.ditto.protocoladapter.Adaptable adaptable)

Description copied from interface: MessageMapper

Maps an Adaptable to an ExternalMessage

Parameters:

adaptable - the Adaptable to map

Returns:

the ExternalMessage or an empty List if the Adaptable should not be mapped after all