本文整理了Java中org.apache.maven.wagon.repository.Repository类的一些代码示例，展示了Repository类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Repository类的具体详情如下：
包路径：org.apache.maven.wagon.repository.Repository
类名称：Repository

Repository介绍

[英]This class is an abstraction of the location from/to resources can be transfered.
[中]这个类是位置的抽象，从/到可以转移的资源。

代码示例

代码示例来源：origin: apache/maven

wagon.connect( new Repository( repository.getId(), repository.getUrl() ), authenticationInfo( repository ),
        proxyInfo( repository ) );
wagon.connect( new Repository( repository.getId(), repository.getUrl() ),
        authenticationInfo( repository ) );
wagon.connect( new Repository( repository.getId(), repository.getUrl() ), proxyInfo( repository ) );
wagon.connect( new Repository( repository.getId(), repository.getUrl() ) );

代码示例来源：origin: apache/maven

private ArtifactTransferResource wrap( Repository repository, Resource resource )
{
  if ( resource == null )
  {
    return null;
  }
  else
  {
    synchronized ( artifacts )
    {
      ArtifactTransferResource artifact = artifacts.get( resource );
      if ( artifact == null )
      {
        artifact = new MavenArtifact( repository.getUrl(), resource );
        artifacts.put( resource, artifact );
      }
      return artifact;
    }
  }
}

代码示例来源：origin: apache/maven

@Override
@Deprecated
public Wagon getWagon( Repository repository )
  throws UnsupportedProtocolException
{
  return getWagon( repository.getProtocol() );
}

代码示例来源：origin: apache/maven

private org.apache.maven.settings.Proxy getProxy( ArtifactRepository repository,
                         List<org.apache.maven.settings.Proxy> proxies )
{
  if ( proxies != null && repository.getProtocol() != null )
  {
    for ( org.apache.maven.settings.Proxy proxy : proxies )
    {
      if ( proxy.isActive() && repository.getProtocol().equalsIgnoreCase( proxy.getProtocol() ) )
      {
        if ( StringUtils.isNotEmpty( proxy.getNonProxyHosts() ) )
        {
          ProxyInfo pi = new ProxyInfo();
          pi.setNonProxyHosts( proxy.getNonProxyHosts() );
          org.apache.maven.wagon.repository.Repository repo =
            new org.apache.maven.wagon.repository.Repository( repository.getId(), repository.getUrl() );
          if ( !ProxyUtils.validateNonProxyHosts( pi, repo.getHost() ) )
          {
            return proxy;
          }
        }
        else
        {
          return proxy;
        }
      }
    }
  }
  return null;
}

代码示例来源：origin: stackoverflow.com

File repoDir = new File("test-git/.git");
// open the repository
Repository repo = new Repository(repoDir);
// find the HEAD
Commit head = repo.mapCommit(Constants.HEAD);
// retrieve the tree in HEAD
Tree tree = head.getTree();

// 1.2.0 api version here
// find a file (as a TreeEntry, which contains the blob object id)
TreeWalk treewalk = TreeWalk.forPath(repo, "b/test.txt", tree);
// use the blob id to read the file's data
byte[] data = repo.open(treewalk.getObjectId(0)).getBytes();

代码示例来源：origin: stackoverflow.com

File repoDir = new File("test-git");
// open the repository
Repository repository = new Repository(repoDir);
// find the HEAD
ObjectId lastCommitId = repository.resolve(Constants.HEAD);
// now we have to get the commit
RevWalk revWalk = new RevWalk(repository);
RevCommit commit = revWalk.parseCommit(lastCommitId);
// and using commit's tree find the path
RevTree tree = commit.getTree();
TreeWalk treeWalk = new TreeWalk(repository);
treeWalk.addTree(tree);
treeWalk.setRecursive(true);
treeWalk.setFilter(PathFilter.create(path));
if (!treeWalk.next()) {
 return null;
}
ObjectId objectId = treeWalk.getObjectId(0);
ObjectLoader loader = repository.open(objectId);

// and then one can use either
InputStream in = loader.openStream()
// or
loader.copyTo(out)

代码示例来源：origin: org.apache.maven.wagon/wagon-provider-test

