org.springframework.data.aerospike.config

Class QueryPolicyFactoryBean

java.lang.Object

org.springframework.data.aerospike.config.ReadPolicyFactoryBean

org.springframework.data.aerospike.config.QueryPolicyFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<com.aerospike.client.policy.Policy>

public class QueryPolicyFactoryBean
extends ReadPolicyFactoryBean

A FactoryBean implementation that exposes the setters necessary to configure a QueryPolicy via XML.

Author:

Peter Milne

Constructor Summary

Constructors

Constructor and Description
QueryPolicyFactoryBean() Creates a new QueryPolicyFactoryBean.

Method Summary

Modifier and Type	Method and Description
com.aerospike.client.policy.QueryPolicy	getObject()
java.lang.Class<?>	getObjectType()
boolean	isSingleton()
void	setMaxConcurrentNodes(int maxConcurrentNodes) Configures the maximum number of concurrent requests to server nodes at any point in time.
void	setRecordQueueSize(int recordQueueSize) Configure the number of records to place in queue before blocking.

Methods inherited from class org.springframework.data.aerospike.config.ReadPolicyFactoryBean

setConsistencyLevel, setMaxRetries, setPriority, setSleepBetweenRetries, setSocketTimeout, setTotalTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryPolicyFactoryBean

public QueryPolicyFactoryBean()

Creates a new QueryPolicyFactoryBean.

Method Detail

setMaxConcurrentNodes

public void setMaxConcurrentNodes(int maxConcurrentNodes)

Configures the maximum number of concurrent requests to server nodes at any point in time. If there are 16 nodes in the cluster and maxConcurrentNodes is 8, then queries will be made to 8 nodes in parallel. When a query completes, a new query will be issued until all 16 nodes have been queried. Default (0) is to issue requests to all server nodes in parallel.

Parameters:

maxConcurrentNodes -

setRecordQueueSize

public void setRecordQueueSize(int recordQueueSize)

Configure the number of records to place in queue before blocking. Records received from multiple server nodes will be placed in a queue. A separate thread consumes these records in parallel. If the queue is full, the producer threads will block until records are consumed.

Parameters:

recordQueueSize -

getObject

public com.aerospike.client.policy.QueryPolicy getObject()
                                                  throws java.lang.Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<com.aerospike.client.policy.Policy>

Overrides:

getObject in class ReadPolicyFactoryBean

Throws:

java.lang.Exception

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<com.aerospike.client.policy.Policy>

Overrides:

isSingleton in class ReadPolicyFactoryBean

getObjectType

public java.lang.Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<com.aerospike.client.policy.Policy>

Overrides:

getObjectType in class ReadPolicyFactoryBean