public class RemoteDelegateEngineImpl extends Object implements RemoteDelegateEngine
Constructor and Description |
---|
RemoteDelegateEngineImpl(org.apache.uima.resourceSpecifier.RemoteAnalysisEngineType draet,
RemoteDelegateConfiguration rdc,
ServiceContext context)
Instantiates a new remote delegate engine impl.
|
Modifier and Type | Method and Description |
---|---|
CasMultiplier |
getCasMultiplier()
Gets the cas multiplier.
|
DelegateConfiguration |
getConfiguration()
Gets the configuration.
|
RemoteDelegateErrorConfiguration |
getErrorConfiguration()
Gets the error configuration.
|
InputQueue |
getInputQueue()
Gets the input queue.
|
String |
getKey()
Gets the key.
|
int |
getReplyQueueScaleup()
Gets the reply queue scaleup.
|
SerializationStrategy |
getSerializationStrategy()
Gets the serialization strategy.
|
boolean |
isAggregate()
Checks if is aggregate.
|
boolean |
isRemote()
Checks if is remote.
|
void |
setCasMultiplier(CasMultiplier cm)
Sets the cas multiplier.
|
void |
setInputQueue(InputQueue iq)
Sets the input queue.
|
void |
setKey(String key)
Sets the key.
|
void |
setRemoteDelegateErrorConfiguration(RemoteDelegateErrorConfiguration er)
Sets the remote delegate error configuration.
|
void |
setReplyQueueScaleup(int remoteReplyQueueScaleout)
Sets the reply queue scaleup.
|
void |
setSerializationStrategy(SerializationStrategy ss)
Sets the serialization strategy.
|
public RemoteDelegateEngineImpl(org.apache.uima.resourceSpecifier.RemoteAnalysisEngineType draet, RemoteDelegateConfiguration rdc, ServiceContext context)
draet
- the draetrdc
- the rdccontext
- the contextpublic DelegateConfiguration getConfiguration()
DelegateAnalysisEngine
getConfiguration
in interface DelegateAnalysisEngine
public String getKey()
DelegateAnalysisEngine
getKey
in interface DelegateAnalysisEngine
public void setKey(String key)
DelegateAnalysisEngine
setKey
in interface DelegateAnalysisEngine
key
- the new keypublic int getReplyQueueScaleup()
DelegateAnalysisEngine
getReplyQueueScaleup
in interface DelegateAnalysisEngine
public void setReplyQueueScaleup(int remoteReplyQueueScaleout)
DelegateAnalysisEngine
setReplyQueueScaleup
in interface DelegateAnalysisEngine
remoteReplyQueueScaleout
- the new reply queue scaleuppublic CasMultiplier getCasMultiplier()
DelegateAnalysisEngine
getCasMultiplier
in interface DelegateAnalysisEngine
public void setCasMultiplier(CasMultiplier cm)
DelegateAnalysisEngine
setCasMultiplier
in interface DelegateAnalysisEngine
cm
- the new cas multiplierpublic InputQueue getInputQueue()
RemoteDelegateEngine
getInputQueue
in interface RemoteDelegateEngine
public void setInputQueue(InputQueue iq)
RemoteDelegateEngine
setInputQueue
in interface RemoteDelegateEngine
iq
- the new input queuepublic SerializationStrategy getSerializationStrategy()
RemoteDelegateEngine
getSerializationStrategy
in interface RemoteDelegateEngine
public void setSerializationStrategy(SerializationStrategy ss)
RemoteDelegateEngine
setSerializationStrategy
in interface RemoteDelegateEngine
ss
- the new serialization strategypublic RemoteDelegateErrorConfiguration getErrorConfiguration()
RemoteDelegateEngine
getErrorConfiguration
in interface RemoteDelegateEngine
public void setRemoteDelegateErrorConfiguration(RemoteDelegateErrorConfiguration er)
RemoteDelegateEngine
setRemoteDelegateErrorConfiguration
in interface RemoteDelegateEngine
er
- the new remote delegate error configurationpublic boolean isRemote()
DelegateAnalysisEngine
isRemote
in interface DelegateAnalysisEngine
public boolean isAggregate()
DelegateAnalysisEngine
isAggregate
in interface DelegateAnalysisEngine
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.