Package org.eclnt.ccee.mq.implactivemq

Class AMQMessageQueue

java.lang.Object

org.eclnt.ccee.mq.implactivemq.AMQMessageQueue

All Implemented Interfaces:

IMessageQueue

public class AMQMessageQueue
extends Object
implements IMessageQueue

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AMQMessageQueue.AMQMessageListener
class	AMQMessageQueue.HealCheckerThread

Constructor Summary

Constructors

Constructor	Description
AMQMessageQueue()

Method Summary

Modifier and Type	Method	Description
void	addMessageListener(String topic, IMessageQueueListener listener)
protected void	initializeFromConfig()
void	publishMessage(String topic, String message)
void	removeMessageListener(String topic, IMessageQueueListener listener)

Methods inherited from class java.lang.Object

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

Constructor Details

AMQMessageQueue

public AMQMessageQueue()

Method Details

publishMessage

public void publishMessage(String topic,
 String message)

Specified by:

publishMessage in interface IMessageQueue

addMessageListener

public void addMessageListener(String topic,
 IMessageQueueListener listener)

Specified by:

addMessageListener in interface IMessageQueue

removeMessageListener

public void removeMessageListener(String topic,
 IMessageQueueListener listener)

Specified by:

removeMessageListener in interface IMessageQueue

initializeFromConfig

protected void initializeFromConfig()