Package org.apache.maven.cli.transfer

Class SimplexTransferListener

java.lang.Object

org.eclipse.aether.transfer.AbstractTransferListener

org.apache.maven.cli.transfer.SimplexTransferListener

All Implemented Interfaces:

org.eclipse.aether.transfer.TransferListener

@Deprecated
public final class SimplexTransferListener
extends org.eclipse.aether.transfer.AbstractTransferListener

Deprecated.

A TransferListener implementation that wraps another delegate TransferListener but makes it run on single thread, keeping the listener logic simple. This listener also blocks on last transfer event to allow output to perform possible cleanup. It spawns a daemon thread to consume queued events that may fall in even concurrently.

Since:

4.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	SimplexTransferListener.BlockingExchange	Deprecated.
private static class	SimplexTransferListener.Exchange	Deprecated.

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	BATCH_MAX_SIZE	Deprecated.
private final int	batchMaxSize	Deprecated.
private final boolean	blockOnLastEvent	Deprecated.
private final org.eclipse.aether.transfer.TransferListener	delegate	Deprecated.
private final ArrayBlockingQueue<SimplexTransferListener.Exchange>	eventQueue	Deprecated.
private static final org.slf4j.Logger	LOGGER	Deprecated.
private final ConcurrentHashMap<TransferResourceIdentifier,Boolean>	ongoing	Deprecated.
private static final int	QUEUE_SIZE	Deprecated.

Constructor Summary

Constructors

Constructor	Description
SimplexTransferListener(org.eclipse.aether.transfer.TransferListener delegate)	Deprecated. Constructor that makes passed in delegate run on single thread, and will block on last event.
SimplexTransferListener(org.eclipse.aether.transfer.TransferListener delegate, int queueSize, int batchMaxSize, boolean blockOnLastEvent)	Deprecated. Constructor that may alter behaviour of this listener.

Method Summary

Modifier and Type	Method	Description
private void	demux(List<SimplexTransferListener.Exchange> exchanges)	Deprecated.
private void	feedConsumer()	Deprecated.
org.eclipse.aether.transfer.TransferListener	getDelegate()	Deprecated.
private void	put(org.eclipse.aether.transfer.TransferEvent event, boolean last)	Deprecated.
void	transferCorrupted(org.eclipse.aether.transfer.TransferEvent event)	Deprecated.
void	transferFailed(org.eclipse.aether.transfer.TransferEvent event)	Deprecated.
void	transferInitiated(org.eclipse.aether.transfer.TransferEvent event)	Deprecated.
void	transferProgressed(org.eclipse.aether.transfer.TransferEvent event)	Deprecated.
void	transferStarted(org.eclipse.aether.transfer.TransferEvent event)	Deprecated.
void	transferSucceeded(org.eclipse.aether.transfer.TransferEvent event)	Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

Deprecated.

QUEUE_SIZE

private static final int QUEUE_SIZE

Deprecated.

See Also:

• Constant Field Values

BATCH_MAX_SIZE

private static final int BATCH_MAX_SIZE

Deprecated.

See Also:

• Constant Field Values

delegate

private final org.eclipse.aether.transfer.TransferListener delegate

Deprecated.

batchMaxSize

private final int batchMaxSize

Deprecated.

blockOnLastEvent

private final boolean blockOnLastEvent

Deprecated.

eventQueue

private final ArrayBlockingQueue<SimplexTransferListener.Exchange> eventQueue

Deprecated.

ongoing

private final ConcurrentHashMap<TransferResourceIdentifier,Boolean> ongoing

Deprecated.

Constructor Details

SimplexTransferListener

public SimplexTransferListener(org.eclipse.aether.transfer.TransferListener delegate)

Deprecated.

Constructor that makes passed in delegate run on single thread, and will block on last event.

SimplexTransferListener

public SimplexTransferListener(org.eclipse.aether.transfer.TransferListener delegate,
 int queueSize,
 int batchMaxSize,
 boolean blockOnLastEvent)

Deprecated.

Constructor that may alter behaviour of this listener.

Parameters:

delegate - The delegate that should run on single thread.

queueSize - The event queue size (default 1024).

batchMaxSize - The maximum batch size delegate should receive (default 500).

blockOnLastEvent - Should this listener block on last transfer end (completed or corrupted) block? (default true).

Method Details

getDelegate

public org.eclipse.aether.transfer.TransferListener getDelegate()

Deprecated.

feedConsumer

private void feedConsumer()

Deprecated.

demux

private void demux(List<SimplexTransferListener.Exchange> exchanges)

Deprecated.

put

private void put(org.eclipse.aether.transfer.TransferEvent event,
 boolean last)

Deprecated.

transferInitiated

public void transferInitiated(org.eclipse.aether.transfer.TransferEvent event)

Deprecated.

Specified by:

transferInitiated in interface org.eclipse.aether.transfer.TransferListener

Overrides:

transferInitiated in class org.eclipse.aether.transfer.AbstractTransferListener

transferStarted

public void transferStarted(org.eclipse.aether.transfer.TransferEvent event)
                     throws org.eclipse.aether.transfer.TransferCancelledException

Deprecated.

Specified by:

transferStarted in interface org.eclipse.aether.transfer.TransferListener

Overrides:

transferStarted in class org.eclipse.aether.transfer.AbstractTransferListener

Throws:

org.eclipse.aether.transfer.TransferCancelledException

transferProgressed

public void transferProgressed(org.eclipse.aether.transfer.TransferEvent event)
                        throws org.eclipse.aether.transfer.TransferCancelledException

Deprecated.

Specified by:

transferProgressed in interface org.eclipse.aether.transfer.TransferListener

Overrides:

transferProgressed in class org.eclipse.aether.transfer.AbstractTransferListener

Throws:

org.eclipse.aether.transfer.TransferCancelledException

transferCorrupted

public void transferCorrupted(org.eclipse.aether.transfer.TransferEvent event)
                       throws org.eclipse.aether.transfer.TransferCancelledException

Deprecated.

Specified by:

transferCorrupted in interface org.eclipse.aether.transfer.TransferListener

Overrides:

transferCorrupted in class org.eclipse.aether.transfer.AbstractTransferListener

Throws:

org.eclipse.aether.transfer.TransferCancelledException

transferSucceeded

public void transferSucceeded(org.eclipse.aether.transfer.TransferEvent event)

Deprecated.

Specified by:

transferSucceeded in interface org.eclipse.aether.transfer.TransferListener

Overrides:

transferSucceeded in class org.eclipse.aether.transfer.AbstractTransferListener

transferFailed

public void transferFailed(org.eclipse.aether.transfer.TransferEvent event)

Deprecated.

Specified by:

transferFailed in interface org.eclipse.aether.transfer.TransferListener

Overrides:

transferFailed in class org.eclipse.aether.transfer.AbstractTransferListener