package com.atlassian.messagequeue.internal.sqs;
   
   import com.atlassian.messagequeue.MessageRunnerKey;
   import com.atlassian.messagequeue.TenantDataIdSupplier;
   import com.atlassian.messagequeue.internal.core.DefaultMessageInformationService;
   import com.atlassian.messagequeue.internal.core.NestedMessageSerializer;
   import com.atlassian.tenant.api.TenantContextProvider;
   
   import static java.util.Objects.requireNonNull;
  
  /**
   * SQS variant of {@link DefaultMessageInformationService}. This provides a method to obtain SQS queue URLs
   * @since 2.1.0
   */
  public class SQSMessageInformationService extends DefaultMessageInformationService {
      private final SQSMessageRunnerKeyToProducerMapper messageRunnerKeyToProducerMapper;
  
      /**
       * @param messageRunnerKeyToProducerMapper mapping from messageRunnerKey to queue config
       * @param tenantContextProvider   the tenant context provider
       * @param nestedMessageSerializer the nested message serializer
       * @param tenantDataIdSupplier    the tenant data id supplier
       */
      public SQSMessageInformationService(SQSMessageRunnerKeyToProducerMapper messageRunnerKeyToProducerMapper, TenantContextProvider tenantContextProvider, NestedMessageSerializer nestedMessageSerializer, TenantDataIdSupplier tenantDataIdSupplier) {
          super("", tenantContextProvider, nestedMessageSerializer, tenantDataIdSupplier);
          this.messageRunnerKeyToProducerMapper = requireNonNull(messageRunnerKeyToProducerMapper);
      }
  
      @Override
      public String getQueueUrl(MessageRunnerKey messageRunnerKey) {
          return messageRunnerKeyToProducerMapper.getQueueConfigForMessageRunner(messageRunnerKey).getQueueUrl();
      }
  }