Package com.swiftmq.impl.queue.standard.cluster

Class Redispatcher

java.lang.Object

MessageProcessor

com.swiftmq.impl.queue.standard.cluster.Redispatcher

public class Redispatcher
extends MessageProcessor

Constructor Summary

Constructors

Constructor	Description
Redispatcher(SwiftletContext ctx, String sourceQueueName, String targetQueueName)

Method Summary

Modifier and Type	Method	Description
String	getDescription()
String	getDispatchToken()
boolean	isValid()
void	processException(Exception exception)
void	processMessage(MessageEntry messageEntry)
void	run()
void	start()
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

Redispatcher

public Redispatcher(SwiftletContext ctx,
 String sourceQueueName,
 String targetQueueName)
             throws Exception

Throws:

Exception

Method Details

start

public void start()
           throws Exception

Throws:

Exception

getDescription

public String getDescription()

getDispatchToken

public String getDispatchToken()

isValid

public boolean isValid()

processException

public void processException(Exception exception)

processMessage

public void processMessage(MessageEntry messageEntry)

run

public void run()

stop

public void stop()

toString

public String toString()