package com.atlassian.messagequeue.internal.core;
   
   import com.atlassian.messagequeue.MessageSerializationException;
   import com.google.gson.Gson;
   import com.google.gson.GsonBuilder;
   import com.google.gson.JsonSyntaxException;
   
   /**
    * Implementation using Gson (https://github.com/google/gson).
   */
  public class GsonNestedMessageSerializer implements NestedMessageSerializer {
      private final Gson gson;
  
      public GsonNestedMessageSerializer() {
          this.gson = new GsonBuilder().serializeNulls().create();
      }
  
      @Override
      public String serialize(NestedMessage message) {
          try {
              return gson.toJson(message);
          } catch (Exception e) {
              throw new MessageSerializationException("Serialization error", e);
          }
      }
  
      @Override
      public NestedMessage deserialize(String string) {
          try {
              return gson.fromJson(string, NestedMessage.class);
          } catch (JsonSyntaxException e) {
              throw new MessageSerializationException("Deserialization error", e);
          }
      }
  }