Package org.codehaus.plexus.taskqueue

Examples of org.codehaus.plexus.taskqueue.Task

1094
1095
1096
1097
1098
1099
1100
1101
1102
1103
1104
                        {
                            return distributedBuildQueue;
                        }
                    }

                    Task task = distributedBuildQueue.getDistributedBuildTaskQueueExecutor().getCurrentTask();
                    if ( task != null && ( (PrepareBuildProjectsTask) task ).getProjectScmRootId() == scmRootId )
                    {
                        return distributedBuildQueue;
                    }
View Full Code Here
746
747
748
749
750
751
752
753
754
755
756
        final BuildDefinition buildDef = new BuildDefinition();
        buildDef.setId( 1 );
        buildDef.setSchedule( getSchedule( 1, 1, 2 ) );

        final TaskQueueExecutor buildQueueExecutor = context.mock( TaskQueueExecutor.class, "build-queue-executor" );
        final Task buildTask = new BuildProjectTask( 1, 1, new BuildTrigger( 1, "test-user" ), "continuum-project-test-1", "BUILD_DEF", null, 1 );

        final List<BuildProjectTask> buildTasks = new ArrayList<BuildProjectTask>();
        buildTasks.add( new BuildProjectTask( 2, 1, new BuildTrigger( 1, "test-user" ), "continuum-project-test-2", "BUILD_DEF", null, 2 ) );

        final List<CheckOutTask> checkoutTasks = new ArrayList<CheckOutTask>();
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
149
150
    }

    private void assertNextBuildIs( int expectedProjectId )
        throws Exception
    {
        Task task = buildQueue.take();

        assertEquals( BuildProjectTask.class.getName(), task.getClass().getName() );

        BuildProjectTask buildProjectTask = (BuildProjectTask) task;

        assertEquals( "Didn't get the expected project id.", expectedProjectId, buildProjectTask.getProjectId() );
    }
View Full Code Here
150
151
152
153
154
155
156
157
158
159
160
    }

    private void assertNextBuildIsNull()
        throws Exception
    {
        Task task = buildQueue.take();

        if ( task != null )
        {
            fail( "Got a non-null build task returned. Project id: " + ( (BuildProjectTask) task ).getProjectId() );
        }
View Full Code Here
296
297
298
299
300
301
302
303
304
305
306
    /**
     * @see OverallBuildQueue#cancelCurrentBuild()
     */
    public boolean cancelCurrentBuild()
    {
        Task task = buildTaskQueueExecutor.getCurrentTask();
        if ( task != null )
        {
            return buildTaskQueueExecutor.cancelTask( task );
        }

View Full Code Here
311
312
313
314
315
316
317
318
319
320
321
    /**
     * @see OverallBuildQueue#cancelCurrentCheckout()
     */
    public boolean cancelCurrentCheckout()
    {
        Task task = checkoutTaskQueueExecutor.getCurrentTask();
        if ( task != null )
        {
            return checkoutTaskQueueExecutor.cancelTask( task );
        }

View Full Code Here
186
187
188
189
190
191
192
193
194
195
196
        this.buildQueue.put( task );

        System.err.println( "Waiting for task to start" );

        Task curTask;

        // Sleep at most 10 seconds for the task to start
        for ( int i = 0; i < 1000; i++ )
        {
            curTask = taskQueueExecutor.getCurrentTask();
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
    }

    private void rollback( String releaseId, ReleaseDescriptor descriptor, ContinuumReleaseManagerListener listener )
        throws ContinuumReleaseException
    {
        Task releaseTask = new RollbackReleaseProjectTask( releaseId, descriptor, (ReleaseManagerListener) listener );

        try
        {
            rollbackReleaseQueue.put( releaseTask );
        }
View Full Code Here
166
167
168
169
170
171
172
173
174
175
176
    private void stopTaskQueueExecutor( ThreadedTaskQueueExecutor taskQueueExecutor )
    {
        if ( taskQueueExecutor != null )
        {
            Task currentTask = taskQueueExecutor.getCurrentTask();
            if ( currentTask != null )
            {
                taskQueueExecutor.cancelTask( currentTask );
            }
View Full Code Here
185
186
187
188
189
190
191
192
193
194
195
        this.buildQueue.put( task );

        System.err.println( "Waiting for task to start" );

        Task curTask = null;

        // Sleep at most 10 seconds for the task to start
        for ( int i = 0; i < 1000; i++ )
        {
            curTask = taskQueueExecutor.getCurrentTask();
View Full Code Here
TOP

Related Classes of org.codehaus.plexus.taskqueue.Task

  • org.apache.archiva.web.startup.ArchivaStartup
  • org.apache.continuum.buildagent.taskqueue.manager.DefaultBuildAgentTaskQueueManager
  • org.apache.continuum.builder.distributed.executor.ThreadedDistributedBuildTaskQueueExecutor$ExecutorRunnable
  • org.apache.continuum.builder.distributed.manager.DefaultDistributedBuildManager
  • org.apache.continuum.buildmanager.ParallelBuildsManager
  • org.apache.continuum.buildmanager.ParallelBuildsManagerTest
  • org.apache.continuum.purge.DefaultContinuumPurgeManager
  • org.apache.continuum.purge.DefaultContinuumPurgeManagerTest
  • org.apache.continuum.taskqueue.DefaultOverallBuildQueue
  • org.apache.continuum.taskqueue.DefaultOverallBuildQueueTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.