This is an automated email from the ASF dual-hosted git repository.
slachiewicz pushed a commit to branch plexus1
in repository https://gitbox.apache.org/repos/asf/maven-wagon.git
The following commit(s) were added to refs/heads/plexus1 by this push:
new 3d8b5f92 overwrite
3d8b5f92 is described below
commit 3d8b5f920c9a99c9e8b5fec6723ee0a3f3ff8e1d
Author: Sylwester Lachiewicz <[email protected]>
AuthorDate: Sat Dec 13 23:42:04 2025 +0100
overwrite
---
.../java/org/apache/maven/wagon/AbstractWagon.java | 26 ++++++++++++++++++++++
.../apache/maven/wagon/LazyFileOutputStream.java | 8 +++++++
.../java/org/apache/maven/wagon/StreamWagon.java | 8 +++++++
.../org/apache/maven/wagon/WagonException.java | 2 ++
.../apache/maven/wagon/events/SessionEvent.java | 1 +
.../apache/maven/wagon/events/TransferEvent.java | 3 +++
.../wagon/observers/AbstractTransferListener.java | 6 +++++
.../maven/wagon/observers/ChecksumObserver.java | 6 +++++
.../org/apache/maven/wagon/observers/Debug.java | 14 ++++++++++++
.../apache/maven/wagon/repository/Repository.java | 3 +++
.../org/apache/maven/wagon/resource/Resource.java | 3 +++
.../org/apache/maven/wagon/AbstractWagonTest.java | 8 +++++++
.../org/apache/maven/wagon/InputStreamMock.java | 2 ++
.../org/apache/maven/wagon/OutputStreamMock.java | 2 ++
.../org/apache/maven/wagon/StreamWagonTest.java | 15 +++++++++++++
.../java/org/apache/maven/wagon/WagonMock.java | 8 +++++++
16 files changed, 115 insertions(+)
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/AbstractWagon.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/AbstractWagon.java
index 9835c317..1bcbb4c2 100644
--- a/wagon-provider-api/src/main/java/org/apache/maven/wagon/AbstractWagon.java
+++ b/wagon-provider-api/src/main/java/org/apache/maven/wagon/AbstractWagon.java
@@ -108,6 +108,7 @@ public abstract class AbstractWagon implements Wagon {
// Accessors
// ----------------------------------------------------------------------
+ @Override
public Repository getRepository() {
return repository;
}
@@ -125,6 +126,7 @@ public AuthenticationInfo getAuthenticationInfo() {
// ----------------------------------------------------------------------
@Deprecated
+ @Override
public void openConnection() throws ConnectionException,
AuthenticationException {
try {
openConnectionInternal();
@@ -135,29 +137,35 @@ public void openConnection() throws ConnectionException,
AuthenticationException
}
}
+ @Override
public void connect(Repository repository) throws ConnectionException,
AuthenticationException {
connect(repository, null, (ProxyInfoProvider) null);
}
+ @Override
public void connect(Repository repository, ProxyInfo proxyInfo)
throws ConnectionException, AuthenticationException {
connect(repository, null, proxyInfo);
}
+ @Override
public void connect(Repository repository, ProxyInfoProvider
proxyInfoProvider)
throws ConnectionException, AuthenticationException {
connect(repository, null, proxyInfoProvider);
}
+ @Override
public void connect(Repository repository, AuthenticationInfo
authenticationInfo)
throws ConnectionException, AuthenticationException {
connect(repository, authenticationInfo, (ProxyInfoProvider) null);
}
+ @Override
public void connect(Repository repository, AuthenticationInfo
authenticationInfo, ProxyInfo proxyInfo)
throws ConnectionException, AuthenticationException {
final ProxyInfo proxy = proxyInfo;
connect(repository, authenticationInfo, new ProxyInfoProvider() {
+ @Override
public ProxyInfo getProxyInfo(String protocol) {
if (protocol == null || proxy == null ||
protocol.equalsIgnoreCase(proxy.getType())) {
return proxy;
@@ -168,6 +176,7 @@ public ProxyInfo getProxyInfo(String protocol) {
});
}
+ @Override
public void connect(
Repository repository, AuthenticationInfo authenticationInfo,
ProxyInfoProvider proxyInfoProvider)
throws ConnectionException, AuthenticationException {
@@ -208,6 +217,7 @@ public void connect(
protected abstract void openConnectionInternal() throws
ConnectionException, AuthenticationException;
+ @Override
public void disconnect() throws ConnectionException {
fireSessionDisconnecting();
@@ -239,10 +249,12 @@ protected void createParentDirectories(File destination)
throws TransferFailedEx
}
}
+ @Override
public void setTimeout(int timeoutValue) {
connectionTimeout = timeoutValue;
}
+ @Override
public int getTimeout() {
return connectionTimeout;
}
@@ -711,26 +723,32 @@ protected void fireSessionDebug(String message) {
sessionEventSupport.fireDebug(message);
}
+ @Override
public boolean hasTransferListener(TransferListener listener) {
return transferEventSupport.hasTransferListener(listener);
}
+ @Override
public void addTransferListener(TransferListener listener) {
transferEventSupport.addTransferListener(listener);
}
+ @Override
public void removeTransferListener(TransferListener listener) {
transferEventSupport.removeTransferListener(listener);
}
+ @Override
public void addSessionListener(SessionListener listener) {
sessionEventSupport.addSessionListener(listener);
}
+ @Override
public boolean hasSessionListener(SessionListener listener) {
return sessionEventSupport.hasSessionListener(listener);
}
+ @Override
public void removeSessionListener(SessionListener listener) {
sessionEventSupport.removeSessionListener(listener);
}
@@ -784,11 +802,13 @@ protected void postProcessListeners(Resource resource,
File source, int requestT
}
}
+ @Override
public void putDirectory(File sourceDirectory, String destinationDirectory)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {
throw new UnsupportedOperationException("The wagon you are using has
not implemented putDirectory()");
}
+ @Override
public boolean supportsDirectoryCopy() {
return false;
}
@@ -803,19 +823,23 @@ protected static String getPath(String basedir, String
dir) {
return path;
}
+ @Override
public boolean isInteractive() {
return interactive;
}
+ @Override
public void setInteractive(boolean interactive) {
this.interactive = interactive;
}
+ @Override
public List<String> getFileList(String destinationDirectory)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {
throw new UnsupportedOperationException("The wagon you are using has
not implemented getFileList()");
}
+ @Override
public boolean resourceExists(String resourceName) throws
TransferFailedException, AuthorizationException {
throw new UnsupportedOperationException("The wagon you are using has
not implemented resourceExists()");
}
@@ -838,10 +862,12 @@ public void setPermissionsOverride(RepositoryPermissions
permissionsOverride) {
this.permissionsOverride = permissionsOverride;
}
+ @Override
public void setReadTimeout(int readTimeout) {
this.readTimeout = readTimeout;
}
+ @Override
public int getReadTimeout() {
return this.readTimeout;
}
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/LazyFileOutputStream.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/LazyFileOutputStream.java
index ca248e36..65ea16e1 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/LazyFileOutputStream.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/LazyFileOutputStream.java
@@ -47,16 +47,19 @@ public LazyFileOutputStream(File file) {
this.file = file;
}
+ @Override
public void close() throws IOException {
if (delegee != null) {
delegee.close();
}
}
+ @Override
public boolean equals(Object obj) {
return delegee.equals(obj);
}
+ @Override
public void flush() throws IOException {
if (delegee != null) {
delegee.flush();
@@ -71,14 +74,17 @@ public FileDescriptor getFD() throws IOException {
return delegee.getFD();
}
+ @Override
public int hashCode() {
return delegee.hashCode();
}
+ @Override
public String toString() {
return delegee.toString();
}
+ @Override
public void write(byte[] b) throws IOException {
if (delegee == null) {
initialize();
@@ -90,6 +96,7 @@ public void write(byte[] b) throws IOException {
/**
* @see java.io.OutputStream#write(byte[], int, int)
*/
+ @Override
public void write(byte[] b, int off, int len) throws IOException {
if (delegee == null) {
initialize();
@@ -102,6 +109,7 @@ public void write(byte[] b, int off, int len) throws
IOException {
* @param b
* @throws java.io.IOException
*/
+ @Override
public void write(int b) throws IOException {
if (delegee == null) {
initialize();
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/StreamWagon.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/StreamWagon.java
index c58ebb17..bbdb7024 100644
--- a/wagon-provider-api/src/main/java/org/apache/maven/wagon/StreamWagon.java
+++ b/wagon-provider-api/src/main/java/org/apache/maven/wagon/StreamWagon.java
@@ -43,12 +43,14 @@ public abstract void fillInputData(InputData inputData)
public abstract void fillOutputData(OutputData outputData) throws
TransferFailedException;
+ @Override
public abstract void closeConnection() throws ConnectionException;
// ----------------------------------------------------------------------
//
// ----------------------------------------------------------------------
+ @Override
public void get(String resourceName, File destination)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {
getIfNewer(resourceName, destination, 0);
@@ -63,6 +65,7 @@ protected void checkInputStream(InputStream is, Resource
resource) throws Transf
}
}
+ @Override
public boolean getIfNewer(String resourceName, File destination, long
timestamp)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {
boolean retValue = false;
@@ -125,6 +128,7 @@ protected InputStream getInputStream(Resource resource)
}
// source doesn't exist exception
+ @Override
public void put(File source, String resourceName)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {
Resource resource = new Resource(resourceName);
@@ -171,6 +175,7 @@ protected OutputStream getOutputStream(Resource resource)
throws TransferFailedE
return outputData.getOutputStream();
}
+ @Override
public boolean getIfNewerToStream(String resourceName, OutputStream
stream, long timestamp)
throws ResourceDoesNotExistException, TransferFailedException,
AuthorizationException {
boolean retValue = false;
@@ -205,12 +210,14 @@ public boolean getIfNewerToStream(String resourceName,
OutputStream stream, long
return retValue;
}
+ @Override
public void getToStream(String resourceName, OutputStream stream)
throws ResourceDoesNotExistException, TransferFailedException,
AuthorizationException {
getIfNewerToStream(resourceName, stream, 0);
}
@Deprecated
+ @Override
public void putFromStream(InputStream stream, String destination)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {
Resource resource = new Resource(destination);
@@ -220,6 +227,7 @@ public void putFromStream(InputStream stream, String
destination)
putFromStream(stream, resource);
}
+ @Override
public void putFromStream(InputStream stream, String destination, long
contentLength, long lastModified)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {
Resource resource = new Resource(destination);
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/WagonException.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/WagonException.java
index 23f6c898..3a5a4901 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/WagonException.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/WagonException.java
@@ -58,6 +58,7 @@ public WagonException(final String message) {
*
* @return the cause of this exception or null if the cause is nonexistent
or unknown.
*/
+ @Override
public Throwable getCause() {
// try
// {
@@ -86,6 +87,7 @@ public Throwable getCause() {
*
* @return a reference to this Throwable instance.
*/
+ @Override
public Throwable initCause(final Throwable cause) {
// try
// {
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/events/SessionEvent.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/events/SessionEvent.java
index c123aeda..f435cffb 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/events/SessionEvent.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/events/SessionEvent.java
@@ -157,6 +157,7 @@ public void setException(final Exception exception) {
this.exception = exception;
}
+ @Override
public String toString() {
StringBuilder sb = new StringBuilder();
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/events/TransferEvent.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/events/TransferEvent.java
index 0d1c2076..c3625a0c 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/events/TransferEvent.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/events/TransferEvent.java
@@ -184,6 +184,7 @@ public void setLocalFile(File localFile) {
this.localFile = localFile;
}
+ @Override
public String toString() {
StringBuilder sb = new StringBuilder();
@@ -233,6 +234,7 @@ public String toString() {
return sb.toString();
}
+ @Override
public int hashCode() {
final int prime = 31;
int result = 1;
@@ -244,6 +246,7 @@ public int hashCode() {
return result;
}
+ @Override
public boolean equals(Object obj) {
if (this == obj) {
return true;
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/AbstractTransferListener.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/AbstractTransferListener.java
index 14e14847..bf3c9c32 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/AbstractTransferListener.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/AbstractTransferListener.java
@@ -28,21 +28,27 @@
*
*/
public abstract class AbstractTransferListener implements TransferListener {
+ @Override
public void transferInitiated(TransferEvent transferEvent) {}
/**
* @see
org.apache.maven.wagon.events.TransferListener#transferStarted(org.apache.maven.wagon.events.TransferEvent)
*/
+ @Override
public void transferStarted(TransferEvent transferEvent) {}
/**
* @see
org.apache.maven.wagon.events.TransferListener#transferProgress(org.apache.maven.wagon.events.TransferEvent,byte[],int)
*/
+ @Override
public void transferProgress(TransferEvent transferEvent, byte[] buffer,
int length) {}
+ @Override
public void transferCompleted(TransferEvent transferEvent) {}
+ @Override
public void transferError(TransferEvent transferEvent) {}
+ @Override
public void debug(String message) {}
}
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/ChecksumObserver.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/ChecksumObserver.java
index b5a0cb86..f06e52c8 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/ChecksumObserver.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/ChecksumObserver.java
@@ -46,6 +46,7 @@ public ChecksumObserver(String algorithm) throws
NoSuchAlgorithmException {
digester = MessageDigest.getInstance(algorithm);
}
+ @Override
public void transferInitiated(TransferEvent transferEvent) {
// This space left intentionally blank
}
@@ -53,6 +54,7 @@ public void transferInitiated(TransferEvent transferEvent) {
/**
* @see
org.apache.maven.wagon.events.TransferListener#transferStarted(org.apache.maven.wagon.events.TransferEvent)
*/
+ @Override
public void transferStarted(TransferEvent transferEvent) {
actualChecksum = null;
@@ -62,20 +64,24 @@ public void transferStarted(TransferEvent transferEvent) {
/**
* @see
org.apache.maven.wagon.events.TransferListener#transferProgress(org.apache.maven.wagon.events.TransferEvent,
byte[], int)
*/
+ @Override
public void transferProgress(TransferEvent transferEvent, byte[] buffer,
int length) {
digester.update(buffer, 0, length);
}
+ @Override
public void transferCompleted(TransferEvent transferEvent) {
actualChecksum = encode(digester.digest());
}
+ @Override
public void transferError(TransferEvent transferEvent) {
digester.reset();
actualChecksum = null;
}
+ @Override
public void debug(String message) {
// left intentionally blank
}
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/Debug.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/Debug.java
index 30b69ece..879544df 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/Debug.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/observers/Debug.java
@@ -47,6 +47,7 @@ public Debug(PrintStream out) {
/**
* @see SessionListener#sessionOpening(SessionEvent)
*/
+ @Override
public void sessionOpening(final SessionEvent sessionEvent) {
// out.println( .getUrl() + " - Session: Opening ");
}
@@ -54,6 +55,7 @@ public void sessionOpening(final SessionEvent sessionEvent) {
/**
* @see SessionListener#sessionOpened(SessionEvent)
*/
+ @Override
public void sessionOpened(final SessionEvent sessionEvent) {
out.println(sessionEvent.getWagon().getRepository().getUrl() + " -
Session: Opened ");
}
@@ -61,6 +63,7 @@ public void sessionOpened(final SessionEvent sessionEvent) {
/**
* @see SessionListener#sessionDisconnecting(SessionEvent)
*/
+ @Override
public void sessionDisconnecting(final SessionEvent sessionEvent) {
out.println(sessionEvent.getWagon().getRepository().getUrl() + " -
Session: Disconnecting ");
}
@@ -68,6 +71,7 @@ public void sessionDisconnecting(final SessionEvent
sessionEvent) {
/**
* @see SessionListener#sessionDisconnected(SessionEvent)
*/
+ @Override
public void sessionDisconnected(final SessionEvent sessionEvent) {
out.println(sessionEvent.getWagon().getRepository().getUrl() + " -
Session: Disconnected");
}
@@ -75,6 +79,7 @@ public void sessionDisconnected(final SessionEvent
sessionEvent) {
/**
* @see SessionListener#sessionConnectionRefused(SessionEvent)
*/
+ @Override
public void sessionConnectionRefused(final SessionEvent sessionEvent) {
out.println(sessionEvent.getWagon().getRepository().getUrl() + " -
Session: Connection refused");
}
@@ -82,6 +87,7 @@ public void sessionConnectionRefused(final SessionEvent
sessionEvent) {
/**
* @see SessionListener#sessionLoggedIn(SessionEvent)
*/
+ @Override
public void sessionLoggedIn(final SessionEvent sessionEvent) {
out.println(sessionEvent.getWagon().getRepository().getUrl() + " -
Session: Logged in");
}
@@ -89,6 +95,7 @@ public void sessionLoggedIn(final SessionEvent sessionEvent) {
/**
* @see SessionListener#sessionLoggedOff(SessionEvent)
*/
+ @Override
public void sessionLoggedOff(final SessionEvent sessionEvent) {
out.println(sessionEvent.getWagon().getRepository().getUrl() + " -
Session: Logged off");
}
@@ -96,10 +103,12 @@ public void sessionLoggedOff(final SessionEvent
sessionEvent) {
/**
* @see TransferListener#debug(String)
*/
+ @Override
public void debug(final String message) {
out.println(message);
}
+ @Override
public void transferInitiated(TransferEvent transferEvent) {
// This space left intentionally blank
}
@@ -107,6 +116,7 @@ public void transferInitiated(TransferEvent transferEvent) {
/**
* @see TransferListener#transferStarted(TransferEvent)
*/
+ @Override
public void transferStarted(final TransferEvent transferEvent) {
timestamp = transferEvent.getTimestamp();
@@ -128,6 +138,7 @@ public void transferStarted(final TransferEvent
transferEvent) {
/**
* @see TransferListener#transferProgress(TransferEvent,byte[],int)
*/
+ @Override
public void transferProgress(final TransferEvent transferEvent, byte[]
buffer, int length) {
out.print("#");
@@ -139,6 +150,7 @@ public void transferProgress(final TransferEvent
transferEvent, byte[] buffer, i
/**
* @see TransferListener#transferCompleted(TransferEvent)
*/
+ @Override
public void transferCompleted(final TransferEvent transferEvent) {
final double duration = (double) (transferEvent.getTimestamp() -
timestamp) / 1000;
@@ -152,6 +164,7 @@ public void transferCompleted(final TransferEvent
transferEvent) {
/**
* @see TransferListener#transferError(TransferEvent)
*/
+ @Override
public void transferError(final TransferEvent transferEvent) {
out.println(" Transfer error: " + transferEvent.getException());
}
@@ -159,6 +172,7 @@ public void transferError(final TransferEvent
transferEvent) {
/**
* @see SessionListener#sessionError(SessionEvent)
*/
+ @Override
public void sessionError(final SessionEvent sessionEvent) {
out.println(" Session error: " + sessionEvent.getException());
}
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/repository/Repository.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/repository/Repository.java
index d8675d60..7b758649 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/repository/Repository.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/repository/Repository.java
@@ -202,6 +202,7 @@ public String getName() {
return name;
}
+ @Override
public String toString() {
StringBuilder sb = new StringBuilder();
@@ -238,6 +239,7 @@ public void setParameters(Properties parameters) {
this.parameters = parameters;
}
+ @Override
public int hashCode() {
final int prime = 31;
int result = 1;
@@ -245,6 +247,7 @@ public int hashCode() {
return result;
}
+ @Override
public boolean equals(Object obj) {
if (this == obj) {
return true;
diff --git
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/resource/Resource.java
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/resource/Resource.java
index 2dfd083c..f8e32eb2 100644
---
a/wagon-provider-api/src/main/java/org/apache/maven/wagon/resource/Resource.java
+++
b/wagon-provider-api/src/main/java/org/apache/maven/wagon/resource/Resource.java
@@ -74,6 +74,7 @@ public void setContentLength(long contentLength) {
this.contentLength = contentLength;
}
+ @Override
public String toString() {
return name;
}
@@ -82,6 +83,7 @@ public String inspect() {
return name + "[len = " + contentLength + "; mod = " + lastModified +
"]";
}
+ @Override
public int hashCode() {
final int prime = 31;
int result = 1;
@@ -91,6 +93,7 @@ public int hashCode() {
return result;
}
+ @Override
public boolean equals(Object obj) {
if (this == obj) {
return true;
diff --git
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/AbstractWagonTest.java
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/AbstractWagonTest.java
index b1c70091..463ead3f 100644
---
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/AbstractWagonTest.java
+++
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/AbstractWagonTest.java
@@ -46,18 +46,23 @@
*/
public class AbstractWagonTest extends TestCase {
private static class TestWagon extends AbstractWagon {
+ @Override
protected void closeConnection() throws ConnectionException {}
+ @Override
protected void openConnectionInternal() throws ConnectionException,
AuthenticationException {}
+ @Override
public void get(String resourceName, File destination)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {}
+ @Override
public boolean getIfNewer(String resourceName, File destination, long
timestamp)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {
return false;
}
+ @Override
public void put(File source, String destination)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {}
}
@@ -250,6 +255,7 @@ private void runTestSessionConnectionRefusedEvent(final
WagonException exception
replay(sessionListener);
Wagon wagon = new TestWagon() {
+ @Override
protected void openConnectionInternal() throws
ConnectionException, AuthenticationException {
if (exception instanceof ConnectionException) {
throw (ConnectionException) exception;
@@ -287,6 +293,7 @@ public void
testSessionCloseRefusedEventConnectionException() throws Exception {
replay(sessionListener);
Wagon wagon = new TestWagon() {
+ @Override
protected void closeConnection() throws ConnectionException {
throw new ConnectionException("");
}
@@ -464,6 +471,7 @@ static final class ProgressAnswer implements IAnswer {
private int size;
+ @Override
public Object answer() {
byte[] buffer = (byte[]) getCurrentArguments()[1];
int length = (Integer) getCurrentArguments()[2];
diff --git
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/InputStreamMock.java
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/InputStreamMock.java
index d1f2384c..a361bdd1 100644
---
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/InputStreamMock.java
+++
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/InputStreamMock.java
@@ -31,6 +31,7 @@ public class InputStreamMock extends InputStream {
boolean forcedError = false;
+ @Override
public void close() {
closed = true;
}
@@ -52,6 +53,7 @@ public boolean isForcedError() {
/**
* @see java.io.InputStream#read()
*/
+ @Override
public int read() throws IOException {
if (forcedError) {
throw new IOException("Mock exception");
diff --git
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/OutputStreamMock.java
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/OutputStreamMock.java
index cfd10fd5..382fbee2 100644
---
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/OutputStreamMock.java
+++
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/OutputStreamMock.java
@@ -31,6 +31,7 @@ public class OutputStreamMock extends OutputStream {
private boolean forcedError = false;
+ @Override
public void close() {
closed = true;
}
@@ -38,6 +39,7 @@ public void close() {
/**
* @see java.io.OutputStream#write(int)
*/
+ @Override
public void write(final int b) throws IOException {
if (forcedError) {
throw new IOException("Mock exception");
diff --git
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/StreamWagonTest.java
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/StreamWagonTest.java
index 139e4ddb..83583cae 100644
---
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/StreamWagonTest.java
+++
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/StreamWagonTest.java
@@ -40,13 +40,17 @@
public class StreamWagonTest extends TestCase {
private static class TestWagon extends StreamWagon {
+ @Override
public void closeConnection() throws ConnectionException {}
+ @Override
public void fillInputData(InputData inputData)
throws TransferFailedException, ResourceDoesNotExistException,
AuthorizationException {}
+ @Override
public void fillOutputData(OutputData outputData) throws
TransferFailedException {}
+ @Override
protected void openConnectionInternal() throws ConnectionException,
AuthenticationException {}
}
@@ -54,6 +58,7 @@ protected void openConnectionInternal() throws
ConnectionException, Authenticati
public void testNullInputStream() throws Exception {
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillInputData(InputData inputData) {
inputData.setInputStream(null);
}
@@ -82,6 +87,7 @@ public void fillInputData(InputData inputData) {
public void testNullOutputStream() throws Exception {
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillOutputData(OutputData inputData) {
inputData.setOutputStream(null);
}
@@ -119,6 +125,7 @@ public void testTransferFailedExceptionOnInput() throws
Exception {
public void testTransferFailedExceptionOnOutput() throws Exception {
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillOutputData(OutputData inputData) throws
TransferFailedException {
throw new TransferFailedException("");
}
@@ -167,6 +174,7 @@ private void runTestTransferError(final WagonException
exception)
throws ConnectionException, AuthenticationException,
ResourceDoesNotExistException, AuthorizationException,
TransferFailedException {
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillInputData(InputData inputData)
throws TransferFailedException,
ResourceDoesNotExistException, AuthorizationException {
if (exception instanceof TransferFailedException) {
@@ -223,6 +231,7 @@ private boolean runTestGetIfNewer(final long resourceTime,
long comparisonTime)
throws IOException, ConnectionException, AuthenticationException,
TransferFailedException,
ResourceDoesNotExistException, AuthorizationException {
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillInputData(InputData inputData) {
inputData.setInputStream(new
ByteArrayInputStream("".getBytes()));
inputData.getResource().setLastModified(resourceTime);
@@ -246,6 +255,7 @@ public void testGetToStream() throws Exception {
final long comparisonTime =
new
SimpleDateFormat("yyyy-MM-dd").parse("2008-01-01").getTime();
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillInputData(InputData inputData) {
inputData.setInputStream(new
ByteArrayInputStream(content.getBytes()));
inputData.getResource().setLastModified(comparisonTime);
@@ -267,6 +277,7 @@ public void testGet() throws Exception {
final long comparisonTime =
new
SimpleDateFormat("yyyy-MM-dd").parse("2008-01-01").getTime();
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillInputData(InputData inputData) {
inputData.setInputStream(new
ByteArrayInputStream(content.getBytes()));
inputData.getResource().setLastModified(comparisonTime);
@@ -310,6 +321,7 @@ private boolean runTestGetIfNewerToStream(final long
resourceTime, long comparis
throws IOException, ConnectionException, AuthenticationException,
TransferFailedException,
ResourceDoesNotExistException, AuthorizationException {
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillInputData(InputData inputData) {
inputData.setInputStream(new
ByteArrayInputStream("".getBytes()));
inputData.getResource().setLastModified(resourceTime);
@@ -329,6 +341,7 @@ public void testPutFromStream() throws Exception {
OutputStream out = new ByteArrayOutputStream();
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillOutputData(OutputData outputData) {
assertEquals("resource", outputData.getResource().getName());
assertEquals(-1, outputData.getResource().getContentLength());
@@ -352,6 +365,7 @@ public void testPutFromStreamWithResourceInformation()
throws Exception {
OutputStream out = new ByteArrayOutputStream();
StreamingWagon wagon = new TestWagon() {
+ @Override
public void fillOutputData(OutputData outputData) {
assertEquals("resource", outputData.getResource().getName());
assertEquals(content.length(),
outputData.getResource().getContentLength());
@@ -379,6 +393,7 @@ public void testPut() throws Exception {
OutputStream out = new ByteArrayOutputStream();
Wagon wagon = new TestWagon() {
+ @Override
public void fillOutputData(OutputData outputData) {
assertEquals("resource", outputData.getResource().getName());
assertEquals(content.length(),
outputData.getResource().getContentLength());
diff --git
a/wagon-provider-api/src/test/java/org/apache/maven/wagon/WagonMock.java
b/wagon-provider-api/src/test/java/org/apache/maven/wagon/WagonMock.java
index 626bf919..d4c377d5 100644
--- a/wagon-provider-api/src/test/java/org/apache/maven/wagon/WagonMock.java
+++ b/wagon-provider-api/src/test/java/org/apache/maven/wagon/WagonMock.java
@@ -41,6 +41,7 @@ public WagonMock(boolean errorInputStream) {
this.errorInputStream = errorInputStream;
}
+ @Override
public void fillInputData(InputData inputData) throws
TransferFailedException {
InputStream is;
@@ -61,6 +62,7 @@ public void fillInputData(InputData inputData) throws
TransferFailedException {
inputData.setInputStream(is);
}
+ @Override
public void fillOutputData(OutputData outputData) throws
TransferFailedException {
OutputStream os;
@@ -78,23 +80,29 @@ public void fillOutputData(OutputData outputData) throws
TransferFailedException
outputData.setOutputStream(os);
}
+ @Override
public void openConnectionInternal() {}
+ @Override
public void closeConnection() {}
+ @Override
public void setTimeout(int timeoutValue) {
timeout = timeoutValue;
}
+ @Override
public int getTimeout() {
return timeout;
}
+ @Override
public List<String> getFileList(String destinationDirectory)
throws TransferFailedException, AuthorizationException {
return Collections.<String>emptyList();
}
+ @Override
public boolean resourceExists(String resourceName) throws
AuthorizationException {
return false;
}
