AbstractWagon (Apache Maven Wagon

java.lang.Object
- org.apache.maven.wagon.AbstractWagon

All Implemented Interfaces:

Wagon

Direct Known Subclasses:

StreamWagon
```
public abstract class AbstractWagon
extends Object
implements Wagon
```
Implementation of common facilities for Wagon providers.

Author:

Michal Maczka

Field Summary

Fields
Modifier and Type	Field and Description
`protected AuthenticationInfo`	`authenticationInfo`
`protected static int`	`DEFAULT_BUFFER_SIZE`
`protected boolean`	`interactive`
`protected ProxyInfo`	`proxyInfo` Deprecated.
`protected Repository`	`repository`
`protected SessionEventSupport`	`sessionEventSupport`
`protected TransferEventSupport`	`transferEventSupport`

Fields inherited from interface org.apache.maven.wagon.Wagon
DEFAULT_CONNECTION_TIMEOUT, DEFAULT_READ_TIMEOUT, ROLE

Constructor Summary

Constructors
Constructor and Description

AbstractWagon()

Constructors
Constructor and Description
`AbstractWagon()`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`addSessionListener(SessionListener listener)`
`void`	`addTransferListener(TransferListener listener)`
`protected void`	`cleanupGetTransfer(Resource resource)`
`protected void`	`cleanupPutTransfer(Resource resource)`
`protected abstract void`	`closeConnection()`
`void`	`connect(Repository repository)` Initiate the connection to the repository.
`void`	`connect(Repository repository, AuthenticationInfo authenticationInfo)` Initiate the connection to the repository.
`void`	`connect(Repository repository, AuthenticationInfo authenticationInfo, ProxyInfo proxyInfo)` Initiate the connection to the repository.
`void`	`connect(Repository repository, AuthenticationInfo authenticationInfo, ProxyInfoProvider proxyInfoProvider)` Initiate the connection to the repository.
`void`	`connect(Repository repository, ProxyInfo proxyInfo)` Initiate the connection to the repository.
`void`	`connect(Repository repository, ProxyInfoProvider proxyInfoProvider)` Initiate the connection to the repository.
`protected void`	`createParentDirectories(File destination)`
`void`	`disconnect()` Disconnect from the repository.
`protected void`	`finishGetTransfer(Resource resource, InputStream input, OutputStream output)`
`protected void`	`finishPutTransfer(Resource resource, InputStream input, OutputStream output)`
`protected void`	`fireGetCompleted(Resource resource, File localFile)`
`protected void`	`fireGetInitiated(Resource resource, File localFile)`
`protected void`	`fireGetStarted(Resource resource, File localFile)`
`protected void`	`firePutCompleted(Resource resource, File localFile)`
`protected void`	`firePutInitiated(Resource resource, File localFile)`
`protected void`	`firePutStarted(Resource resource, File localFile)`
`protected void`	`fireSessionConnectionRefused()`
`protected void`	`fireSessionDebug(String message)`
`protected void`	`fireSessionDisconnected()`
`protected void`	`fireSessionDisconnecting()`
`protected void`	`fireSessionError(Exception exception)`
`protected void`	`fireSessionLoggedIn()`
`protected void`	`fireSessionLoggedOff()`
`protected void`	`fireSessionOpened()`
`protected void`	`fireSessionOpening()`
`protected void`	`fireTransferDebug(String message)`
`protected void`	`fireTransferError(Resource resource, Exception e, int requestType)`
`protected void`	`fireTransferProgress(TransferEvent transferEvent, byte[] buffer, int n)`
`AuthenticationInfo`	`getAuthenticationInfo()`
`List<String>`	`getFileList(String destinationDirectory)` Returns a `List` of strings naming the files and directories in the directory denoted by this abstract pathname.
`protected static String`	`getPath(String basedir, String dir)`
`RepositoryPermissions`	`getPermissionsOverride()`
`ProxyInfo`	`getProxyInfo()`
`protected ProxyInfo`	`getProxyInfo(String protocol, String host)`
`int`	`getReadTimeout()` Get the read timeout limit in milliseconds
`Repository`	`getRepository()`
`SessionEventSupport`	`getSessionEventSupport()`
`int`	`getTimeout()` Get the connection timeout limit in milliseconds
`protected void`	`getTransfer(Resource resource, File destination, InputStream input)`
`protected void`	`getTransfer(Resource resource, File destination, InputStream input, boolean closeInput, int maxSize)` Deprecated.
`protected void`	`getTransfer(Resource resource, File destination, InputStream input, boolean closeInput, long maxSize)`
`protected void`	`getTransfer(Resource resource, OutputStream output, InputStream input)`
`protected void`	`getTransfer(Resource resource, OutputStream output, InputStream input, boolean closeInput, int maxSize)` Deprecated.
`protected void`	`getTransfer(Resource resource, OutputStream output, InputStream input, boolean closeInput, long maxSize)`
`TransferEventSupport`	`getTransferEventSupport()`
`boolean`	`hasSessionListener(SessionListener listener)`
`boolean`	`hasTransferListener(TransferListener listener)`
`boolean`	`isInteractive()`
`void`	`openConnection()` Initiate the connection to the repository.
`protected abstract void`	`openConnectionInternal()`
`protected void`	`postProcessListeners(Resource resource, File source, int requestType)` This method is used if you are not streaming the transfer, to make sure any listeners dependent on state (eg checksum observers) succeed.
`void`	`putDirectory(File sourceDirectory, String destinationDirectory)` Copy a directory from local system to remote
`protected void`	`putTransfer(Resource resource, File source, OutputStream output, boolean closeOutput)`
`protected void`	`putTransfer(Resource resource, InputStream input, OutputStream output, boolean closeOutput)`
`void`	`removeSessionListener(SessionListener listener)`
`void`	`removeTransferListener(TransferListener listener)`
`boolean`	`resourceExists(String resourceName)` Check if a remote resource exists
`void`	`setInteractive(boolean interactive)`
`void`	`setPermissionsOverride(RepositoryPermissions permissionsOverride)`
`void`	`setReadTimeout(int readTimeout)` Set the read timeout limit in milliseconds
`void`	`setSessionEventSupport(SessionEventSupport sessionEventSupport)`
`void`	`setTimeout(int timeoutValue)` Set the connection timeout limit in milliseconds
`void`	`setTransferEventSupport(TransferEventSupport transferEventSupport)`
`boolean`	`supportsDirectoryCopy()` Flag indicating if this wagon supports directory copy operations.
`protected void`	`transfer(Resource resource, File source, OutputStream output, boolean closeOutput)` Write from `File` to `OutputStream`
`protected void`	`transfer(Resource resource, InputStream input, OutputStream output, int requestType)` Write from `InputStream` to `OutputStream`.
`protected void`	`transfer(Resource resource, InputStream input, OutputStream output, int requestType, int maxSize)` Deprecated. Please use the transfer using long as type of maxSize
`protected void`	`transfer(Resource resource, InputStream input, OutputStream output, int requestType, long maxSize)` Write from `InputStream` to `OutputStream`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.maven.wagon.Wagon
get, getIfNewer, put

Field Detail

DEFAULT_BUFFER_SIZE
```
protected static final int DEFAULT_BUFFER_SIZE
```
See Also:
Constant Field Values

repository
```
protected Repository repository
```

sessionEventSupport

protected SessionEventSupport sessionEventSupport

transferEventSupport

protected TransferEventSupport transferEventSupport

authenticationInfo

protected AuthenticationInfo authenticationInfo

interactive
```
protected boolean interactive
```

proxyInfo
```
protected ProxyInfo proxyInfo
```
Deprecated.

Constructor Detail
- AbstractWagon
```
public AbstractWagon()
```

Method Detail

getRepository
```
public Repository getRepository()
```
Specified by:

getRepository in interface Wagon

getProxyInfo
```
public ProxyInfo getProxyInfo()
```

getAuthenticationInfo

public AuthenticationInfo getAuthenticationInfo()

openConnection
```
public void openConnection()
                    throws ConnectionException,
                           AuthenticationException
```
Description copied from interface: Wagon

Initiate the connection to the repository.

Specified by:

openConnection in interface Wagon

Throws:

ConnectionException - if there is a problem connecting

AuthenticationException - if ther credentials for connecting are not sufficient

connect
```
public void connect(Repository repository)
             throws ConnectionException,
                    AuthenticationException
```
Description copied from interface: Wagon

Initiate the connection to the repository.

Specified by:

connect in interface Wagon

Parameters:
repository - the repository to connect to

Throws:

ConnectionException - if there is a problem connecting

AuthenticationException - if the credentials for connecting are not sufficient

connect
```
public void connect(Repository repository,
           ProxyInfo proxyInfo)
             throws ConnectionException,
                    AuthenticationException
```
Description copied from interface: Wagon

Initiate the connection to the repository.

Specified by:

connect in interface Wagon

Parameters:
repository - the repository to connect to

Throws:

ConnectionException - if there is a problem connecting

AuthenticationException - if the credentials for connecting are not sufficient

connect
```
public void connect(Repository repository,
           ProxyInfoProvider proxyInfoProvider)
             throws ConnectionException,
                    AuthenticationException
```
Description copied from interface: Wagon

Initiate the connection to the repository.

Specified by:

connect in interface Wagon

Parameters:
repository - the repository to connect to
proxyInfoProvider - the provider to obtain a network proxy to use to connect to the remote repository

Throws:

ConnectionException - if there is a problem connecting

AuthenticationException - if the credentials for connecting are not sufficient

connect
```
public void connect(Repository repository,
           AuthenticationInfo authenticationInfo)
             throws ConnectionException,
                    AuthenticationException
```
Description copied from interface: Wagon

Initiate the connection to the repository.

Specified by:

connect in interface Wagon

Parameters:
repository - the repository to connect to
authenticationInfo - authentication credentials for connecting

Throws:

ConnectionException - if there is a problem connecting

AuthenticationException - if the credentials for connecting are not sufficient

connect
```
public void connect(Repository repository,
           AuthenticationInfo authenticationInfo,
           ProxyInfo proxyInfo)
             throws ConnectionException,
                    AuthenticationException
```
Description copied from interface: Wagon

Initiate the connection to the repository.

Specified by:

connect in interface Wagon

Parameters:
repository - the repository to connect to
authenticationInfo - authentication credentials for connecting
proxyInfo - the network proxy to use to connect to the remote repository

Throws:

ConnectionException - if there is a problem connecting

AuthenticationException - if the credentials for connecting are not sufficient

connect
```
public void connect(Repository repository,
           AuthenticationInfo authenticationInfo,
           ProxyInfoProvider proxyInfoProvider)
             throws ConnectionException,
                    AuthenticationException
```
Description copied from interface: Wagon

Initiate the connection to the repository.

Specified by:

connect in interface Wagon

Parameters:
repository - the repository to connect to
authenticationInfo - authentication credentials for connecting
proxyInfoProvider - the provider to obtain a network proxy to use to connect to the remote repository

Throws:

ConnectionException - if there is a problem connecting

AuthenticationException - if the credentials for connecting are not sufficient

openConnectionInternal

protected abstract void openConnectionInternal()
                                        throws ConnectionException,
                                               AuthenticationException

Throws:: ConnectionException; AuthenticationException

disconnect
```
public void disconnect()
                throws ConnectionException
```
Description copied from interface: Wagon

Disconnect from the repository.

Specified by:

disconnect in interface Wagon

Throws:

ConnectionException - if there is a problem disconnecting

closeConnection

protected abstract void closeConnection()
                                 throws ConnectionException

Throws:: ConnectionException

createParentDirectories

protected void createParentDirectories(File destination)
                                throws TransferFailedException

Throws:: TransferFailedException

setTimeout
```
public void setTimeout(int timeoutValue)
```
Description copied from interface: Wagon

Set the connection timeout limit in milliseconds

Specified by:

setTimeout in interface Wagon

getTimeout
```
public int getTimeout()
```
Description copied from interface: Wagon

Get the connection timeout limit in milliseconds

Specified by:

getTimeout in interface Wagon

getTransfer

protected void getTransfer(Resource resource,
               File destination,
               InputStream input)
                    throws TransferFailedException

Throws:: TransferFailedException

getTransfer

protected void getTransfer(Resource resource,
               OutputStream output,
               InputStream input)
                    throws TransferFailedException

Throws:: TransferFailedException

getTransfer

@Deprecated
protected void getTransfer(Resource resource,
                          File destination,
                          InputStream input,
                          boolean closeInput,
                          int maxSize)
                    throws TransferFailedException

Deprecated.

Throws:: TransferFailedException

getTransfer

protected void getTransfer(Resource resource,
               File destination,
               InputStream input,
               boolean closeInput,
               long maxSize)
                    throws TransferFailedException

Throws:: TransferFailedException

getTransfer

@Deprecated
protected void getTransfer(Resource resource,
                          OutputStream output,
                          InputStream input,
                          boolean closeInput,
                          int maxSize)
                    throws TransferFailedException

Deprecated.

Throws:: TransferFailedException

getTransfer

protected void getTransfer(Resource resource,
               OutputStream output,
               InputStream input,
               boolean closeInput,
               long maxSize)
                    throws TransferFailedException

Throws:: TransferFailedException

finishGetTransfer

protected void finishGetTransfer(Resource resource,
                     InputStream input,
                     OutputStream output)
                          throws TransferFailedException

Throws:: TransferFailedException

cleanupGetTransfer

protected void cleanupGetTransfer(Resource resource)

putTransfer

protected void putTransfer(Resource resource,
               File source,
               OutputStream output,
               boolean closeOutput)
                    throws TransferFailedException,
                           AuthorizationException,
                           ResourceDoesNotExistException

Throws:: TransferFailedException; AuthorizationException; ResourceDoesNotExistException

transfer

protected void transfer(Resource resource,
            File source,
            OutputStream output,
            boolean closeOutput)
                 throws TransferFailedException,
                        AuthorizationException,
                        ResourceDoesNotExistException

Write from File to OutputStream

Parameters:: resource - resource to transfer; source - file to read from; output - output stream; closeOutput - whether the output stream should be closed or not
Throws:: TransferFailedException; ResourceDoesNotExistException; AuthorizationException
Since:: 1.0-beta-1

putTransfer

protected void putTransfer(Resource resource,
               InputStream input,
               OutputStream output,
               boolean closeOutput)
                    throws TransferFailedException,
                           AuthorizationException,
                           ResourceDoesNotExistException

Throws:: TransferFailedException; AuthorizationException; ResourceDoesNotExistException

cleanupPutTransfer

protected void cleanupPutTransfer(Resource resource)

finishPutTransfer

protected void finishPutTransfer(Resource resource,
                     InputStream input,
                     OutputStream output)
                          throws TransferFailedException,
                                 AuthorizationException,
                                 ResourceDoesNotExistException

Throws:: TransferFailedException; AuthorizationException; ResourceDoesNotExistException

transfer
```
protected void transfer(Resource resource,
            InputStream input,
            OutputStream output,
            int requestType)
                 throws IOException
```
Write from InputStream to OutputStream. Equivalent to transfer(Resource, InputStream, OutputStream, int, int) with a maxSize equals to Integer.MAX_VALUE

Parameters:
resource - resource to transfer
input - input stream
output - output stream
requestType - one of TransferEvent.REQUEST_GET or TransferEvent.REQUEST_PUT

Throws:

IOException

transfer
```
@Deprecated
protected void transfer(Resource resource,
                       InputStream input,
                       OutputStream output,
                       int requestType,
                       int maxSize)
                 throws IOException
```
Deprecated. Please use the transfer using long as type of maxSize

Write from InputStream to OutputStream. Equivalent to transfer(Resource, InputStream, OutputStream, int, int) with a maxSize equals to Integer.MAX_VALUE

Parameters:
resource - resource to transfer
input - input stream
output - output stream
requestType - one of TransferEvent.REQUEST_GET or TransferEvent.REQUEST_PUT
maxSize - size of the buffer

Throws:

IOException

transfer
```
protected void transfer(Resource resource,
            InputStream input,
            OutputStream output,
            int requestType,
            long maxSize)
                 throws IOException
```
Write from InputStream to OutputStream. Equivalent to transfer(Resource, InputStream, OutputStream, int, long) with a maxSize equals to Integer.MAX_VALUE

Parameters:
resource - resource to transfer
input - input stream
output - output stream
requestType - one of TransferEvent.REQUEST_GET or TransferEvent.REQUEST_PUT
maxSize - size of the buffer

Throws:

IOException

fireTransferProgress

protected void fireTransferProgress(TransferEvent transferEvent,
                        byte[] buffer,
                        int n)

fireGetCompleted

protected void fireGetCompleted(Resource resource,
                    File localFile)

fireGetStarted

protected void fireGetStarted(Resource resource,
                  File localFile)

fireGetInitiated

protected void fireGetInitiated(Resource resource,
                    File localFile)

firePutInitiated

protected void firePutInitiated(Resource resource,
                    File localFile)

firePutCompleted

protected void firePutCompleted(Resource resource,
                    File localFile)

firePutStarted

protected void firePutStarted(Resource resource,
                  File localFile)

fireSessionDisconnected

protected void fireSessionDisconnected()

fireSessionDisconnecting

protected void fireSessionDisconnecting()

fireSessionLoggedIn
```
protected void fireSessionLoggedIn()
```

fireSessionLoggedOff
```
protected void fireSessionLoggedOff()
```

fireSessionOpened
```
protected void fireSessionOpened()
```

fireSessionOpening
```
protected void fireSessionOpening()
```

fireSessionConnectionRefused

protected void fireSessionConnectionRefused()

fireSessionError

protected void fireSessionError(Exception exception)

fireTransferDebug

protected void fireTransferDebug(String message)

fireSessionDebug

protected void fireSessionDebug(String message)

hasTransferListener

public boolean hasTransferListener(TransferListener listener)

Specified by:: hasTransferListener in interface Wagon

addTransferListener
```
public void addTransferListener(TransferListener listener)
```
Specified by:

addTransferListener in interface Wagon

removeTransferListener
```
public void removeTransferListener(TransferListener listener)
```
Specified by:

removeTransferListener in interface Wagon

addSessionListener
```
public void addSessionListener(SessionListener listener)
```
Specified by:

addSessionListener in interface Wagon

hasSessionListener

public boolean hasSessionListener(SessionListener listener)

Specified by:: hasSessionListener in interface Wagon

removeSessionListener
```
public void removeSessionListener(SessionListener listener)
```
Specified by:

removeSessionListener in interface Wagon

fireTransferError

protected void fireTransferError(Resource resource,
                     Exception e,
                     int requestType)

getSessionEventSupport

public SessionEventSupport getSessionEventSupport()

setSessionEventSupport

public void setSessionEventSupport(SessionEventSupport sessionEventSupport)

getTransferEventSupport

public TransferEventSupport getTransferEventSupport()

setTransferEventSupport

public void setTransferEventSupport(TransferEventSupport transferEventSupport)

postProcessListeners

protected void postProcessListeners(Resource resource,
                        File source,
                        int requestType)
                             throws TransferFailedException

This method is used if you are not streaming the transfer, to make sure any listeners dependent on state (eg checksum observers) succeed.

Throws:: TransferFailedException

putDirectory

public void putDirectory(File sourceDirectory,
                String destinationDirectory)
                  throws TransferFailedException,
                         ResourceDoesNotExistException,
                         AuthorizationException

Description copied from interface: Wagon

Copy a directory from local system to remote

Specified by:: putDirectory in interface Wagon
Parameters:: sourceDirectory - the local directory; destinationDirectory - the remote destination
Throws:: TransferFailedException; ResourceDoesNotExistException; AuthorizationException

supportsDirectoryCopy
```
public boolean supportsDirectoryCopy()
```
Description copied from interface: Wagon

Flag indicating if this wagon supports directory copy operations.

Specified by:

supportsDirectoryCopy in interface Wagon

Returns:
whether if this wagon supports directory operations

getPath

protected static String getPath(String basedir,
             String dir)

isInteractive
```
public boolean isInteractive()
```
Specified by:

isInteractive in interface Wagon

setInteractive
```
public void setInteractive(boolean interactive)
```
Specified by:

setInteractive in interface Wagon

getFileList
```
public List<String> getFileList(String destinationDirectory)
                         throws TransferFailedException,
                                ResourceDoesNotExistException,
                                AuthorizationException
```
Description copied from interface: Wagon

Returns a List of strings naming the files and directories in the directory denoted by this abstract pathname.

If this abstract pathname does not denote a directory, or does not exist, then this method throws ResourceDoesNotExistException. Otherwise a List of strings is returned, one for each file or directory in the directory. Names denoting the directory itself and the directory's parent directory are not included in the result. Each string is a file name rather than a complete path.

There is no guarantee that the name strings in the resulting list will appear in any specific order; they are not, in particular, guaranteed to appear in alphabetical order.

Specified by:

getFileList in interface Wagon

Parameters:
destinationDirectory - directory to list contents of

Returns:
A List of strings naming the files and directories in the directory denoted by this abstract pathname. The List will be empty if the directory is empty.

Throws:

TransferFailedException - if there's an error trying to access the remote side

ResourceDoesNotExistException - if destinationDirectory does not exist or is not a directory

AuthorizationException - if not authorized to list the contents of the directory

resourceExists
```
public boolean resourceExists(String resourceName)
                       throws TransferFailedException,
                              AuthorizationException
```
Description copied from interface: Wagon

Check if a remote resource exists

Specified by:

resourceExists in interface Wagon

Returns:
whether the resource exists or not

Throws:

TransferFailedException - if there's an error trying to access the remote side

AuthorizationException - if not authorized to verify the existence of the resource

getProxyInfo

protected ProxyInfo getProxyInfo(String protocol,
                     String host)

getPermissionsOverride

public RepositoryPermissions getPermissionsOverride()

setPermissionsOverride

public void setPermissionsOverride(RepositoryPermissions permissionsOverride)

setReadTimeout
```
public void setReadTimeout(int readTimeout)
```
Description copied from interface: Wagon

Set the read timeout limit in milliseconds

Specified by:

setReadTimeout in interface Wagon

getReadTimeout
```
public int getReadTimeout()
```
Description copied from interface: Wagon

Get the read timeout limit in milliseconds

Specified by:

getReadTimeout in interface Wagon

Class AbstractWagon

Field Summary

Fields inherited from interface org.apache.maven.wagon.Wagon

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.maven.wagon.Wagon

Field Detail

DEFAULT_BUFFER_SIZE

repository

sessionEventSupport

transferEventSupport

authenticationInfo

interactive

proxyInfo

Constructor Detail

AbstractWagon

Method Detail

getRepository

getProxyInfo

getAuthenticationInfo

openConnection

connect

connect

connect

connect

connect

connect

openConnectionInternal

disconnect

closeConnection

createParentDirectories

setTimeout

getTimeout

getTransfer

getTransfer

getTransfer

getTransfer

getTransfer

getTransfer

finishGetTransfer

cleanupGetTransfer

putTransfer

transfer

putTransfer

cleanupPutTransfer

finishPutTransfer

transfer

transfer

transfer

fireTransferProgress

fireGetCompleted

fireGetStarted

fireGetInitiated

firePutInitiated

firePutCompleted

firePutStarted

fireSessionDisconnected

fireSessionDisconnecting

fireSessionLoggedIn

fireSessionLoggedOff

fireSessionOpened

fireSessionOpening

fireSessionConnectionRefused

fireSessionError

fireTransferDebug

fireSessionDebug

hasTransferListener

addTransferListener

removeTransferListener

addSessionListener

hasSessionListener

removeSessionListener

fireTransferError

getSessionEventSupport

setSessionEventSupport

getTransferEventSupport

setTransferEventSupport

postProcessListeners

putDirectory