Class TopicAnnounceReceiver

java.lang.Object

com.swiftmq.swiftlet.queue.MessageProcessor

com.swiftmq.impl.topic.standard.announce.TopicAnnounceReceiver

All Implemented Interfaces:

com.swiftmq.swiftlet.threadpool.AsyncTask, com.swiftmq.tools.versioning.VersionVisitor, Runnable

public class TopicAnnounceReceiver
extends com.swiftmq.swiftlet.queue.MessageProcessor
implements com.swiftmq.tools.versioning.VersionVisitor

Constructor Summary

Constructors

Constructor	Description
TopicAnnounceReceiver(TopicManagerContext ctx, String topicQueue)

Method Summary

Modifier and Type	Method	Description
String	getDescription()
String	getDispatchToken()
boolean	isValid()
void	processException(Exception exception)
void	processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)
void	run()
void	setClosed()
void	stop()
String	toString()
void	visit(com.swiftmq.tools.versioning.Versioned versioned)
void	visit(com.swiftmq.tools.versioning.VersionNotification notification)

Methods inherited from class com.swiftmq.swiftlet.queue.MessageProcessor

createBulkBuffer, getBulkBuffer, getCurrentBulkSize, getMaxBulkSize, getReceiverId, getRegistrationId, getRegistrationTime, getSelector, getTimeout, getTransactionId, getViewId, isAutoCommit, isBulkMode, processMessages, reset, setAutoCommit, setBulkMode, setCurrentBulkSize, setReceiverId, setRegistrationId, setRegistrationTime, setTransactionId, setViewId

Methods inherited from class Object

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

Constructor Details

TopicAnnounceReceiver

public TopicAnnounceReceiver(TopicManagerContext ctx,
 String topicQueue)
                      throws Exception

Throws:

Exception

Method Details

setClosed

public void setClosed()

isValid

public boolean isValid()

Specified by:

isValid in interface com.swiftmq.swiftlet.threadpool.AsyncTask

processMessage

public void processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)

Specified by:

processMessage in class com.swiftmq.swiftlet.queue.MessageProcessor

processException

public void processException(Exception exception)

Specified by:

processException in class com.swiftmq.swiftlet.queue.MessageProcessor

getDispatchToken

public String getDispatchToken()

Specified by:

getDispatchToken in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

getDispatchToken in class com.swiftmq.swiftlet.queue.MessageProcessor

getDescription

public String getDescription()

Specified by:

getDescription in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

getDescription in class com.swiftmq.swiftlet.queue.MessageProcessor

stop

public void stop()

Specified by:

stop in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

stop in class com.swiftmq.swiftlet.queue.MessageProcessor

run

public void run()

Specified by:

run in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Specified by:

run in interface Runnable

Overrides:

run in class com.swiftmq.swiftlet.queue.MessageProcessor

visit

public void visit(com.swiftmq.tools.versioning.VersionNotification notification)

Specified by:

visit in interface com.swiftmq.tools.versioning.VersionVisitor

visit

public void visit(com.swiftmq.tools.versioning.Versioned versioned)

Specified by:

visit in interface com.swiftmq.tools.versioning.VersionVisitor

toString

public String toString()

Overrides:

toString in class Object