Examples of TransferEvent

com.googlecode.richrest.client.event.TransferEvent
处理工作事件信息 @author liangfei
org.apache.maven.wagon.events.TransferEvent
TransferEvent is used to notify TransferListeners about progress in transfer of resources form/to the repository @author Michal Maczka @version $Id: TransferEvent.java 1133758 2011-06-09 09:53:31Z struberg $
org.eclipse.aether.transfer.TransferEvent

Examples of com.googlecode.richrest.client.event.TransferEvent

    }
    return Collections.unmodifiableCollection(copies);
  }


  protected void addTransfer(Transfer execution, Abortable abortor) {
    transportationPublisher.publishEvent(new TransferEvent(AbstractTransferrer.this, execution));
    synchronized (executions) {
      if (executions.size() >= maxConnectionSize) {
        try {
          executions.wait();
        } catch (InterruptedException e) {
          // ignore
        }
      }
      executions.add(execution);
    }
    execution.transferring(abortor);
    transportationPublisher.publishEvent(new TransferEvent(AbstractTransferrer.this, execution));
  }

View Full Code Here

Examples of com.googlecode.richrest.client.event.TransferEvent

    synchronized (executions) {
      executions.remove(execution);
      executions.notify();
    }
    execution.transferred(result);
    transportationPublisher.publishEvent(new TransferEvent(AbstractTransferrer.this, execution));
  }

View Full Code Here

Examples of org.apache.maven.wagon.events.TransferEvent

    {
        ChecksumObserver listener = new ChecksumObserver( "SHA-1" );


        Resource resource = new Resource( "resource" );


        TransferEvent transferEvent =
            new TransferEvent( wagon, resource, TransferEvent.TRANSFER_INITIATED, TransferEvent.REQUEST_GET );


        listener.transferInitiated( transferEvent );


        transferEvent = new TransferEvent( wagon, resource, TransferEvent.TRANSFER_STARTED, TransferEvent.REQUEST_GET );


        listener.transferStarted( transferEvent );


        transferEvent = new TransferEvent( wagon, resource, TransferEvent.TRANSFER_PROGRESS, TransferEvent.REQUEST_GET );


        listener.transferProgress( transferEvent, "checksum\n".getBytes(), 9 );


        transferEvent =
            new TransferEvent( wagon, resource, TransferEvent.TRANSFER_COMPLETED, TransferEvent.REQUEST_GET );


        listener.transferCompleted( transferEvent );


        assertEquals( "2e5daf0201ddeb068a62d5e08da18657ab2c6be9", listener.getActualChecksum() );
    }

View Full Code Here

Examples of org.apache.maven.wagon.events.TransferEvent


        transferListener.transferInitiated( null );
        transferListenerControl.setMatcher( MockControl.ALWAYS_MATCHER );
        transferListener.transferStarted( null );
        transferListenerControl.setMatcher( MockControl.ALWAYS_MATCHER );
        TransferEvent event =
            new TransferEvent( wagon, resource, TransferEvent.TRANSFER_PROGRESS, TransferEvent.REQUEST_PUT );
        event.setLocalFile( tempFile );
        transferListener.transferProgress( event, content.getBytes(), content.length() );
        ProgressArgumentMatcher matcher = new ProgressArgumentMatcher();
        transferListenerControl.setMatcher( matcher );
        transferListener.transferCompleted( null );
        transferListenerControl.setMatcher( MockControl.ALWAYS_MATCHER );

View Full Code Here

Examples of org.apache.maven.wagon.events.TransferEvent

    }


    protected TransferEvent createTransferEvent( Wagon wagon, Resource resource, int eventType, int requestType,
                                                 File file )
    {
        TransferEvent transferEvent = new TransferEvent( wagon, resource, eventType, requestType );
        transferEvent.setLocalFile( file );
        return transferEvent;
    }

View Full Code Here

Examples of org.apache.maven.wagon.events.TransferEvent

        public void writeRequest( OutputStream output )
            throws IOException
        {
            byte[] buffer = new byte[DEFAULT_BUFFER_SIZE];


            TransferEvent transferEvent =
                new TransferEvent( wagon, resource, TransferEvent.TRANSFER_PROGRESS, TransferEvent.REQUEST_PUT );
            transferEvent.setTimestamp( System.currentTimeMillis() );


            InputStream fin = null;
            try
            {
                fin = this.source != null

View Full Code Here

Examples of org.apache.maven.wagon.events.TransferEvent

        fireGetStarted( resource, destination );
        try
        {
            byte[] bytes = data.getBytes( "UTF-8" );
            FileUtils.fileWrite( destination.getPath(), "UTF-8", data );
            fireTransferProgress( new TransferEvent( this, resource, TransferEvent.TRANSFER_PROGRESS,
                                                     TransferEvent.REQUEST_GET ), bytes, bytes.length );
        }
        catch ( IOException e )
        {
            return false;

View Full Code Here

Examples of org.apache.maven.wagon.events.TransferEvent

    }


    protected TransferEvent createTransferEvent( Wagon wagon, Resource resource, int eventType, int requestType,
                                                 File file )
    {
        TransferEvent transferEvent = new TransferEvent( wagon, resource, eventType, requestType );
        transferEvent.setLocalFile( file );
        return transferEvent;
    }

View Full Code Here

Examples of org.apache.maven.wagon.events.TransferEvent

            createTransferEvent( wagon, resource, TransferEvent.TRANSFER_INITIATED, TransferEvent.REQUEST_GET,
                                 destFile ) );
        resource = new Resource( this.resource );
        resource.setContentLength( getExpectedContentLengthOnGet( expectedSize ) );
        resource.setLastModified( getExpectedLastModifiedOnGet( testRepository, resource ) );
        TransferEvent te =
            createTransferEvent( wagon, resource, TransferEvent.TRANSFER_STARTED, TransferEvent.REQUEST_GET, null );
        mockTransferListener.transferStarted( te );
        mockTransferListener.transferProgress(
            eq( new TransferEvent( wagon, resource, TransferEvent.TRANSFER_PROGRESS, TransferEvent.REQUEST_GET ) ),
            anyObject( byte[].class ), anyInt() );


        ProgressAnswer progressAnswer = new ProgressAnswer();


        if ( assertOnTransferProgress() )

View Full Code Here

Examples of org.apache.maven.wagon.events.TransferEvent

        {
            if ( outstream == null )
            {
                throw new IllegalArgumentException( "Output stream may not be null" );
            }
            TransferEvent transferEvent =
                new TransferEvent( wagon, resource, TransferEvent.TRANSFER_PROGRESS, TransferEvent.REQUEST_PUT );
            transferEvent.setTimestamp( System.currentTimeMillis() );
            InputStream instream = ( this.source != null )
                ? new FileInputStream( this.source )
                : new ByteArrayInputStream( this.byteBuffer.array() );
            try
            {

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.