package com.atlassian.messagequeue.internal.lifecycle;
   
   import org.codehaus.jackson.map.ObjectMapper;
   
   import java.io.IOException;
   import java.util.Optional;
   
   /**
    * {@inheritDoc}
   */
  public class JacksonNotificationDeserializer implements NotificationDeserializer {
      private final ObjectMapper objectMapper;
  
      public JacksonNotificationDeserializer() {
          objectMapper = new ObjectMapper();
      }
  
      @Override
      public <T> Optional<T> deserialize(String string, Class<T> notificationType) {
          if (string == null) {
              return Optional.empty();
          }
  
          try {
              return Optional.ofNullable(objectMapper.readValue(string, notificationType));
          } catch (IOException e) {
              return Optional.empty();
          }
      }
  }