001/* 002 * Licensed to the Apache Software Foundation (ASF) under one 003 * or more contributor license agreements. See the NOTICE file 004 * distributed with this work for additional information 005 * regarding copyright ownership. The ASF licenses this file 006 * to you under the Apache License, Version 2.0 (the 007 * "License"); you may not use this file except in compliance 008 * with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, 013 * software distributed under the License is distributed on an 014 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 015 * KIND, either express or implied. See the License for the 016 * specific language governing permissions and limitations 017 * under the License. 018 */ 019package org.eclipse.aether.transport.jetty; 020 021import javax.inject.Inject; 022import javax.inject.Named; 023 024import org.eclipse.aether.RepositorySystemSession; 025import org.eclipse.aether.repository.RemoteRepository; 026import org.eclipse.aether.spi.connector.transport.http.ChecksumExtractor; 027import org.eclipse.aether.spi.connector.transport.http.HttpTransporter; 028import org.eclipse.aether.spi.connector.transport.http.HttpTransporterFactory; 029import org.eclipse.aether.spi.io.PathProcessor; 030import org.eclipse.aether.transfer.NoTransporterException; 031 032import static java.util.Objects.requireNonNull; 033 034/** 035 * A transporter factory for repositories using the {@code http:} or {@code https:} protocol. 036 * 037 * @since 2.0.0 038 */ 039@Named(JettyTransporterFactory.NAME) 040public final class JettyTransporterFactory implements HttpTransporterFactory { 041 public static final String NAME = "jetty"; 042 043 private float priority = 15.0f; 044 045 private final ChecksumExtractor checksumExtractor; 046 047 private final PathProcessor pathProcessor; 048 049 @Inject 050 public JettyTransporterFactory(ChecksumExtractor checksumExtractor, PathProcessor pathProcessor) { 051 this.checksumExtractor = requireNonNull(checksumExtractor, "checksumExtractor"); 052 this.pathProcessor = requireNonNull(pathProcessor, "pathProcessor"); 053 } 054 055 @Override 056 public float getPriority() { 057 return priority; 058 } 059 060 public JettyTransporterFactory setPriority(float priority) { 061 this.priority = priority; 062 return this; 063 } 064 065 @Override 066 public HttpTransporter newInstance(RepositorySystemSession session, RemoteRepository repository) 067 throws NoTransporterException { 068 requireNonNull(session, "session cannot be null"); 069 requireNonNull(repository, "repository cannot be null"); 070 071 if (!"http".equalsIgnoreCase(repository.getProtocol()) && !"https".equalsIgnoreCase(repository.getProtocol())) { 072 throw new NoTransporterException(repository); 073 } 074 075 return new JettyTransporter(session, repository, checksumExtractor, pathProcessor); 076 } 077}