public void testUserAgentHeaderIsPresentOnlyOnceIfSetMultipleTimes()
  throws Exception
{
  StreamingWagon wagon = (StreamingWagon) getWagon();
  // 1. set User-Agent header via HttpConfiguration
  Properties headers1 = new Properties();
  headers1.setProperty( "User-Agent", "test-user-agent" );
  setHttpHeaders( wagon, headers1 );
  // 2. redundantly set User-Agent header via setHttpHeaders()
  Properties headers2 = new Properties();
  headers2.setProperty( "User-Agent", "test-user-agent" );
  Method setHttpHeaders = wagon.getClass().getMethod( "setHttpHeaders", Properties.class );
  setHttpHeaders.invoke( wagon, headers2 );
  Server server = new Server(  );
  TestHeaderHandler handler = new TestHeaderHandler();
  server.setHandler( handler );
  addConnector( server );
  server.start();
  wagon.connect( new Repository( "id", getProtocol() + "://localhost:" + getLocalPort( server ) ) );
  wagon.getToStream( "resource", new ByteArrayOutputStream() );
  wagon.disconnect();
  server.stop();
  assertEquals( "test-user-agent", handler.headers.get( "User-Agent" ) );
}

代码示例来源：origin: org.apache.maven.wagon/wagon-provider-test

public void testGzipGet()
  throws Exception
  Server server = new Server( );
  root.addServlet( servletHolder, "/*" );
  addConnector( server );
  server.setHandler( root );
  server.start();
    Repository testRepository = new Repository( "id", getRepositoryUrl( server ) );
    String sourceContent = writeTestFile( sourceFile, resName, "gzip" );
    wagon.connect( testRepository );
    wagon.get( "gzip/" + resName, destFile );
    wagon.disconnect();
    String destContent = FileUtils.fileRead( destFile );

代码示例来源：origin: org.apache.maven.wagon/wagon-provider-test

Server server = createSecurityServer( localRepositoryPath );
server.start();
  Repository testRepository = new Repository( "id", getRepositoryUrl( server ) );
  FileUtils.fileWrite( sourceFile.getAbsolutePath(), "top secret" );
  TestSecurityHandler securityHandler = server.getChildHandlerByClass( TestSecurityHandler.class );
  testPreemptiveAuthenticationGet( securityHandler, supportPreemptiveAuthenticationGet() );
  server.stop();

代码示例来源：origin: org.apache.maven.wagon/wagon-provider-test

protected void setupWagonTestingFixtures()
  throws Exception
{
  // File round trip testing
  File file = FileTestUtils.createUniqueFile( "local-repository", "test-resource" );
  file.delete();
  file.getParentFile().mkdirs();
  File repositoryDirectory = getRepositoryDirectory();
  FileUtils.deleteDirectory( repositoryDirectory );
  repositoryDirectory.mkdirs();
  server = new Server( );
  //connector = new ServerConnector( server, new HttpConnectionFactory( new HttpConfiguration() ) );
  //server.addConnector( connector );
  connector = addConnector( server );
  PutHandler putHandler = new PutHandler( repositoryDirectory );
  ServletContextHandler context = createContext( server, repositoryDirectory );
  HandlerCollection handlers = new HandlerCollection();
  handlers.addHandler( putHandler );
  handlers.addHandler( context );
  server.setHandler( handlers );
  server.start();
  testRepository.setUrl( getTestRepositoryUrl() );
}

代码示例来源：origin: apache/archiva

@Override
public void transferStarted( TransferEvent transferEvent )
{
  log.debug( "transferStarted for resource {} on repository url {}", transferEvent.getResource().getName(),
        transferEvent.getWagon().getRepository().getUrl() );
}

代码示例来源：origin: org.sonatype.nexus/nexus-test-utils

public void deploy()
  throws ComponentLookupException, ConnectionException, AuthenticationException, TransferFailedException,
  ResourceDoesNotExistException, AuthorizationException
{
  Repository repository = new Repository();
  repository.setUrl( repositoryUrl );
  wagon.connect( repository, getWagonAuthenticationInfo() );
  wagon.put( fileToDeploy, artifactPath );
  wagon.disconnect();
}

代码示例来源：origin: org.apache.maven.wagon/wagon-provider-api

protected void checkOutputStream( Resource resource, OutputStream os )
  throws TransferFailedException
{
  if ( os == null )
  {
    TransferFailedException e =
      new TransferFailedException( getRepository().getUrl()
        + " - Could not open output stream for resource: '" + resource + "'" );
    fireTransferError( resource, e, TransferEvent.REQUEST_PUT );
    throw e;
  }
}

代码示例来源：origin: org.codehaus.mojo/wagon-maven-plugin

