Class AMQPMirrorControllerAggregation

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.mirror.AMQPMirrorControllerAggregation

All Implemented Interfaces:

org.apache.activemq.artemis.core.server.ActiveMQComponent, org.apache.activemq.artemis.core.server.mirror.MirrorController

public class AMQPMirrorControllerAggregation
extends Object
implements org.apache.activemq.artemis.core.server.mirror.MirrorController, org.apache.activemq.artemis.core.server.ActiveMQComponent

this will be used when there are multiple replicas in use.

Constructor Summary

Constructors

Constructor	Description
AMQPMirrorControllerAggregation()

Method Summary

Modifier and Type	Method	Description
void	addAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
void	addPartition(AMQPMirrorControllerSource partition)
void	createQueue(QueueConfiguration queueConfiguration)
void	deleteAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
void	deleteQueue(SimpleString addressName, SimpleString queueName)
List<AMQPMirrorControllerSource>	getPartitions()
String	getRemoteMirrorId()
boolean	isStarted()
void	postAcknowledge(org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason)
void	preAcknowledge(org.apache.activemq.artemis.core.transaction.Transaction tx, org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason)
void	removeParition(AMQPMirrorControllerSource partition)
void	sendMessage(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, org.apache.activemq.artemis.core.server.RoutingContext context)
void	start()
void	stop()

Methods inherited from class Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Methods inherited from interface org.apache.activemq.artemis.core.server.mirror.MirrorController

isRetryACK

Constructor Details

AMQPMirrorControllerAggregation

public AMQPMirrorControllerAggregation()

Method Details

addPartition

public void addPartition(AMQPMirrorControllerSource partition)

removeParition

public void removeParition(AMQPMirrorControllerSource partition)

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

Throws:

Exception

getRemoteMirrorId

public String getRemoteMirrorId()

Specified by:

getRemoteMirrorId in interface org.apache.activemq.artemis.core.server.mirror.MirrorController

isStarted

public boolean isStarted()

Specified by:

isStarted in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

getPartitions

public List<AMQPMirrorControllerSource> getPartitions()

preAcknowledge

public void preAcknowledge(org.apache.activemq.artemis.core.transaction.Transaction tx,
 org.apache.activemq.artemis.core.server.MessageReference ref,
 org.apache.activemq.artemis.core.server.impl.AckReason reason)
                    throws Exception

Specified by:

preAcknowledge in interface org.apache.activemq.artemis.core.server.mirror.MirrorController

Throws:

Exception

addAddress

public void addAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
                throws Exception

Specified by:

addAddress in interface org.apache.activemq.artemis.core.server.mirror.MirrorController

Throws:

Exception

deleteAddress

public void deleteAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
                   throws Exception

Specified by:

deleteAddress in interface org.apache.activemq.artemis.core.server.mirror.MirrorController

Throws:

Exception

createQueue

public void createQueue(QueueConfiguration queueConfiguration)
                 throws Exception

Specified by:

createQueue in interface org.apache.activemq.artemis.core.server.mirror.MirrorController

Throws:

Exception

deleteQueue

public void deleteQueue(SimpleString addressName,
 SimpleString queueName)
                 throws Exception

Specified by:

deleteQueue in interface org.apache.activemq.artemis.core.server.mirror.MirrorController

Throws:

Exception

sendMessage

public void sendMessage(org.apache.activemq.artemis.core.transaction.Transaction tx,
 Message message,
 org.apache.activemq.artemis.core.server.RoutingContext context)

Specified by:

sendMessage in interface org.apache.activemq.artemis.core.server.mirror.MirrorController

postAcknowledge

public void postAcknowledge(org.apache.activemq.artemis.core.server.MessageReference ref,
 org.apache.activemq.artemis.core.server.impl.AckReason reason)
                     throws Exception

Specified by:

postAcknowledge in interface org.apache.activemq.artemis.core.server.mirror.MirrorController

Throws:

Exception