package com.atlassian.messagequeue;
   
   import static org.junit.Assert.*;
   import static org.mockito.Mockito.*;
   
   import org.junit.Test;
   import org.junit.runner.RunWith;
   import org.mockito.runners.MockitoJUnitRunner;
   
  import java.util.Optional;
  
  @RunWith(MockitoJUnitRunner.class)
  public class MessageTest {
      @Test(expected = MessagePayloadSizeExceededException.class)
      public void largePayloadSizeThrowsException() throws Exception {
          StringBuffer payload = new StringBuffer();
          for (int i = 0; i < MessageRunnerConstants.payloadMaxSize() + 1; ++i) {
              payload.append("a");
          }
  
          new Message(MessageRunnerKey.of("test"), payload.toString());
      }
  
      @Test(expected = InvalidMessagePayloadException.class)
      public void illegalCharacterThrowsException() throws Exception {
          new Message(MessageRunnerKey.of("test"), "foo " + codePointToString(0xD800) + " bar"); // The range 0xD800 - 0xDFFF is reserved for encoding to UTF-16 and is therefore invalid
      }
  
      private static String codePointToString(int i) {
          return String.valueOf(Character.toChars(i));
      }
  }