Package org.jumpmind.symmetric.transport.internal

Class InternalOutgoingTransport

java.lang.Object

org.jumpmind.symmetric.transport.internal.InternalOutgoingTransport

All Implemented Interfaces:

IOutgoingTransport

public class InternalOutgoingTransport
extends Object
implements IOutgoingTransport

Constructor Summary

Constructors

Constructor	Description
InternalOutgoingTransport(BufferedWriter writer)
InternalOutgoingTransport(OutputStream os, String encoding)
InternalOutgoingTransport(OutputStream os, ChannelMap map, String encoding)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

InternalOutgoingTransport

public InternalOutgoingTransport(OutputStream os,
 String encoding)
                          throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

InternalOutgoingTransport

public InternalOutgoingTransport(OutputStream os,
 ChannelMap map,
 String encoding)
                          throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

InternalOutgoingTransport

public InternalOutgoingTransport(BufferedWriter writer)

Method Details

close

public void close()

Specified by:

close in interface IOutgoingTransport

isOpen

public boolean isOpen()

Specified by:

isOpen in interface IOutgoingTransport

openStream

public OutputStream openStream()

Specified by:

openStream in interface IOutgoingTransport

openWriter

public BufferedWriter openWriter()

Specified by:

openWriter in interface IOutgoingTransport

getWriter

public BufferedWriter getWriter()

Specified by:

getWriter in interface IOutgoingTransport

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 interface IOutgoingTransport