Package org.apache.activemq.artemis.core.server.mirror

Interface MirrorController

public interface MirrorController

This represents the contract we will use to send messages to replicas.

Method Summary

Modifier and Type	Method	Description
void	addAddress(AddressInfo addressInfo)
void	createQueue(QueueConfiguration queueConfiguration)
void	deleteAddress(AddressInfo addressInfo)
void	deleteQueue(SimpleString addressName, SimpleString queueName)
String	getRemoteMirrorId()
default boolean	isRetryACK()
void	postAcknowledge(MessageReference ref, AckReason reason)
void	preAcknowledge(Transaction tx, MessageReference ref, AckReason reason)
void	sendMessage(Transaction tx, Message message, RoutingContext context)

Method Details

isRetryACK

default boolean isRetryACK()

addAddress

void addAddress(AddressInfo addressInfo)
         throws Exception

Throws:

Exception

deleteAddress

void deleteAddress(AddressInfo addressInfo)
            throws Exception

Throws:

Exception

createQueue

void createQueue(QueueConfiguration queueConfiguration)
          throws Exception

Throws:

Exception

deleteQueue

void deleteQueue(SimpleString addressName,
 SimpleString queueName)
          throws Exception

Throws:

Exception

sendMessage

void sendMessage(Transaction tx,
 Message message,
 RoutingContext context)

postAcknowledge

void postAcknowledge(MessageReference ref,
 AckReason reason)
              throws Exception

Throws:

Exception

preAcknowledge

void preAcknowledge(Transaction tx,
 MessageReference ref,
 AckReason reason)
             throws Exception

Throws:

Exception

getRemoteMirrorId

String getRemoteMirrorId()