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

Class ClusterMetricSubscriber

java.lang.Object

MessageProcessor

com.swiftmq.impl.queue.standard.cluster.ClusterMetricSubscriber

public class ClusterMetricSubscriber
extends MessageProcessor

Constructor Summary

Constructors

Constructor	Description
ClusterMetricSubscriber(SwiftletContext ctx)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isValid()
void	processException(Exception exception)
void	processMessage(MessageEntry messageEntry)
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterMetricSubscriber

public ClusterMetricSubscriber(SwiftletContext ctx)
                        throws Exception

Throws:

Exception

Method Details

isValid

public boolean isValid()

processException

public void processException(Exception exception)

processMessage

public void processMessage(MessageEntry messageEntry)

run

public void run()

close

public void close()

toString

public String toString()