blob: dd6d4fa64839f23177151c2eec659cd02c4ed745 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.sling.event.impl.jobs.queues;
import java.util.concurrent.Semaphore;
/**
* Encapsulates data required to survive queue outdating
*/
class OutdatedJobQueueInfo {
private final Semaphore available;
private final int maxParallel;
private final Semaphore drainage;
OutdatedJobQueueInfo(Semaphore available, int maxParallel, Semaphore drainage) {
this.available = available;
this.maxParallel = maxParallel;
this.drainage = drainage;
}
final Semaphore getAvailable() {
return available;
}
final int getMaxParallel() {
return maxParallel;
}
final Semaphore getDrainage() {
return drainage;
}
}