Package com.swiftmq.impl.streams.comp.io

Class Output

java.lang.Object

com.swiftmq.impl.streams.comp.io.Output

Direct Known Subclasses:

QueueOutput, TopicOutput

public abstract class Output
extends Object

Represents an Output to a Queue or Topic.

Author:

IIT Software GmbH, Muenster/Germany, (c) 2016, All Rights Reserved

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this Output.
void	collect(long interval)	Internal use.
protected abstract QueueSender	createSender()
protected abstract Destination	getDestination()
protected abstract String	getType()
boolean	isDirty()	Internal use.
String	name()	Returns the name of the Output
Output	send(Message message)	Sends a Message.
protected abstract void	setDestination(Destination destination)
void	setDirty(boolean dirty)	Internal use.

Methods inherited from class java.lang.Object

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

Method Details

name

public String name()

Returns the name of the Output

Returns:

name

isDirty

public boolean isDirty()

Internal use.

setDirty

public void setDirty(boolean dirty)

Internal use.

setDestination

protected abstract void setDestination(Destination destination)

getType

protected abstract String getType()

createSender

protected abstract QueueSender createSender()
                                     throws Exception

Throws:

Exception

getDestination

protected abstract Destination getDestination()
                                       throws Exception

Throws:

Exception

send

public Output send(Message message)
            throws Exception

Sends a Message.

Parameters:

message - Message

Returns:

Output

Throws:

Exception

collect

public void collect(long interval)

Internal use.

close

public void close()

Closes this Output.