Package com.swiftmq.impl.topic.standard.announce

Class TopicAnnounceReceiver

java.lang.Object

MessageProcessor

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

public class TopicAnnounceReceiver
extends MessageProcessor

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(MessageEntry messageEntry)
void	run()
void	setClosed()
void	stop()
String	toString()
void	visit(Versioned versioned)
void	visit(VersionNotification notification)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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()

processMessage

public void processMessage(MessageEntry messageEntry)

processException

public void processException(Exception exception)

getDispatchToken

public String getDispatchToken()

getDescription

public String getDescription()

stop

public void stop()

run

public void run()

visit

public void visit(VersionNotification notification)

visit

public void visit(Versioned versioned)

toString

public String toString()