/*
* Copyright Terracotta, Inc.
*
* Licensed 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.ehcache.impl.config.loaderwriter.writebehind;
import org.ehcache.spi.loaderwriter.WriteBehindConfiguration;
import org.ehcache.spi.loaderwriter.WriteBehindProvider;
ServiceConfiguration
for the default WriteBehindProvider
. /**
* {@link org.ehcache.spi.service.ServiceConfiguration} for the default {@link WriteBehindProvider}.
*/
public class DefaultWriteBehindConfiguration implements WriteBehindConfiguration<Void> {
private final BatchingConfiguration batchingConfig;
private final int concurrency;
private final int queueSize;
private final String executorAlias;
Creates a new configuration with the provided parameters.
Params: - executorAlias – the thread pool alias
- concurrency – the write-behind concurrency
- queueSize – the maximum queue size
- batchingConfig – optional batching configuration
/**
* Creates a new configuration with the provided parameters.
*
* @param executorAlias the thread pool alias
* @param concurrency the write-behind concurrency
* @param queueSize the maximum queue size
* @param batchingConfig optional batching configuration
*/
public DefaultWriteBehindConfiguration(String executorAlias, int concurrency, int queueSize, BatchingConfiguration batchingConfig) {
this.concurrency = concurrency;
this.queueSize = queueSize;
this.executorAlias = executorAlias;
this.batchingConfig = batchingConfig;
}
{@inheritDoc}
/**
* {@inheritDoc}
*/
@Override
public int getConcurrency() {
return concurrency;
}
{@inheritDoc}
/**
* {@inheritDoc}
*/
@Override
public int getMaxQueueSize() {
return queueSize;
}
{@inheritDoc}
/**
* {@inheritDoc}
*/
@Override
public String getThreadPoolAlias() {
return executorAlias;
}
{@inheritDoc}
/**
* {@inheritDoc}
*/
@Override
public BatchingConfiguration getBatchingConfiguration() {
return batchingConfig;
}
{@inheritDoc}
/**
* {@inheritDoc}
*/
@Override
public Class<WriteBehindProvider> getServiceType() {
return WriteBehindProvider.class;
}
}