Package org.jumpmind.symmetric.web

Class NodeConcurrencyInterceptor

java.lang.Object

org.jumpmind.symmetric.web.NodeConcurrencyInterceptor

All Implemented Interfaces:

IInterceptor

public class NodeConcurrencyInterceptor
extends Object
implements IInterceptor

An intercepter that controls access to this node for pushes and pulls. It is configured within symmetric-web.xml

Constructor Summary

Constructors

Constructor	Description
NodeConcurrencyInterceptor(IConcurrentConnectionManager concurrentConnectionManager, IConfigurationService configurationService, INodeService nodeService, IStatisticManager statisticManager)

Method Summary

Modifier and Type	Method	Description
void	after(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
boolean	before(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
protected void	buildSuspendIgnoreResponseHeaders(String nodeId, jakarta.servlet.ServletResponse resp)
protected String	getNodeId(jakarta.servlet.http.HttpServletRequest req)
protected void	sendError(jakarta.servlet.http.HttpServletResponse resp, IConcurrentConnectionManager.ReservationStatus status, String nodeId)

Methods inherited from class java.lang.Object

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

Constructor Details

NodeConcurrencyInterceptor

public NodeConcurrencyInterceptor(IConcurrentConnectionManager concurrentConnectionManager,
 IConfigurationService configurationService,
 INodeService nodeService,
 IStatisticManager statisticManager)

Method Details

before

public boolean before(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)
               throws IOException,
jakarta.servlet.ServletException

Specified by:

before in interface IInterceptor

Throws:

IOException

jakarta.servlet.ServletException

sendError

protected void sendError(jakarta.servlet.http.HttpServletResponse resp,
 IConcurrentConnectionManager.ReservationStatus status,
 String nodeId)
                  throws IOException

Throws:

IOException

getNodeId

protected String getNodeId(jakarta.servlet.http.HttpServletRequest req)

after

public void after(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)
           throws IOException,
jakarta.servlet.ServletException

Specified by:

after in interface IInterceptor

Throws:

IOException

jakarta.servlet.ServletException

buildSuspendIgnoreResponseHeaders

protected void buildSuspendIgnoreResponseHeaders(String nodeId,
 jakarta.servlet.ServletResponse resp)