public class JGroupsBackendQueueProcessor extends Object implements BackendQueueProcessor
BackendQueueProcessor.Transactional
Modifier and Type | Field and Description |
---|---|
static String |
BLOCK_WAITING_ACK
Configuration property specific to 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 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() |
long |
getMessageTimeout() |
void |
initialize(Properties props,
WorkerBuildContext context,
IndexManager indexManager) |
public static final String BLOCK_WAITING_ACK
public 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
public JGroupsBackendQueueProcessor(NodeSelectorStrategy selectionStrategy)
public void initialize(Properties props, WorkerBuildContext context, IndexManager indexManager)
initialize
in interface BackendQueueProcessor
public void close()
close
in interface BackendQueueProcessor
public org.jgroups.Address getAddress()
public void applyWork(List<LuceneWork> workList, IndexingMonitor monitor)
applyWork
in interface BackendQueueProcessor
public void applyStreamWork(LuceneWork singleOperation, IndexingMonitor monitor)
applyStreamWork
in interface BackendQueueProcessor
public boolean blocksForACK()
public BackendQueueProcessor getDelegatedBackend()
public long getMessageTimeout()
Copyright © 2006–2017 Hibernate. All rights reserved.