org.jumpmind.symmetric.transport.http

Class HttpOutgoingTransport

java.lang.Object

org.jumpmind.symmetric.transport.http.HttpOutgoingTransport

All Implemented Interfaces:

IOutgoingTransport, IOutgoingWithResponseTransport

public class HttpOutgoingTransport
extends java.lang.Object
implements IOutgoingWithResponseTransport

Constructor Summary

Constructors

Constructor and Description
HttpOutgoingTransport(HttpTransportManager httpTransportManager, java.net.URL url, int httpTimeout, boolean useCompression, int compressionStrategy, int compressionLevel, java.lang.String nodeId, java.lang.String securityToken, boolean streamOutputEnabled, int streamOutputSize, boolean fileUpload)
HttpOutgoingTransport(HttpTransportManager httpTransportManager, java.net.URL url, int httpTimeout, boolean useCompression, int compressionStrategy, int compressionLevel, java.lang.String nodeId, java.lang.String securityToken, boolean streamOutputEnabled, int streamOutputSize, boolean fileUpload, java.util.Map<java.lang.String,java.lang.String> requestProperties)

Method Summary

Modifier and Type	Method and Description
void	close()
HttpConnection	getConnection()
ChannelMap	getSuspendIgnoreChannelLists(IConfigurationService configurationService, java.lang.String queue, Node targetNode) This returns a (combined) list of suspended or ignored channels.
java.io.BufferedWriter	getWriter()
boolean	isOpen()
java.io.OutputStream	openStream()
java.io.BufferedWriter	openWriter()
java.io.BufferedReader	readResponse()

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpOutgoingTransport

public HttpOutgoingTransport(HttpTransportManager httpTransportManager,
                             java.net.URL url,
                             int httpTimeout,
                             boolean useCompression,
                             int compressionStrategy,
                             int compressionLevel,
                             java.lang.String nodeId,
                             java.lang.String securityToken,
                             boolean streamOutputEnabled,
                             int streamOutputSize,
                             boolean fileUpload)

HttpOutgoingTransport

public HttpOutgoingTransport(HttpTransportManager httpTransportManager,
                             java.net.URL url,
                             int httpTimeout,
                             boolean useCompression,
                             int compressionStrategy,
                             int compressionLevel,
                             java.lang.String nodeId,
                             java.lang.String securityToken,
                             boolean streamOutputEnabled,
                             int streamOutputSize,
                             boolean fileUpload,
                             java.util.Map<java.lang.String,java.lang.String> requestProperties)

Method Detail

close

public void close()

Specified by:

close in interface IOutgoingTransport

openStream

public java.io.OutputStream openStream()

Specified by:

openStream in interface IOutgoingTransport

openWriter

public java.io.BufferedWriter openWriter()

Specified by:

openWriter in interface IOutgoingTransport

getWriter

public java.io.BufferedWriter getWriter()

Specified by:

getWriter in interface IOutgoingTransport

readResponse

public java.io.BufferedReader readResponse()
                                    throws java.io.IOException

Specified by:

readResponse in interface IOutgoingWithResponseTransport

Throws:

java.io.IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface IOutgoingTransport

getSuspendIgnoreChannelLists

public ChannelMap getSuspendIgnoreChannelLists(IConfigurationService configurationService,
                                               java.lang.String queue,
                                               Node targetNode)

Description copied from interface: IOutgoingTransport

This returns a (combined) list of suspended or ignored channels. In addition, it will optionally do a reservation in the case of a Push request

Specified by:

getSuspendIgnoreChannelLists in interface IOutgoingTransport

getConnection

public HttpConnection getConnection()