Class AMQPMirrorControllerSource

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.mirror.BasicMirrorController<org.apache.qpid.proton.engine.Sender>

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

All Implemented Interfaces:

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

public class AMQPMirrorControllerSource
extends BasicMirrorController<org.apache.qpid.proton.engine.Sender>
implements org.apache.activemq.artemis.core.server.mirror.MirrorController, org.apache.activemq.artemis.core.server.ActiveMQComponent

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.qpid.proton.amqp.Symbol	ACK_REASON
static final org.apache.qpid.proton.amqp.Symbol	ADD_ADDRESS
static final org.apache.qpid.proton.amqp.Symbol	ADDRESS
static final org.apache.qpid.proton.amqp.Symbol	BROKER_ID
static final SimpleString	BROKER_ID_SIMPLE_STRING
static final org.apache.qpid.proton.amqp.Symbol	CREATE_QUEUE
static final org.apache.qpid.proton.amqp.Symbol	DELETE_ADDRESS
static final org.apache.qpid.proton.amqp.Symbol	DELETE_QUEUE
static final org.apache.qpid.proton.amqp.Symbol	EVENT_TYPE
static final SimpleString	INTERNAL_BROKER_ID_EXTRA_PROPERTY
static final org.apache.qpid.proton.amqp.Symbol	INTERNAL_DESTINATION
static final org.apache.qpid.proton.amqp.Symbol	INTERNAL_ID
static final SimpleString	INTERNAL_ID_EXTRA_PROPERTY
static final org.apache.qpid.proton.amqp.Symbol	MIRROR_CAPABILITY
static final org.apache.qpid.proton.amqp.Symbol	POST_ACK
static final org.apache.qpid.proton.amqp.Symbol	QPID_DISPATCH_WAYPOINT_CAPABILITY
static final org.apache.qpid.proton.amqp.Symbol	QUEUE
static final org.apache.qpid.proton.amqp.Symbol	TARGET_QUEUES

Fields inherited from class BasicMirrorController

link, localMirrorId, remoteMirrorId

Constructor Summary

Constructors

Constructor	Description
AMQPMirrorControllerSource(ReferenceIDSupplier referenceIdSupplier, org.apache.activemq.artemis.core.server.Queue snfQueue, org.apache.activemq.artemis.core.server.ActiveMQServer server, AMQPMirrorBrokerConnectionElement replicaConfig, AMQPBrokerConnection brokerConnection)

Method Summary

Modifier and Type	Method	Description
void	addAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
void	createQueue(QueueConfiguration queueConfiguration)
void	deleteAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
void	deleteQueue(SimpleString address, SimpleString queue)
AMQPBrokerConnection	getBrokerConnection()
org.apache.activemq.artemis.core.server.Queue	getSnfQueue()
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)
static void	routeMirrorCommand(org.apache.activemq.artemis.core.server.ActiveMQServer server, Message message)
static void	routeMirrorCommand(org.apache.activemq.artemis.core.server.ActiveMQServer server, Message message, org.apache.activemq.artemis.core.transaction.Transaction tx)
void	sendMessage(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, org.apache.activemq.artemis.core.server.RoutingContext context)
void	start()
void	stop()
static void	validateProtocolData(ReferenceIDSupplier referenceIDSupplier, org.apache.activemq.artemis.core.server.MessageReference ref, SimpleString snfAddress)

Methods inherited from class BasicMirrorController

getLink, getLocalMirrorId, getRemoteMirrorId, getRemoteMirrorID, setLink

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

getRemoteMirrorId, isRetryACK

Field Details

EVENT_TYPE

public static final org.apache.qpid.proton.amqp.Symbol EVENT_TYPE

ACK_REASON

public static final org.apache.qpid.proton.amqp.Symbol ACK_REASON

ADDRESS

public static final org.apache.qpid.proton.amqp.Symbol ADDRESS

QUEUE

public static final org.apache.qpid.proton.amqp.Symbol QUEUE

BROKER_ID

public static final org.apache.qpid.proton.amqp.Symbol BROKER_ID

BROKER_ID_SIMPLE_STRING

public static final SimpleString BROKER_ID_SIMPLE_STRING

ADD_ADDRESS

public static final org.apache.qpid.proton.amqp.Symbol ADD_ADDRESS

DELETE_ADDRESS

public static final org.apache.qpid.proton.amqp.Symbol DELETE_ADDRESS

CREATE_QUEUE

public static final org.apache.qpid.proton.amqp.Symbol CREATE_QUEUE

DELETE_QUEUE

public static final org.apache.qpid.proton.amqp.Symbol DELETE_QUEUE

POST_ACK

public static final org.apache.qpid.proton.amqp.Symbol POST_ACK

INTERNAL_ID

public static final org.apache.qpid.proton.amqp.Symbol INTERNAL_ID

INTERNAL_DESTINATION

public static final org.apache.qpid.proton.amqp.Symbol INTERNAL_DESTINATION

TARGET_QUEUES

public static final org.apache.qpid.proton.amqp.Symbol TARGET_QUEUES

MIRROR_CAPABILITY

public static final org.apache.qpid.proton.amqp.Symbol MIRROR_CAPABILITY

QPID_DISPATCH_WAYPOINT_CAPABILITY

public static final org.apache.qpid.proton.amqp.Symbol QPID_DISPATCH_WAYPOINT_CAPABILITY

INTERNAL_ID_EXTRA_PROPERTY

public static final SimpleString INTERNAL_ID_EXTRA_PROPERTY

INTERNAL_BROKER_ID_EXTRA_PROPERTY

public static final SimpleString INTERNAL_BROKER_ID_EXTRA_PROPERTY

Constructor Details

AMQPMirrorControllerSource

public AMQPMirrorControllerSource(ReferenceIDSupplier referenceIdSupplier,
 org.apache.activemq.artemis.core.server.Queue snfQueue,
 org.apache.activemq.artemis.core.server.ActiveMQServer server,
 AMQPMirrorBrokerConnectionElement replicaConfig,
 AMQPBrokerConnection brokerConnection)

Method Details

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

isStarted

public boolean isStarted()

Specified by:

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

getSnfQueue

public org.apache.activemq.artemis.core.server.Queue getSnfQueue()

getBrokerConnection

public AMQPBrokerConnection getBrokerConnection()

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 address,
 SimpleString queue)
                 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

validateProtocolData

public static void validateProtocolData(ReferenceIDSupplier referenceIDSupplier,
 org.apache.activemq.artemis.core.server.MessageReference ref,
 SimpleString snfAddress)

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

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

routeMirrorCommand

public static void routeMirrorCommand(org.apache.activemq.artemis.core.server.ActiveMQServer server,
 Message message)
                               throws Exception

Throws:

Exception

routeMirrorCommand

public static void routeMirrorCommand(org.apache.activemq.artemis.core.server.ActiveMQServer server,
 Message message,
 org.apache.activemq.artemis.core.transaction.Transaction tx)
                               throws Exception

Throws:

Exception