1 package org.apache.maven.index.updater.fixtures;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import org.apache.maven.wagon.events.TransferEvent;
23 import org.apache.maven.wagon.events.TransferListener;
24
25 public class TransferListenerFixture
26 implements TransferListener
27 {
28 private static final int ONE_CHUNK = 64;
29
30 private int col = 0;
31
32 private int count = 0;
33
34 private int kb = 0;
35
36 public void transferStarted( final TransferEvent transferEvent )
37 {
38 System.out.println( "Started transfer: " + transferEvent.getResource().getName() );
39 }
40
41 public void transferProgress( final TransferEvent transferEvent, final byte[] buffer, final int length )
42 {
43 if ( buffer == null )
44 {
45 return;
46 }
47
48 count += buffer.length;
49
50 if ( ( count / ONE_CHUNK ) > kb )
51 {
52 if ( col > 80 )
53 {
54 System.out.println();
55 col = 0;
56 }
57
58 System.out.print( '.' );
59 col++;
60 kb++;
61 }
62 }
63
64 public void transferInitiated( final TransferEvent transferEvent )
65 {
66 }
67
68 public void transferError( final TransferEvent transferEvent )
69 {
70 System.out.println( "[ERROR]: " + transferEvent.getException().getLocalizedMessage() );
71 transferEvent.getException().printStackTrace();
72 }
73
74 public void transferCompleted( final TransferEvent transferEvent )
75 {
76 System.out.println( "\nCompleted transfer: " + transferEvent.getResource().getName() + " ("
77 + (double) ( count / ONE_CHUNK ) + " chunks of size: " + ONE_CHUNK + " bytes)" );
78 }
79
80 public void debug( final String message )
81 {
82 System.out.println( "[DEBUG]: " + message );
83 }
84 }