@Override
public Wagon create( String url, String serverId, Settings settings )
  throws WagonException
{
  final Repository repository = new Repository( serverId, url == null ? "" : url );
  repository.setPermissions( getPermissions( serverId, settings ) );
  Wagon wagon;
  if ( url == null )
  {
    wagon = createAndConfigureWagon( serverId, settings, repository );
  }
  else
  {
    wagon = getWagon( repository.getProtocol() );
    configureWagon( wagon, serverId, settings );
  }
  if ( logger.isDebugEnabled() )
  {
    Debug debug = new Debug();
    wagon.addSessionListener( debug );
    wagon.addTransferListener( debug );
  }
  AuthenticationInfo authInfo = getAuthenticationInfo( serverId, settings );
  ProxyInfo proxyInfo = getProxyInfo( settings );
  wagon.connect( repository, authInfo, proxyInfo );
  return wagon;
}

代码示例来源：origin: apache/maven-archetype

private ArchetypeCatalog downloadCatalog( ArtifactRepository repository )
  throws WagonException, IOException, ArchetypeDataSourceException
{
  getLogger().debug( "Searching for remote catalog: " + repository.getUrl() + "/" + ARCHETYPE_CATALOG_FILENAME );
  // We use wagon to take advantage of a Proxy that has already been setup in a Maven environment.
  Repository wagonRepository = new Repository( repository.getId(), repository.getUrl() );
  
  AuthenticationInfo authInfo = getAuthenticationInfo( wagonRepository.getId() );
  ProxyInfo proxyInfo = getProxy( wagonRepository.getProtocol() );
  Wagon wagon = getWagon( wagonRepository );
  File catalog = File.createTempFile( "archetype-catalog", ".xml" );
  try
  {
    wagon.connect( wagonRepository, authInfo, proxyInfo );
    wagon.get( ARCHETYPE_CATALOG_FILENAME, catalog );
    return readCatalog( ReaderFactory.newXmlReader( catalog ) );
  }
  finally
  {
    disconnectWagon( wagon );
    catalog.delete();
  }
}

代码示例来源：origin: org.apache.maven.wagon/wagon-ssh

private void handleIOException( Resource resource, IOException e )
  throws TransferFailedException
{
  if ( e.getMessage().contains( "set mode: Operation not permitted" ) )
  {
    fireTransferDebug( e.getMessage() );
  }
  else
  {
    fireTransferError( resource, e, TransferEvent.REQUEST_PUT );
    String msg = "Error occurred while deploying '" + resource.getName() + "' to remote repository: "
      + getRepository().getUrl() + ": " + e.getMessage();
    throw new TransferFailedException( msg, e );
  }
}

代码示例来源：origin: org.apache.maven.wagon/wagon-file

public void fillOutputData( OutputData outputData )
  throws TransferFailedException
{
  if ( getRepository().getBasedir() == null )
  {
    throw new TransferFailedException( "Unable to operate with a null basedir." );
  }
  Resource resource = outputData.getResource();
  File file = new File( getRepository().getBasedir(), resource.getName() );
  createParentDirectories( file );
  OutputStream outputStream = new BufferedOutputStream( new LazyFileOutputStream( file ) );
  outputData.setOutputStream( outputStream );
}

代码示例来源：origin: org.apache.maven/maven-ant-tasks

public void transferInitiated( TransferEvent event )
{
  String message = event.getRequestType() == TransferEvent.REQUEST_PUT ? "Uploading" : "Downloading";
  String dest = event.getRequestType() == TransferEvent.REQUEST_PUT ? " to " : " from ";
  log( message + ": " + event.getResource().getName() + dest + "repository "
    + event.getWagon().getRepository().getId() + " at " + event.getWagon().getRepository().getUrl() );
}

代码示例来源：origin: org.apache.maven.wagon/wagon-provider-api

/**
 * @see SessionListener#sessionConnectionRefused(SessionEvent)
 */
public void sessionConnectionRefused( final SessionEvent sessionEvent )
{
  out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Connection refused" );
}

代码示例来源：origin: victims/maven-security-versions

public WagonHttpRepository(Log log,WagonManager wagonManager) throws ConnectionException, AuthenticationException, WagonConfigurationException, UnsupportedProtocolException {
  this.log = log;
  this.rep = new Repository(URL_REPO, URL_REPO);
  this.w = wagonManager.getWagon(rep);
  w.connect(rep, wagonManager.getProxy(rep.getProtocol()));
}