Package org.hibernate.search.backend.impl.jgroups

Class JGroupsBackendQueueProcessorFactory

java.lang.Object

org.hibernate.search.backend.impl.jgroups.JGroupsBackendQueueProcessorFactory

All Implemented Interfaces:

BackendQueueProcessorFactory, UpdatableBackendQueueProcessorFactory

Direct Known Subclasses:

MasterJGroupsBackendQueueProcessorFactory, SlaveJGroupsBackendQueueProcessorFactory

public abstract class JGroupsBackendQueueProcessorFactory
extends Object
implements UpdatableBackendQueueProcessorFactory

Common base class for Master and Slave BackendQueueProcessorFactories

Field Summary

Fields

Modifier and Type	Field	Description
protected org.jgroups.Address	address
protected org.jgroups.Channel	channel
protected String	clusterName
static final String	CONFIGURATION_FILE
static final String	CONFIGURATION_STRING
static final String	CONFIGURATION_XML
static final String	JG_CLUSTER_NAME
static final String	JGROUPS_PREFIX
protected SearchFactoryImplementor	searchFactory

Constructor Summary

Constructors

Constructor	Description
JGroupsBackendQueueProcessorFactory()

Method Summary

Modifier and Type	Method	Description
void	close()	Used to shutdown and eventually release resources.
org.jgroups.Address	getAddress()	Cluster's node address
org.jgroups.Channel	getChannel()
String	getClusterName()
abstract Runnable	getProcessor(List<LuceneWork> queue)	Return a runnable implementation responsible for processing the queue to a given backend.
void	initialize(Properties props, WorkerBuildContext context)	Used at startup, called once as first method.
void	setClusterName(String clusterName)
void	updateDirectoryProviders(Set<DirectoryProvider<?>> providers, WorkerBuildContext context)	Update the list of DirectoryProviders in case the SearchFactory is updated.

Methods inherited from class java.lang.Object

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

Field Details

JGROUPS_PREFIX

public static final String JGROUPS_PREFIX

See Also:

• Constant Field Values

CONFIGURATION_STRING

public static final String CONFIGURATION_STRING

See Also:

• Constant Field Values

CONFIGURATION_XML

public static final String CONFIGURATION_XML

See Also:

• Constant Field Values

CONFIGURATION_FILE

public static final String CONFIGURATION_FILE

See Also:

• Constant Field Values

JG_CLUSTER_NAME

public static final String JG_CLUSTER_NAME

See Also:

• Constant Field Values

clusterName

protected String clusterName

searchFactory

protected SearchFactoryImplementor searchFactory

channel

protected org.jgroups.Channel channel

address

protected org.jgroups.Address address

Constructor Details

JGroupsBackendQueueProcessorFactory

public JGroupsBackendQueueProcessorFactory()

Method Details

initialize

public void initialize(Properties props,
 WorkerBuildContext context)

Description copied from interface: BackendQueueProcessorFactory

Used at startup, called once as first method.

Specified by:

initialize in interface BackendQueueProcessorFactory

Parameters:

props - all configuration properties

context - context giving access to required meta data

updateDirectoryProviders

public void updateDirectoryProviders(Set<DirectoryProvider<?>> providers,
 WorkerBuildContext context)

Description copied from interface: UpdatableBackendQueueProcessorFactory

Update the list of DirectoryProviders in case the SearchFactory is updated. The processor factory should react and update its state accordingly.

Specified by:

updateDirectoryProviders in interface UpdatableBackendQueueProcessorFactory

getProcessor

public abstract Runnable getProcessor(List<LuceneWork> queue)

Description copied from interface: BackendQueueProcessorFactory

Return a runnable implementation responsible for processing the queue to a given backend.

Specified by:

getProcessor in interface BackendQueueProcessorFactory

Parameters:

queue - The work queue to process.

Returns:

Runnable which processes queue when started.

close

public void close()

Description copied from interface: BackendQueueProcessorFactory

Used to shutdown and eventually release resources. No other method should be used after this one.

Specified by:

close in interface BackendQueueProcessorFactory

getChannel

public org.jgroups.Channel getChannel()

setClusterName

public void setClusterName(String clusterName)

getClusterName

public String getClusterName()

getAddress

public org.jgroups.Address getAddress()

Cluster's node address

Returns:

Address