Package org.opennms.netmgt.activemq.auth

Class OpenNMSJaasAuthenticationBroker

  • All Implemented Interfaces:
    org.apache.activemq.broker.Broker, org.apache.activemq.broker.region.Region, org.apache.activemq.security.AuthenticationBroker, org.apache.activemq.Service
    public class OpenNMSJaasAuthenticationBroker
extends org.apache.activemq.security.AbstractAuthenticationBroker

    • Field Summary

      • Fields inherited from class org.apache.activemq.security.AbstractAuthenticationBroker

        securityContexts

      • Fields inherited from class org.apache.activemq.broker.BrokerFilter

        next

    • Constructor Summary

      Constructors 
      Constructor Description
      OpenNMSJaasAuthenticationBroker​(org.apache.activemq.broker.Broker next, java.util.Set<java.net.InetAddress> trustedHosts, java.lang.String usernameForTrustedHosts, java.util.Set<java.security.Principal> principalsForTrustedHosts)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void addConnection​(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConnectionInfo info)  
      org.apache.activemq.security.SecurityContext authenticate​(java.lang.String username, java.lang.String password, java.security.cert.X509Certificate[] certificates)  
      protected static java.net.InetAddress getAddressFromConnectionString​(java.lang.String remoteAddress)  

      • Methods inherited from class org.apache.activemq.security.AbstractAuthenticationBroker

        refresh, removeConnection, removeDestination

      • Methods inherited from class org.apache.activemq.broker.BrokerFilter

        acknowledge, addBroker, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, 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, removeConsumer, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop, virtualDestinationAdded, virtualDestinationRemoved

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • OpenNMSJaasAuthenticationBroker

        public OpenNMSJaasAuthenticationBroker​(org.apache.activemq.broker.Broker next,
                                       java.util.Set<java.net.InetAddress> trustedHosts,
                                       java.lang.String usernameForTrustedHosts,
                                       java.util.Set<java.security.Principal> principalsForTrustedHosts)

    • Method Detail

      • addConnection

        public void addConnection​(org.apache.activemq.broker.ConnectionContext context,
                          org.apache.activemq.command.ConnectionInfo info)
                   throws java.lang.Exception
        Specified by:
        addConnection in interface org.apache.activemq.broker.Broker
        Overrides:
        addConnection in class org.apache.activemq.broker.BrokerFilter
        Throws:
        java.lang.Exception

      • getAddressFromConnectionString

        protected static java.net.InetAddress getAddressFromConnectionString​(java.lang.String remoteAddress)

      • authenticate

        public org.apache.activemq.security.SecurityContext authenticate​(java.lang.String username,
                                                                 java.lang.String password,
                                                                 java.security.cert.X509Certificate[] certificates)
                                                          throws java.lang.SecurityException
        Throws:
        java.lang.SecurityException