diff options
author | Olivier Lamy <olamy@apache.org> | 2011-09-30 09:41:47 +0000 |
---|---|---|
committer | Olivier Lamy <olamy@apache.org> | 2011-09-30 09:41:47 +0000 |
commit | 3e6842504aabfde08a80c0f0a05f9e889d98df3d (patch) | |
tree | ac0fc12989fd1548ff3050300b92d47f0275d411 /archiva-modules/archiva-base/archiva-proxy-common | |
parent | 3734ce78c811751dd0485ee2cff6a6921e320ba4 (diff) | |
download | archiva-3e6842504aabfde08a80c0f0a05f9e889d98df3d.tar.gz archiva-3e6842504aabfde08a80c0f0a05f9e889d98df3d.zip |
add a wagon transfert listener for debugging purpose
git-svn-id: https://svn.apache.org/repos/asf/archiva/trunk@1177571 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'archiva-modules/archiva-base/archiva-proxy-common')
2 files changed, 78 insertions, 1 deletions
diff --git a/archiva-modules/archiva-base/archiva-proxy-common/src/main/java/org/apache/archiva/proxy/common/DebugTransferListener.java b/archiva-modules/archiva-base/archiva-proxy-common/src/main/java/org/apache/archiva/proxy/common/DebugTransferListener.java new file mode 100644 index 000000000..226a118f7 --- /dev/null +++ b/archiva-modules/archiva-base/archiva-proxy-common/src/main/java/org/apache/archiva/proxy/common/DebugTransferListener.java @@ -0,0 +1,73 @@ +package org.apache.archiva.proxy.common; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +import org.apache.maven.wagon.events.TransferEvent; +import org.apache.maven.wagon.events.TransferListener; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.util.Arrays; + +/** + * @author Olivier Lamy + * @since 1.4 + */ +public class DebugTransferListener + implements TransferListener +{ + private Logger log = LoggerFactory.getLogger( getClass() ); + + public void transferInitiated( TransferEvent transferEvent ) + { + log.debug( "transferInitiated for resource {} on repository url {}", transferEvent.getResource().getName(), + transferEvent.getWagon().getRepository().getUrl() ); + } + + public void transferStarted( TransferEvent transferEvent ) + { + log.debug( "transferStarted for resource {} on repository url {}", transferEvent.getResource().getName(), + transferEvent.getWagon().getRepository().getUrl() ); + } + + public void transferProgress( TransferEvent transferEvent, byte[] bytes, int i ) + { + log.debug( "transferProgress for resource {} on repository url {}", transferEvent.getResource().getName(), + transferEvent.getWagon().getRepository().getUrl() ); + } + + public void transferCompleted( TransferEvent transferEvent ) + { + log.debug( "transferCompleted for resource {} on repository url {}", transferEvent.getResource().getName(), + transferEvent.getWagon().getRepository().getUrl() ); + } + + public void transferError( TransferEvent transferEvent ) + { + log.debug( "transferError for resource {} on repository url {}", + Arrays.asList( transferEvent.getResource().getName(), + transferEvent.getWagon().getRepository().getUrl() ).toArray( new String[2] ), + transferEvent.getException() ); + } + + public void debug( String s ) + { + log.debug( "wagon debug {}", s ); + } +} diff --git a/archiva-modules/archiva-base/archiva-proxy-common/src/main/java/org/apache/archiva/proxy/common/DefaultWagonFactory.java b/archiva-modules/archiva-base/archiva-proxy-common/src/main/java/org/apache/archiva/proxy/common/DefaultWagonFactory.java index f2631c051..9316bbf49 100755 --- a/archiva-modules/archiva-base/archiva-proxy-common/src/main/java/org/apache/archiva/proxy/common/DefaultWagonFactory.java +++ b/archiva-modules/archiva-base/archiva-proxy-common/src/main/java/org/apache/archiva/proxy/common/DefaultWagonFactory.java @@ -38,6 +38,8 @@ public class DefaultWagonFactory private PlexusSisuBridge plexusSisuBridge; + private DebugTransferListener debugTransferListener = new DebugTransferListener(); + @Inject public DefaultWagonFactory( PlexusSisuBridge plexusSisuBridge ) { @@ -52,7 +54,9 @@ public class DefaultWagonFactory // with sisu inject bridge hint is file or http // so remove wagon# protocol = StringUtils.remove( protocol, "wagon#" ); - return plexusSisuBridge.lookup( Wagon.class, protocol ); + Wagon wagon = plexusSisuBridge.lookup( Wagon.class, protocol ); + wagon.addTransferListener( debugTransferListener ); + return wagon; } catch ( PlexusSisuBridgeException e ) { |