package com.atlassian.messagequeue.internal.core;
   
   import com.atlassian.messagequeue.MessageSerializationException;
   import org.codehaus.jackson.annotate.JsonAutoDetect;
   import org.codehaus.jackson.annotate.JsonMethod;
   import org.codehaus.jackson.map.ObjectMapper;
   
   import java.io.IOException;
   
  /**
   * Implementation using Jackson (https://github.com/FasterXML/jackson).
   */
  public class JacksonNestedMessageSerializer implements NestedMessageSerializer {
      private final ObjectMapper objectMapper;
  
      public JacksonNestedMessageSerializer() {
          this.objectMapper = new ObjectMapper().setVisibility(JsonMethod.FIELD, JsonAutoDetect.Visibility.ANY);
  
      }
  
      @Override
      public String serialize(NestedMessage nestedMessage) {
          try {
              return objectMapper.writeValueAsString(nestedMessage);
          } catch (IOException e) {
              throw new MessageSerializationException("Error serializing nested message", e);
          }
      }
  
      @Override
      public NestedMessage deserialize(String string) {
          try {
              return objectMapper.readValue(string, NestedMessage.class);
          } catch (IOException e) {
              throw new MessageSerializationException("Error deserializing nested message", e);
          }
      }
  }