Package org.apache.activemq.artemis.core.server.plugin.impl

Class BrokerMessageAuthorizationPlugin

java.lang.Object

org.apache.activemq.artemis.core.server.plugin.impl.BrokerMessageAuthorizationPlugin

All Implemented Interfaces:

ActiveMQServerAddressPlugin, ActiveMQServerBasePlugin, ActiveMQServerBindingPlugin, ActiveMQServerBridgePlugin, ActiveMQServerConnectionPlugin, ActiveMQServerConsumerPlugin, ActiveMQServerCriticalPlugin, ActiveMQServerFederationPlugin, ActiveMQServerMessagePlugin, ActiveMQServerPlugin, ActiveMQServerQueuePlugin, ActiveMQServerResourcePlugin, ActiveMQServerSessionPlugin

public class BrokerMessageAuthorizationPlugin
extends Object
implements ActiveMQServerPlugin

Constructor Summary

Constructors

Constructor	Description
BrokerMessageAuthorizationPlugin()

Method Summary

Modifier and Type	Method	Description
boolean	canAccept(ServerConsumer consumer, MessageReference reference)	Before a message is delivered to a client consumer
void	init(Map<String,String> properties)	used to pass configured properties to Plugin
void	registered(ActiveMQServer server)	The plugin has been registered with the server
void	unregistered(ActiveMQServer server)	The plugin has been unregistered with the server

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerAddressPlugin

afterAddAddress, afterRemoveAddress, afterUpdateAddress, beforeAddAddress, beforeRemoveAddress, beforeUpdateAddress

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBasePlugin

setInit

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBindingPlugin

afterAddBinding, afterRemoveBinding, beforeAddBinding, beforeRemoveBinding

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBridgePlugin

afterAcknowledgeBridge, afterDeliverBridge, afterDeployBridge, beforeDeliverBridge, beforeDeployBridge

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerConnectionPlugin

afterCreateConnection, afterDestroyConnection

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerConsumerPlugin

afterCloseConsumer, afterCreateConsumer, beforeCloseConsumer, beforeCreateConsumer, beforeCreateConsumer

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerCriticalPlugin

criticalFailure

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerFederationPlugin

afterCloseFederatedQueueConsumer, afterCreateFederatedQueueConsumer, afterFederatedQueueConsumerMessageHandled, beforeCloseFederatedQueueConsumer, beforeCreateFederatedQueueConsumer, beforeFederatedQueueConsumerMessageHandled, federatedAddressConditionalCreateConsumer, federatedAddressConditionalCreateDivertConsumer, federatedQueueConditionalCreateConsumer, federationStreamStarted, federationStreamStopped

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerMessagePlugin

afterDeliver, afterDeliver, afterMessageRoute, afterSend, afterSend, beforeDeliver, beforeDeliver, beforeMessageRoute, beforeSend, beforeSend, messageAcknowledged, messageAcknowledged, messageAcknowledged, messageExpired, messageExpired, messageMoved, onMessageRouteException, onSendException

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerQueuePlugin

afterCreateQueue, afterDestroyQueue, afterExpiryScan, beforeCreateQueue, beforeCreateQueue, beforeDestroyQueue, beforeDestroyQueue, beforeExpiryScan

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerResourcePlugin

afterPutTransaction, afterRemoveTransaction, beforePutTransaction, beforeRemoveTransaction

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerSessionPlugin

afterCloseSession, afterCreateSession, afterSessionMetadataAdded, beforeCloseSession, beforeCreateSession, beforeSessionMetadataAdded, duplicateSessionMetadataFailure

Constructor Details

BrokerMessageAuthorizationPlugin

public BrokerMessageAuthorizationPlugin()

Method Details

init

public void init(Map<String,String> properties)

Description copied from interface: ActiveMQServerBasePlugin

used to pass configured properties to Plugin

Specified by:

init in interface ActiveMQServerBasePlugin

registered

public void registered(ActiveMQServer server)

Description copied from interface: ActiveMQServerBasePlugin

The plugin has been registered with the server

Specified by:

registered in interface ActiveMQServerBasePlugin

Parameters:

server - The ActiveMQServer the plugin has been registered to

unregistered

public void unregistered(ActiveMQServer server)

Description copied from interface: ActiveMQServerBasePlugin

The plugin has been unregistered with the server

Specified by:

unregistered in interface ActiveMQServerBasePlugin

Parameters:

server - The ActiveMQServer the plugin has been unregistered to

canAccept

public boolean canAccept(ServerConsumer consumer,
 MessageReference reference)
                  throws ActiveMQException

Description copied from interface: ActiveMQServerMessagePlugin

Before a message is delivered to a client consumer

Specified by:

canAccept in interface ActiveMQServerMessagePlugin

Parameters:

consumer - the consumer the message will be delivered to

reference - message reference

Throws:

ActiveMQException