ByThreadStrategy (service-proxy-core 5.8.3 API)

java.lang.Object

com.predic8.membrane.core.config.AbstractXmlElement

com.predic8.membrane.core.interceptor.balancer.ByThreadStrategy

All Implemented Interfaces:: XMLElement, DispatchingStrategy

public class ByThreadStrategy extends AbstractXmlElement implements DispatchingStrategy

Constructor Summary

Constructors

Constructor

Description

ByThreadStrategy()
Method Summary

Modifier and Type

Method

Description

Node

dispatch(LoadBalancingInterceptor interceptor, AbstractExchange exc)

void

done(AbstractExchange exc)

protected String

getElementName()

int

getMaxNumberOfThreadsPerEndpoint()

int

getRetryTimeOnBusy()

void

init(Router router)

protected void

parseAttributes(XMLStreamReader token)

void

setMaxNumberOfThreadsPerEndpoint(int maxNumberOfThreadsPerEndpoint)

void

setRetryTimeOnBusy(int retryTimeOnBusy)

void

write(XMLStreamWriter out)

Methods inherited from class com.predic8.membrane.core.config.AbstractXmlElement
doAfterParsing, getBoolean, move2RootElementIfNeeded, parse, parseCharacters, parseChildren, toXml, writeIfNotNull

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- ByThreadStrategy
  
  public ByThreadStrategy()
Method Details
- done
  
  public void done(AbstractExchange exc)
  
  Specified by:
  
  done in interface DispatchingStrategy
- dispatch
  
  public Node dispatch(LoadBalancingInterceptor interceptor, AbstractExchange exc)
  
  Specified by:
  
  dispatch in interface DispatchingStrategy
- setMaxNumberOfThreadsPerEndpoint
  
  public void setMaxNumberOfThreadsPerEndpoint(int maxNumberOfThreadsPerEndpoint)
  
  Description
  
  Maximum number of concurrently running requests per endpoint.
- setRetryTimeOnBusy
  
  public void setRetryTimeOnBusy(int retryTimeOnBusy)
- getMaxNumberOfThreadsPerEndpoint
  
  public int getMaxNumberOfThreadsPerEndpoint()
- getRetryTimeOnBusy
  
  public int getRetryTimeOnBusy()
- write
  
  public void write(XMLStreamWriter out) throws XMLStreamException
  
  Specified by:
  
  write in interface XMLElement
  
  Overrides:
  
  write in class AbstractXmlElement
  
  Throws:
  
  XMLStreamException
- parseAttributes
  
  protected void parseAttributes(XMLStreamReader token)
  
  Overrides:
  
  parseAttributes in class AbstractXmlElement
- getElementName
  
  protected String getElementName()
  
  Overrides:
  
  getElementName in class AbstractXmlElement
- init
  
  public void init(Router router)
  
  Specified by:
  
  init in interface DispatchingStrategy