org.apache.activemq.artemis.core.server.cluster

Interface Bridge

All Superinterfaces:

org.apache.activemq.artemis.core.server.ActiveMQComponent, Consumer

All Known Implementing Classes:

BridgeImpl, ClusterConnectionBridge

public interface Bridge
extends Consumer, org.apache.activemq.artemis.core.server.ActiveMQComponent

A Core Bridge

Method Summary

Modifier and Type	Method and Description
void	disconnect() To be called when the server sent a disconnect to the client.
void	flushExecutor()
org.apache.activemq.artemis.api.core.SimpleString	getForwardingAddress()
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection	getForwardingConnection()
org.apache.activemq.artemis.api.core.SimpleString	getName()
Queue	getQueue()
boolean	isConnected()
void	pause()
void	resume()
void	setNotificationService(org.apache.activemq.artemis.core.server.management.NotificationService notificationService)

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

debug, getDeliveringMessages, getFilter, handle, proceedDeliver, toManagementString

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

isStarted, start, stop

Method Detail

getName

org.apache.activemq.artemis.api.core.SimpleString getName()

getQueue

Queue getQueue()

getForwardingAddress

org.apache.activemq.artemis.api.core.SimpleString getForwardingAddress()

flushExecutor

void flushExecutor()

setNotificationService

void setNotificationService(org.apache.activemq.artemis.core.server.management.NotificationService notificationService)

getForwardingConnection

org.apache.activemq.artemis.spi.core.protocol.RemotingConnection getForwardingConnection()

pause

void pause()
    throws Exception

Throws:

Exception

resume

void resume()
     throws Exception

Throws:

Exception

disconnect

void disconnect()

To be called when the server sent a disconnect to the client. Basically this is for cluster bridges being disconnected

Specified by:

disconnect in interface Consumer

isConnected

boolean isConnected()