| Package | Description |
|---|---|
| org.eclipse.ditto.services.connectivity.mapping |
The mapping package contains the mapping functionality of mapping between arbitrary messages and Ditto Protocol and
back.
|
| org.eclipse.ditto.services.connectivity.mapping.javascript |
JavaScript based mapping implementation using the Rhino JavaScript engine.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractMessageMapper
Abstract implementation of
MessageMapper which adds an id field and also its initialization from mapping
configuration (id is not passed as constructor argument because the mappers are created by reflection). |
class |
ConnectionStatusMessageMapper
This mapper extracts the headers
creation-time and ttd from the message and builds a
ModifyFeature command from it. |
class |
DittoMessageMapper
A message mapper implementation for the Ditto Protocol.
|
class |
NormalizedMessageMapper
A message mapper implementation for normalized changes.
|
| Modifier and Type | Method and Description |
|---|---|
MessageMapper |
MessageMapperExtension.apply(org.eclipse.ditto.model.connectivity.ConnectionId connectionId,
MessageMapper mapper,
akka.actor.ExtendedActorSystem actorSystem)
Instantiates a message mapper.
|
MessageMapper |
MessageMapperRegistry.getDefaultMapper()
Returns a mapper with the supposed role of a fallback mapping strategy.
|
MessageMapper |
DefaultMessageMapperRegistry.getDefaultMapper() |
| Modifier and Type | Method and Description |
|---|---|
List<MessageMapper> |
MessageMapperRegistry.getMappers(org.eclipse.ditto.model.connectivity.PayloadMapping payloadMapping)
Returns the
MessageMappers to use for mapping. |
List<MessageMapper> |
DefaultMessageMapperRegistry.getMappers(org.eclipse.ditto.model.connectivity.PayloadMapping payloadMapping) |
Optional<MessageMapper> |
DefaultMessageMapperFactory.mapperOf(String mapperId,
org.eclipse.ditto.model.connectivity.MappingContext mappingContext) |
Optional<MessageMapper> |
MessageMapperFactory.mapperOf(String mapperId,
org.eclipse.ditto.model.connectivity.MappingContext context)
Creates an configures a
MessageMapper instance of
the given context. |
| Modifier and Type | Method and Description |
|---|---|
MessageMapper |
MessageMapperExtension.apply(org.eclipse.ditto.model.connectivity.ConnectionId connectionId,
MessageMapper mapper,
akka.actor.ExtendedActorSystem actorSystem)
Instantiates a message mapper.
|
static DefaultMessageMapperRegistry |
DefaultMessageMapperRegistry.of(MessageMapper defaultMapper,
Map<String,MessageMapper> customMappers,
Map<String,MessageMapper> fallbackMappers)
Creates a new instance of
DefaultMessageMapperRegistry of the parameter values. |
| Modifier and Type | Method and Description |
|---|---|
static DefaultMessageMapperRegistry |
DefaultMessageMapperRegistry.of(MessageMapper defaultMapper,
Map<String,MessageMapper> customMappers,
Map<String,MessageMapper> fallbackMappers)
Creates a new instance of
DefaultMessageMapperRegistry of the parameter values. |
static DefaultMessageMapperRegistry |
DefaultMessageMapperRegistry.of(MessageMapper defaultMapper,
Map<String,MessageMapper> customMappers,
Map<String,MessageMapper> fallbackMappers)
Creates a new instance of
DefaultMessageMapperRegistry of the parameter values. |
| Modifier and Type | Method and Description |
|---|---|
static MessageMapper |
JavaScriptMessageMapperFactory.createJavaScriptMessageMapperRhino()
Creates a new JavaScript MessageMapper based on the Rhino engine.
|
Copyright © 2017–2019 Eclipse Foundation. All rights reserved.