Package org.jumpmind.symmetric.web

Class PushUriHandler

java.lang.Object

org.jumpmind.symmetric.web.AbstractUriHandler

org.jumpmind.symmetric.web.PushUriHandler

All Implemented Interfaces:

IUriHandler

public class PushUriHandler
extends AbstractUriHandler

Handles data pushes from nodes.

Field Summary

Fields inherited from class org.jumpmind.symmetric.web.AbstractUriHandler

log, parameterService

Constructor Summary

Constructors

Constructor	Description
PushUriHandler(IParameterService parameterService, IDataLoaderService dataLoaderService, IStatisticManager statisticManager, INodeService nodeService, IInterceptor... interceptors)

Method Summary

Modifier and Type	Method	Description
void	handle(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse res)
protected int	push(String sourceNodeId, String channelQueue, InputStream inputStream, OutputStream outputStream)

Methods inherited from class org.jumpmind.symmetric.web.AbstractUriHandler

createInputStream, createOutgoingTransport, createOutgoingTransport, getInterceptors, getUriPattern, isEnabled, setEnabled, setInterceptors, setParameterService, setUriPattern

Methods inherited from class java.lang.Object

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

Constructor Details

PushUriHandler

public PushUriHandler(IParameterService parameterService,
 IDataLoaderService dataLoaderService,
 IStatisticManager statisticManager,
 INodeService nodeService,
 IInterceptor... interceptors)

Method Details

handle

public void handle(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse res)
            throws IOException,
jakarta.servlet.ServletException

Throws:

IOException

jakarta.servlet.ServletException

push

protected int push(String sourceNodeId,
 String channelQueue,
 InputStream inputStream,
 OutputStream outputStream)
            throws IOException

Throws:

IOException