@@ -36,10 +36,10 @@ public TransferListenerContainerImpl(Wagon wagon) {
3636
3737 @ Override
3838 public void addTransferListener (TransferListener transferListener ) {
39- if (transferListener == null ) {
39+ if (transferListener == null ) {
4040 throw new NullPointerException ();
4141 }
42- if (!transferListeners .contains (transferListener )) {
42+ if (!transferListeners .contains (transferListener )) {
4343 transferListeners .add (transferListener );
4444 }
4545 }
@@ -56,32 +56,36 @@ public boolean hasTransferListener(TransferListener transferListener) {
5656
5757 @ Override
5858 public void fireTransferInitiated (Resource resource , int requestType ) {
59- TransferEvent transferEvent = new TransferEvent (this .wagon ,resource ,TransferEvent .TRANSFER_INITIATED ,requestType );
60- transferListeners .forEach (tl -> tl .transferInitiated (transferEvent ));
59+ TransferEvent transferEvent = new TransferEvent (this .wagon , resource , TransferEvent .TRANSFER_INITIATED , requestType );
60+ transferListeners .forEach (tl -> tl .transferInitiated (transferEvent ));
6161 }
6262
6363 @ Override
6464 public void fireTransferStarted (Resource resource , int requestType , File localFile ) {
65- resource .setContentLength (localFile .length ());
65+ if (localFile .exists ()) {
66+ resource .setContentLength (localFile .length ());
67+ }
6668 resource .setLastModified (localFile .lastModified ());
67- TransferEvent transferEvent = new TransferEvent (this .wagon ,resource ,TransferEvent .TRANSFER_STARTED ,requestType );
69+ TransferEvent transferEvent = new TransferEvent (this .wagon , resource , TransferEvent .TRANSFER_STARTED , requestType );
6870 transferEvent .setLocalFile (localFile );
69- transferListeners .forEach (tl -> tl .transferStarted (transferEvent ));
71+ transferListeners .forEach (tl -> tl .transferStarted (transferEvent ));
7072 }
7173
7274 @ Override
7375 public void fireTransferProgress (Resource resource , int requestType , byte [] buffer , int length ) {
7476 TransferEvent transferEvent = new TransferEvent (this .wagon , resource , TransferEvent .TRANSFER_PROGRESS , requestType );
75- transferListeners .forEach (tl -> tl .transferProgress (transferEvent ,buffer ,length ));
77+ transferListeners .forEach (tl -> tl .transferProgress (transferEvent , buffer , length ));
7678 }
7779
78- @ Override public void fireTransferCompleted (Resource resource , int requestType ) {
80+ @ Override
81+ public void fireTransferCompleted (Resource resource , int requestType ) {
7982 TransferEvent transferEvent = new TransferEvent (this .wagon , resource , TransferEvent .TRANSFER_COMPLETED , requestType );
80- transferListeners .forEach (tl -> tl .transferCompleted (transferEvent ));
83+ transferListeners .forEach (tl -> tl .transferCompleted (transferEvent ));
8184 }
8285
83- @ Override public void fireTransferError (Resource resource , int requestType , Exception exception ) {
86+ @ Override
87+ public void fireTransferError (Resource resource , int requestType , Exception exception ) {
8488 TransferEvent transferEvent = new TransferEvent (this .wagon , resource , exception , requestType );
85- transferListeners .forEach (tl -> tl .transferError (transferEvent ));
89+ transferListeners .forEach (tl -> tl .transferError (transferEvent ));
8690 }
8791}
0 commit comments