public class JGroupsBackendQueueProcessor extends Object implements BackendQueueProcessor
BackendQueueProcessor.Transactional
Modifier and Type | Field and Description |
---|---|
static String |
BLOCK_WAITING_ACK
Configuration property specific the the backend instance.
|
static int |
DEFAULT_MESSAGE_TIMEOUT
Default value for the
MESSAGE_TIMEOUT_MS configuration property. |
static String |
DELEGATE_BACKEND
This JGroups backend is meant to delegate to a different backend on the
master node.
|
protected DirectoryBasedIndexManager |
indexManager |
protected String |
indexName |
static String |
MESSAGE_TIMEOUT_MS
Specifies the timeout defined on messages sent to other nodes via the JGroups
Channel.
|
protected MessageSenderService |
messageSender |
Constructor and Description |
---|
JGroupsBackendQueueProcessor(NodeSelectorStrategy selectionStrategy) |
Modifier and Type | Method and Description |
---|---|
void |
applyStreamWork(LuceneWork singleOperation,
IndexingMonitor monitor) |
void |
applyWork(List<LuceneWork> workList,
IndexingMonitor monitor) |
boolean |
blocksForACK() |
void |
close() |
org.jgroups.Address |
getAddress()
Cluster's node address
|
BackendQueueProcessor |
getDelegatedBackend() |
Lock |
getExclusiveWriteLock() |
long |
getMessageTimeout() |
void |
indexMappingChanged() |
void |
initialize(Properties props,
WorkerBuildContext context,
DirectoryBasedIndexManager indexManager) |
public static final String BLOCK_WAITING_ACK
Environment
,
Constant Field Valuespublic static final String DELEGATE_BACKEND
public static final String MESSAGE_TIMEOUT_MS
public static final int DEFAULT_MESSAGE_TIMEOUT
MESSAGE_TIMEOUT_MS
configuration property.protected MessageSenderService messageSender
protected String indexName
protected DirectoryBasedIndexManager indexManager
public JGroupsBackendQueueProcessor(NodeSelectorStrategy selectionStrategy)
public void initialize(Properties props, WorkerBuildContext context, DirectoryBasedIndexManager indexManager)
initialize
in interface BackendQueueProcessor
public void close()
close
in interface BackendQueueProcessor
public org.jgroups.Address getAddress()
public void indexMappingChanged()
indexMappingChanged
in interface BackendQueueProcessor
public void applyWork(List<LuceneWork> workList, IndexingMonitor monitor)
applyWork
in interface BackendQueueProcessor
public void applyStreamWork(LuceneWork singleOperation, IndexingMonitor monitor)
applyStreamWork
in interface BackendQueueProcessor
public Lock getExclusiveWriteLock()
getExclusiveWriteLock
in interface BackendQueueProcessor
public boolean blocksForACK()
public BackendQueueProcessor getDelegatedBackend()
public long getMessageTimeout()
Copyright © 2006–2017 Hibernate. All rights reserved.