public void transfer()

in daemon/src/main/java/org/mvndaemon/mvnd/daemon/ClientDispatcher.java [147:202]


    public void transfer(String projectId, TransferEvent e) {
        final int event;
        switch (e.getType()) {
            case INITIATED:
                event = Message.TRANSFER_INITIATED;
                break;
            case STARTED:
                event = Message.TRANSFER_STARTED;
                break;
            case PROGRESSED:
                event = Message.TRANSFER_PROGRESSED;
                break;
            case CORRUPTED:
                event = Message.TRANSFER_CORRUPTED;
                break;
            case SUCCEEDED:
                event = Message.TRANSFER_SUCCEEDED;
                break;
            case FAILED:
                event = Message.TRANSFER_FAILED;
                break;
            default:
                throw new IllegalStateException("Unexpected " + EventType.class.getSimpleName() + ": " + e.getType());
        }
        final int requestType;
        switch (e.getRequestType()) {
            case GET:
                requestType = Message.TransferEvent.GET;
                break;
            case GET_EXISTENCE:
                requestType = Message.TransferEvent.GET_EXISTENCE;
                break;
            case PUT:
                requestType = Message.TransferEvent.PUT;
                break;
            default:
                throw new IllegalStateException(
                        "Unexpected " + RequestType.class.getSimpleName() + ": " + e.getRequestType());
        }
        String repositoryId = e.getResource().getRepositoryId();
        String repositoryUrl = e.getResource().getRepositoryUrl();
        String resourceName = e.getResource().getResourceName();
        long contentLength = e.getResource().getContentLength();
        long transferredBytes = e.getTransferredBytes();
        String exception = e.getException() != null ? e.getException().toString() : null;
        queue.add(Message.transfer(
                projectId,
                event,
                requestType,
                repositoryId,
                repositoryUrl,
                resourceName,
                contentLength,
                transferredBytes,
                exception));
    }