package com.atlassian.messagequeue.internal.inmemory;
   
   import com.atlassian.messagequeue.registry.MessageContext;
   
   import javax.annotation.Nullable;
   import java.util.Optional;
   
   /**
    * In-memory message context.
   */
  public class InMemoryMessageContext implements MessageContext {
      private final String payload;
  
      public InMemoryMessageContext(@Nullable String payload) {
          this.payload = payload;
      }
  
      @Override
      public Optional<String> getMessageId() {
          return Optional.empty();
      }
  
      @Override
      public Optional<String> getPayload() {
          return Optional.ofNullable(payload);
      }
  
      @Override
      public void acknowledge() {
          // no op
          // messages are delivered once-only to a single thread in the thread pool managed by InMemoryMessageRunnerService
      }
  
      @Override
      public boolean isCancellationRequested() {
          return false;
      }
  }