Class HttpOutgoingTransport
java.lang.Object
org.jumpmind.symmetric.transport.http.HttpOutgoingTransport
- All Implemented Interfaces:
IOutgoingTransport
,IOutgoingWithResponseTransport
-
Constructor Summary
ConstructorsConstructorDescriptionHttpOutgoingTransport
(HttpTransportManager httpTransportManager, URL url, int httpTimeout, int httpConnectTimeout, boolean useCompression, int compressionStrategy, int compressionLevel, String nodeId, String securityToken, boolean streamOutputEnabled, int streamOutputSize, boolean fileUpload) HttpOutgoingTransport
(HttpTransportManager httpTransportManager, URL url, int httpTimeout, int httpConnectTimeout, boolean useCompression, int compressionStrategy, int compressionLevel, String nodeId, String securityToken, boolean streamOutputEnabled, int streamOutputSize, boolean fileUpload, Map<String, String> requestProperties) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
getSuspendIgnoreChannelLists
(IConfigurationService configurationService, String queue, Node targetNode) This returns a (combined) list of suspended or ignored channels.boolean
isOpen()
-
Constructor Details
-
HttpOutgoingTransport
public HttpOutgoingTransport(HttpTransportManager httpTransportManager, URL url, int httpTimeout, int httpConnectTimeout, boolean useCompression, int compressionStrategy, int compressionLevel, String nodeId, String securityToken, boolean streamOutputEnabled, int streamOutputSize, boolean fileUpload) -
HttpOutgoingTransport
public HttpOutgoingTransport(HttpTransportManager httpTransportManager, URL url, int httpTimeout, int httpConnectTimeout, boolean useCompression, int compressionStrategy, int compressionLevel, String nodeId, String securityToken, boolean streamOutputEnabled, int streamOutputSize, boolean fileUpload, Map<String, String> requestProperties)
-
-
Method Details
-
close
public void close()- Specified by:
close
in interfaceIOutgoingTransport
-
openStream
- Specified by:
openStream
in interfaceIOutgoingTransport
-
openWriter
- Specified by:
openWriter
in interfaceIOutgoingTransport
-
getWriter
- Specified by:
getWriter
in interfaceIOutgoingTransport
-
readResponse
- Specified by:
readResponse
in interfaceIOutgoingWithResponseTransport
- Throws:
IOException
-
isOpen
public boolean isOpen()- Specified by:
isOpen
in interfaceIOutgoingTransport
-
getSuspendIgnoreChannelLists
public ChannelMap getSuspendIgnoreChannelLists(IConfigurationService configurationService, 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 interfaceIOutgoingTransport
-
getConnection
-