Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add SDK functionality to make it easier to deserialize/consume EventGrid events #2426

Merged
merged 7 commits into from
Sep 27, 2018
Merged

Add SDK functionality to make it easier to deserialize/consume EventGrid events #2426

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
d5ea61e
Adding support for deserialize/conusme (custom) eventgrid events
anuchandy Sep 25, 2018
3d44634
Tests for deserialize/conusme (custom) eventgrid events utility (Even…
anuchandy Sep 25, 2018
e677125
Adding beta annotation for EventGridSubscriber and associated types, …
anuchandy Sep 25, 2018
902e748
Merge branch 'master' of github.com:azure/azure-sdk-for-java into eve…
anuchandy Sep 27, 2018
613a617
Simplifying code using canonicalizeEventType(String), improved custom…
anuchandy Sep 27, 2018
42e2c97
Adding tests for new IoT [Connected|Disconnected] & resource [Action*…
anuchandy Sep 27, 2018
8b21ddc
Rename getAllCustomEventMapping() -> getAllCustomEventMappings(), add…
anuchandy Sep 27, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
110 changes: 66 additions & 44 deletions ...-plane/src/main/java/com/microsoft/azure/eventgrid/customization/EventGridSubscriber.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
*/
package com.microsoft.azure.eventgrid.customization;


import com.fasterxml.jackson.databind.ObjectMapper;
import com.microsoft.azure.eventgrid.models.EventGridEvent;
import com.microsoft.azure.management.apigeneration.Beta;
Expand All @@ -15,23 +14,28 @@
import java.io.IOException;
import java.lang.reflect.Field;
import java.lang.reflect.Type;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;

/**
* The type that can be used to de-serialize events.
*/
@Beta
public class EventGridSubscriber {
/**
* The default adapter for to be used for de-serializing the events
* The default adapter to be used for de-serializing the events.
*/
private final AzureJacksonAdapter defaultSerializerAdapter;
/**
* The map containing user defined mapping of eventType to Java model type
* The map containing user defined mapping of eventType to Java model type.
*/
private Map<String, Type> eventTypeToEventDataMapping;

/**
* Creates EventGridSubscriber with default de-serializer.
*/
@Beta
public EventGridSubscriber() {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should we add a method to list all custom event mappings (similar to what we have in https://raw.githubusercontent.com/Azure/azure-sdk-for-net/psSdkJson6/src/SDKs/EventGrid/DataPlane/Microsoft.Azure.EventGrid/Customization/EventGridSubscriber.cs)

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

good catch, will add it.

this.defaultSerializerAdapter = new AzureJacksonAdapter();
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

If the Data property contains polymorphic types, will this handle that as well, or do we need some special logic for it? In the C# case, we do something like:

       // Note: If any of the events have polymorphic data, add converters for them here.
        // This enables the polymorphic deserialization for the event data.
        // For example, MediaJobCompletedEventData's JobOutput type is polymorphic 
        // based on the @odata.type property in the data.

        // Example usage: jsonSerializer.Converters.Add(new PolymorphicDeserializeJsonConverter<JobOutput>("@odata.type"));

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looking at the tests, I do see you are supporting this, which is great! However, it wasn't quite clear to me whether this is handled automatically, or whether like in C# we need to express something like the above where we add the PolymorphicDeserializeJsonConverter explicitly.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

De-serialization of polymorphic types are handled using Jackson annotations. See this models

azure-sdk-for-java/eventgrid/data-plane/src/test/java/com/microsoft/azure/eventgrid/customization/models/ShippingInfo.java

Line 15 in e677125

@JsonSubTypes({

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I see, thanks. For 1st party / system event data that contains polymorphic fields, will we have to annotate in the same way (on top of the default autorest generated class)?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

For system events - if discriminator is defined in swagger for corresponding event models then auto rest will generate these annotations, no need to modify the generated models.

For custom events - User has to annotate their model as shown in the tests.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

sounds good, thanks!

Expand All @@ -40,114 +44,124 @@ public EventGridSubscriber() {

/**
* Add a custom event mapping. If a mapping with same eventType exists then the old eventDataType is replaced by
* the specified eventDataType
* the specified eventDataType.
*
* @param eventType the event type name
* @param eventDataType type of the Java model that the event type name mapped to
* @param eventType the event type name.
* @param eventDataType type of the Java model that the event type name mapped to.
*/
@Beta
public void putCustomEventMapping(String eventType, Type eventDataType) {
public void putCustomEventMapping(final String eventType, final Type eventDataType) {
if (eventType == null || eventType.isEmpty()) {
throw new IllegalArgumentException("eventType parameter is required and cannot be null or empty");
}
if (eventDataType == null) {
throw new IllegalArgumentException("eventDataType parameter is required and cannot be null");
}
this.eventTypeToEventDataMapping.put(eventType.toLowerCase(), eventDataType);
this.eventTypeToEventDataMapping.put(canonicalizeEventType(eventType), eventDataType);
}

/**
* Get type of the Java model that is mapped to the given eventType.
*
* @param eventType the event type name
* @return type of the Java model id mapping exists, null otherwise
* @param eventType the event type name.
* @return type of the Java model if mapping exists, null otherwise.
*/
@Beta
public Type getCustomEventMapping(String eventType) {
if (eventType == null || eventType.isEmpty()) {
throw new IllegalArgumentException("eventType parameter is required and cannot be null or empty");
}
if (!this.eventTypeToEventDataMapping.containsKey(eventType.toLowerCase())) {
public Type getCustomEventMapping(final String eventType) {
if (!containsCustomEventMappingFor(eventType)) {
return null;
} else {
return this.eventTypeToEventDataMapping.get(canonicalizeEventType(eventType));
}
return this.eventTypeToEventDataMapping.get(eventType.toLowerCase());
}

/**
* @return get all registered custom event mappings.
*/
@Beta
public Set<Map.Entry<String, Type>> getAllCustomEventMapping() {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nit: Should this have a "s" at the end to denote the plurality (getAllCustomEventMappings())?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

thanks for catching the typo, will fix it.

return Collections.unmodifiableSet(this.eventTypeToEventDataMapping.entrySet());
}

/**
* Removes the mapping with the given eventType.
*
* @param eventType the event type name
* @return true if the mapping exists and removed, false if mapping does not exists
* @param eventType the event type name.
* @return true if the mapping exists and removed, false if mapping does not exists.
*/
@Beta
public boolean removeCustomEventMapping(String eventType) {
if (eventType == null || eventType.isEmpty()) {
throw new IllegalArgumentException("eventType parameter is required and cannot be null or empty");
}
if (!this.eventTypeToEventDataMapping.containsKey(eventType.toLowerCase())) {
public boolean removeCustomEventMapping(final String eventType) {
if (!containsCustomEventMappingFor(eventType)) {
return false;
} else {
this.eventTypeToEventDataMapping.remove(canonicalizeEventType(eventType));
return true;
}
this.eventTypeToEventDataMapping.remove(eventType.toLowerCase());
return true;
}

/**
* Checks an event mapping with the given eventType exists.
* Checks if an event mapping with the given eventType exists.
*
* @param eventType the event type name
* @return true if the mapping exists, false otherwise
* @param eventType the event type name.
* @return true if the mapping exists, false otherwise.
*/
@Beta
public boolean containsEventMappingFor(String eventType) {
public boolean containsCustomEventMappingFor(final String eventType) {
if (eventType == null || eventType.isEmpty()) {
throw new IllegalArgumentException("eventType parameter is required and cannot be null or empty");
return false;
} else {
return this.eventTypeToEventDataMapping.containsKey(canonicalizeEventType(eventType));
}
return this.eventTypeToEventDataMapping.containsKey(eventType.toLowerCase());
}

/**
* De-serialize the events in the given requested content using default de-serializer.
*
* @param requestContent the request content in string format
* @param requestContent the request content in string format.
* @return De-serialized events.
*
* @throws IOException
*/
@Beta
public EventGridEvent[] DeserializeEventGridEvents(final String requestContent) throws IOException {
return this.DeserializeEventGridEvents(requestContent, this.defaultSerializerAdapter);
public EventGridEvent[] deserializeEventGridEvents(final String requestContent) throws IOException {
return this.deserializeEventGridEvents(requestContent, this.defaultSerializerAdapter);
}

/**
* De-serialize the events in the given requested content using the provided de-serializer.
*
* @param requestContent the request content in string format
* @param serializerAdapter the de-serializer
* @return e-serialized events.
* @param requestContent the request content as string.
* @param serializerAdapter the de-serializer.
* @return de-serialized events.
* @throws IOException
*/
@Beta
public EventGridEvent[] DeserializeEventGridEvents(final String requestContent, final SerializerAdapter<ObjectMapper> serializerAdapter) throws IOException {
public EventGridEvent[] deserializeEventGridEvents(final String requestContent, final SerializerAdapter<ObjectMapper> serializerAdapter) throws IOException {
EventGridEvent[] eventGridEvents = serializerAdapter.<EventGridEvent[]>deserialize(requestContent, EventGridEvent[].class);
for (EventGridEvent receivedEvent : eventGridEvents) {
if (receivedEvent.data() == null) {
continue;
} else {
final String dataStr = serializerAdapter.serializeRaw(receivedEvent.data());
final String eventType = receivedEvent.eventType();
final Type eventDataType;
if (SystemEventTypeMappings.containsMappingFor(eventType)) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nit: can we do something like if (SystemEventTypeMappings.containsMappingFor(eventType) { eventDataType = SystemEventTypeMappings.getMapping(EventType) } else { eventDataType = getCustomEventMapping(eventType);} and then actually call deserialize & setEventData just once outside the if/else block.

Copy link
Contributor

@kalyanaj kalyanaj Sep 26, 2018 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

For custom events, the Data property can be of any type (i.e. object, array, or any other primitive type), so we would need some special handling for it. For C#, the way we handle it is covered in 185-207 of https://github.com/Azure/azure-sdk-for-net/blob/psSdkJson6/src/SDKs/EventGrid/DataPlane/Microsoft.Azure.EventGrid/Customization/EventGridSubscriber.cs. Not sure if the current logic automatically handles that case as well, wanted to double-check.

Copy link
Member Author

@anuchandy anuchandy Sep 27, 2018 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

  1. sounds good, will update the code as suggested.
  2. yes, no special handing required for primitives and arrays. we do have tests covering these scenarios.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The primitive and array tests are:

azure-sdk-for-java/eventgrid/data-plane/src/test/java/com/microsoft/azure/eventgrid/customization/CustomizationTests.java

Line 77 in 42e2c97

public void consumeCustomEventWithArrayData() throws IOException {

azure-sdk-for-java/eventgrid/data-plane/src/test/java/com/microsoft/azure/eventgrid/customization/CustomizationTests.java

Line 95 in 42e2c97

public void consumeCustomEventWithBooleanData() throws IOException {

final Object eventData = serializerAdapter.<Object>deserialize(dataStr, SystemEventTypeMappings.getMapping(eventType));
setEventData(receivedEvent, eventData);
} else if (containsEventMappingFor(eventType)) {
final Object eventData = serializerAdapter.<Object>deserialize(dataStr, getCustomEventMapping(eventType));
eventDataType = SystemEventTypeMappings.getMapping(eventType);
} else if (containsCustomEventMappingFor(eventType)) {
eventDataType = getCustomEventMapping(eventType);
} else {
eventDataType = null;
}
if (eventDataType != null) {
final String eventDataAsString = serializerAdapter.serializeRaw(receivedEvent.data());
final Object eventData = serializerAdapter.<Object>deserialize(eventDataAsString, eventDataType);
setEventData(receivedEvent, eventData);
}
}
}
return eventGridEvents;
}

private void setEventData(EventGridEvent event, Object data) {
private static void setEventData(EventGridEvent event, final Object data) {
// This reflection based way to set the data field needs to be removed once
// we expose a wither in EventGridEvent to set the data. (Check swagger + codegen)
try {
Expand All @@ -160,4 +174,12 @@ private void setEventData(EventGridEvent event, Object data) {
throw new RuntimeException(iae);
}
}

private static String canonicalizeEventType(final String eventType) {
if (eventType == null) {
return null;
} else {
return eventType.toLowerCase();
}
}
}
100 changes: 66 additions & 34 deletions ...ne/src/main/java/com/microsoft/azure/eventgrid/customization/SystemEventTypeMappings.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,14 @@
import com.microsoft.azure.eventgrid.models.ContainerRegistryImageDeletedEventData;
import com.microsoft.azure.eventgrid.models.ContainerRegistryImagePushedEventData;
import com.microsoft.azure.eventgrid.models.EventHubCaptureFileCreatedEventData;
import com.microsoft.azure.eventgrid.models.IotHubDeviceConnectedEventData;
import com.microsoft.azure.eventgrid.models.IotHubDeviceCreatedEventData;
import com.microsoft.azure.eventgrid.models.IotHubDeviceDeletedEventData;
import com.microsoft.azure.eventgrid.models.IotHubDeviceDisconnectedEventData;
import com.microsoft.azure.eventgrid.models.MediaJobStateChangeEventData;
import com.microsoft.azure.eventgrid.models.ResourceActionCancelData;
import com.microsoft.azure.eventgrid.models.ResourceActionFailureData;
import com.microsoft.azure.eventgrid.models.ResourceActionSuccessData;
import com.microsoft.azure.eventgrid.models.ResourceDeleteCancelData;
import com.microsoft.azure.eventgrid.models.ResourceDeleteFailureData;
import com.microsoft.azure.eventgrid.models.ResourceDeleteSuccessData;
Expand All @@ -20,6 +26,8 @@
import com.microsoft.azure.eventgrid.models.ServiceBusDeadletterMessagesAvailableWithNoListenersEventData;
import com.microsoft.azure.eventgrid.models.StorageBlobCreatedEventData;
import com.microsoft.azure.eventgrid.models.StorageBlobDeletedEventData;
import com.microsoft.azure.eventgrid.models.SubscriptionDeletedEventData;
import com.microsoft.azure.eventgrid.models.SubscriptionValidationEventData;
import com.microsoft.azure.management.apigeneration.Beta;

import java.lang.reflect.Type;
Expand All @@ -38,58 +46,82 @@ final class SystemEventTypeMappings {

static {
systemEventMappings = new HashMap<>(); // key: eventType, Value:eventDataType
// ContainerRegistry events
systemEventMappings.put(SystemEventTypes.CONTAINER_REGISTRY_IMAGE_PUSHED_EVENT.toLowerCase(), ContainerRegistryImagePushedEventData.class);
systemEventMappings.put(SystemEventTypes.CONTAINER_REGISTRY_IMAGE_DELETED_EVENT.toLowerCase(), ContainerRegistryImageDeletedEventData.class);
// Device events
systemEventMappings.put(SystemEventTypes.IOT_HUB_DEVICE_CREATED_EVENT.toLowerCase(), IotHubDeviceCreatedEventData.class);
systemEventMappings.put(SystemEventTypes.IOT_HUB_DEVICE_DELETED_EVENT.toLowerCase(), IotHubDeviceDeletedEventData.class);
// EventGrid events
// TODO: Enable this once SDK is refreshed
// systemEventMappings.put(SystemEventTypes.EVENT_GRID_SUBSCRIPTION_VALIDATION_EVENT.toLowerCase(), SubscriptionValidationEventData.class);
// systemEventMappings.put(SystemEventTypes.EVENT_GRID_SUBSCRIPTION_DELETED_EVENT.toLowerCase(), SubscriptionDeletedEventData.class);
// Event Hub Events
systemEventMappings.put(SystemEventTypes.EVENT_HUB_CAPTURE_FILE_CREATED_EVENT.toLowerCase(), EventHubCaptureFileCreatedEventData.class);
// Media Services events
// TODO: Enable this once SDK is refreshed
// systemEventMappings.put(SystemEventTypes.MEDIA_JOB_STATE_CHANGE_EVENT.toLowerCase(), MediaJobStateChangeEventData.class);
// Resource Manager (Azure Subscription/Resource Group) events
systemEventMappings.put(SystemEventTypes.RESOURCE_WRITE_SUCCESS_EVENT.toLowerCase(), ResourceWriteSuccessData.class);
systemEventMappings.put(SystemEventTypes.RESOURCE_WRITE_FAILURE_EVENT.toLowerCase(), ResourceWriteFailureData.class);
systemEventMappings.put(SystemEventTypes.RESOURCE_WRITE_CANCEL_EVENT.toLowerCase(), ResourceWriteCancelData.class);
systemEventMappings.put(SystemEventTypes.RESOURCE_DELETE_SUCCESS_EVENT.toLowerCase(), ResourceDeleteSuccessData.class);
systemEventMappings.put(SystemEventTypes.RESOURCE_DELETE_FAILURE_EVENT.toLowerCase(), ResourceDeleteFailureData.class);
systemEventMappings.put(SystemEventTypes.RESOURCE_DELETE_CANCEL_EVENT.toLowerCase(), ResourceDeleteCancelData.class);
// ServiceBus events
systemEventMappings.put(SystemEventTypes.SERVICE_BUS_ACTIVE_MESSAGES_AVAILABLE_WITH_NO_LISTENERS_EVENT.toLowerCase(), ServiceBusActiveMessagesAvailableWithNoListenersEventData.class);
systemEventMappings.put(SystemEventTypes.SERVICE_BUS_DEADLETTER_MESSAGES_AVAILABLE_WITH_NO_LISTENER_EVENT.toLowerCase(), ServiceBusDeadletterMessagesAvailableWithNoListenersEventData.class);
// Storage events
systemEventMappings.put(SystemEventTypes.STORAGE_BLOB_CREATED_EVENT.toLowerCase(), StorageBlobCreatedEventData.class);
systemEventMappings.put(SystemEventTypes.STORAGE_BLOB_DELETED_EVENT.toLowerCase(), StorageBlobDeletedEventData.class);
//
// ContainerRegistry events.
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.CONTAINER_REGISTRY_IMAGE_PUSHED_EVENT), ContainerRegistryImagePushedEventData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.CONTAINER_REGISTRY_IMAGE_DELETED_EVENT), ContainerRegistryImageDeletedEventData.class);
//
// Device events.
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.IOT_HUB_DEVICE_CREATED_EVENT), IotHubDeviceCreatedEventData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.IOT_HUB_DEVICE_DELETED_EVENT), IotHubDeviceDeletedEventData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.IOT_HUB_DEVICE_CONNECTED_EVENT), IotHubDeviceConnectedEventData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.IOT_HUB_DEVICE_DISCONNECTED_EVENT), IotHubDeviceDisconnectedEventData.class);
//
// EventGrid events.
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.EVENT_GRID_SUBSCRIPTION_VALIDATION_EVENT), SubscriptionValidationEventData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.EVENT_GRID_SUBSCRIPTION_DELETED_EVENT), SubscriptionDeletedEventData.class);
//
// Event Hub Events.
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.EVENT_HUB_CAPTURE_FILE_CREATED_EVENT), EventHubCaptureFileCreatedEventData.class);
//
// Media Services events.
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.MEDIA_JOB_STATE_CHANGE_EVENT), MediaJobStateChangeEventData.class);
//
// Resource Manager (Azure Subscription/Resource Group) events.
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_WRITE_SUCCESS_EVENT), ResourceWriteSuccessData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_WRITE_FAILURE_EVENT), ResourceWriteFailureData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_WRITE_CANCEL_EVENT), ResourceWriteCancelData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_DELETE_SUCCESS_EVENT), ResourceDeleteSuccessData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_DELETE_FAILURE_EVENT), ResourceDeleteFailureData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_DELETE_CANCEL_EVENT), ResourceDeleteCancelData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_ACTION_SUCCESS_EVENT), ResourceActionSuccessData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_ACTION_FAILURE_EVENT), ResourceActionFailureData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.RESOURCE_ACTION_CANCEL_EVENT), ResourceActionCancelData.class);
//
// ServiceBus events.
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.SERVICE_BUS_ACTIVE_MESSAGES_AVAILABLE_WITH_NO_LISTENERS_EVENT), ServiceBusActiveMessagesAvailableWithNoListenersEventData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.SERVICE_BUS_DEADLETTER_MESSAGES_AVAILABLE_WITH_NO_LISTENER_EVENT), ServiceBusDeadletterMessagesAvailableWithNoListenersEventData.class);
//
// Storage events.
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.STORAGE_BLOB_CREATED_EVENT), StorageBlobCreatedEventData.class);
systemEventMappings.put(canonicalizeEventType(SystemEventTypes.STORAGE_BLOB_DELETED_EVENT), StorageBlobDeletedEventData.class);
}

/**
* Checks a mapping exists for the given type.
* Checks if a mapping exists for the given type.
*
* @param eventType the event type
* @param eventType the event type.
* @return true if mapping exists, false otherwise.
*/
@Beta
public static boolean containsMappingFor(final String eventType) {
return systemEventMappings.containsKey(eventType.toLowerCase());
if (eventType == null || eventType.isEmpty()) {
return false;
} else {
return systemEventMappings.containsKey(canonicalizeEventType(eventType));
}
}

/**
* Get Java model type for the given event type.
*
* @param eventType the event type
* @param eventType the event type.
* @return the Java model type if mapping exists, null otherwise.
*/
@Beta
public static Type getMapping(final String eventType) {
if (!systemEventMappings.containsKey(eventType.toLowerCase())) {
if (!containsMappingFor(eventType)) {
return null;
} else {
return systemEventMappings.get(canonicalizeEventType(eventType));
}
}

private static String canonicalizeEventType(final String eventType) {
if (eventType == null) {
return null;
} else {
return eventType.toLowerCase();
}
return systemEventMappings.get(eventType.toLowerCase());
}
}
Loading