Skip to content

Commit

Permalink
Remove redundant allocation of ConfigurationBuilder.
Browse files Browse the repository at this point in the history
  • Loading branch information
pferraro committed Mar 31, 2018
1 parent d6b7eb0 commit dc90003
Showing 1 changed file with 8 additions and 10 deletions.
Expand Up @@ -24,9 +24,9 @@


import static org.jboss.as.clustering.infinispan.subsystem.ClusteredCacheResourceDefinition.Attribute.*; import static org.jboss.as.clustering.infinispan.subsystem.ClusteredCacheResourceDefinition.Attribute.*;


import java.util.concurrent.TimeUnit;

import org.infinispan.configuration.cache.CacheMode; import org.infinispan.configuration.cache.CacheMode;
import org.infinispan.configuration.cache.ClusteringConfiguration;
import org.infinispan.configuration.cache.ClusteringConfigurationBuilder;
import org.infinispan.configuration.cache.Configuration; import org.infinispan.configuration.cache.Configuration;
import org.infinispan.configuration.cache.ConfigurationBuilder; import org.infinispan.configuration.cache.ConfigurationBuilder;
import org.jboss.as.controller.OperationContext; import org.jboss.as.controller.OperationContext;
Expand All @@ -43,7 +43,7 @@ public class ClusteredCacheBuilder extends CacheConfigurationBuilder {


private final CacheMode mode; private final CacheMode mode;


private volatile ClusteringConfiguration clustering; private volatile long remoteTimeout;


ClusteredCacheBuilder(PathAddress address, CacheMode mode) { ClusteredCacheBuilder(PathAddress address, CacheMode mode) {
super(address); super(address);
Expand All @@ -52,18 +52,16 @@ public class ClusteredCacheBuilder extends CacheConfigurationBuilder {


@Override @Override
public Builder<Configuration> configure(OperationContext context, ModelNode model) throws OperationFailedException { public Builder<Configuration> configure(OperationContext context, ModelNode model) throws OperationFailedException {
ClusteringConfigurationBuilder builder = new ConfigurationBuilder().clustering().cacheMode(this.mode); this.remoteTimeout = REMOTE_TIMEOUT.resolveModelAttribute(context, model).asLong();

builder.remoteTimeout(REMOTE_TIMEOUT.resolveModelAttribute(context, model).asLong());

this.clustering = builder.create();

return super.configure(context, model); return super.configure(context, model);
} }


@Override @Override
public void accept(ConfigurationBuilder builder) { public void accept(ConfigurationBuilder builder) {
builder.clustering().read(this.clustering); builder.clustering()
.cacheMode(this.mode)
.remoteTimeout(this.remoteTimeout, TimeUnit.MILLISECONDS)
;
super.accept(builder); super.accept(builder);
} }
} }

0 comments on commit dc90003

Please sign in to comment.