public class AuthorizationBroker extends BrokerFilter implements SecurityAdminMBean
next
OPERATION_ADMIN, OPERATION_READ, OPERATION_WRITE
Constructor and Description |
---|
AuthorizationBroker(Broker next,
AuthorizationMap authorizationMap) |
Modifier and Type | Method and Description |
---|---|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer.
|
Destination |
addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create)
Used to create a destination.
|
void |
addDestinationInfo(ConnectionContext context,
DestinationInfo info)
Add and process a DestinationInfo object
|
void |
addDestinationRole(javax.jms.Destination destination,
String operation,
String role) |
void |
addProducer(ConnectionContext context,
ProducerInfo info)
Adds a producer.
|
void |
addQueueRole(String queue,
String operation,
String role) |
void |
addRole(String role) |
void |
addTopicRole(String topic,
String operation,
String role) |
void |
addUserRole(String user,
String role) |
protected boolean |
checkDestinationAdmin(SecurityContext securityContext,
ActiveMQDestination destination) |
protected SecurityContext |
checkSecurityContext(ConnectionContext context) |
AuthorizationMap |
getAuthorizationMap() |
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination.
|
void |
removeDestinationInfo(ConnectionContext context,
DestinationInfo info)
Remove and process a DestinationInfo object
|
void |
removeDestinationRole(javax.jms.Destination destination,
String operation,
String role) |
void |
removeQueueRole(String queue,
String operation,
String role) |
void |
removeRole(String role) |
void |
removeTopicRole(String topic,
String operation,
String role) |
void |
removeUserRole(String user,
String role) |
void |
send(ProducerBrokerExchange producerExchange,
Message messageSend)
Send a message to the broker to using the specified destination.
|
void |
setAuthorizationMap(AuthorizationMap map) |
acknowledge, addBroker, addConnection, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getNext, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeConsumer, removeProducer, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop, virtualDestinationAdded, virtualDestinationRemoved
public AuthorizationBroker(Broker next, AuthorizationMap authorizationMap)
public AuthorizationMap getAuthorizationMap()
public void setAuthorizationMap(AuthorizationMap map)
protected SecurityContext checkSecurityContext(ConnectionContext context) throws SecurityException
SecurityException
protected boolean checkDestinationAdmin(SecurityContext securityContext, ActiveMQDestination destination)
public void addDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception
Broker
addDestinationInfo
in interface Broker
addDestinationInfo
in class BrokerFilter
Exception
public Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create) throws Exception
Region
addDestination
in interface Region
addDestination
in class BrokerFilter
destination
- the destination to create.Exception
- TODOpublic void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws Exception
Region
removeDestination
in interface Region
removeDestination
in class BrokerFilter
context
- the environment the operation is being executed under.destination
- what is being removed from the broker.timeout
- the max amount of time to wait for the destination to quiesceException
- TODOpublic void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception
Broker
removeDestinationInfo
in interface Broker
removeDestinationInfo
in class BrokerFilter
Exception
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception
Region
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.Exception
- TODOpublic void addQueueRole(String queue, String operation, String role)
addQueueRole
in interface SecurityAdminMBean
public void addTopicRole(String topic, String operation, String role)
addTopicRole
in interface SecurityAdminMBean
public void removeQueueRole(String queue, String operation, String role)
removeQueueRole
in interface SecurityAdminMBean
public void removeTopicRole(String topic, String operation, String role)
removeTopicRole
in interface SecurityAdminMBean
public void addDestinationRole(javax.jms.Destination destination, String operation, String role)
public void removeDestinationRole(javax.jms.Destination destination, String operation, String role)
public void addRole(String role)
addRole
in interface SecurityAdminMBean
public void addUserRole(String user, String role)
addUserRole
in interface SecurityAdminMBean
public void removeRole(String role)
removeRole
in interface SecurityAdminMBean
public void removeUserRole(String user, String role)
removeUserRole
in interface SecurityAdminMBean
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.