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 java.lang.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 javax.jms.Destination	getDestination()
protected abstract java.lang.String	getType()
boolean	isDirty()	Internal use.
java.lang.String	name()	Returns the name of the Output
Output	send(Message message)	Sends a Message.
protected abstract void	setDestination(javax.jms.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 Detail

name

public java.lang.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(javax.jms.Destination destination)

getType

protected abstract java.lang.String getType()

createSender

protected abstract QueueSender createSender()
                                     throws java.lang.Exception

Throws:

java.lang.Exception

getDestination

protected abstract javax.jms.Destination getDestination()
                                                 throws java.lang.Exception

Throws:

java.lang.Exception

send

public Output send(Message message)
            throws java.lang.Exception

Sends a Message.

Parameters:

message - Message

Returns:

Output

Throws:

java.lang.Exception

collect

public void collect(long interval)

Internal use.

close

public void close()

Closes this Output.