org.xdi.oxauth.audit.ApplicationAuditLogger クラス

org.xdi.oxauth.audit.ApplicationAuditLogger 連携図

公開メンバ関数
void	updateConfiguration (@Observes @ConfigurationUpdate AppConfiguration appConfiguration)
void	init ()
void	sendMessage (OAuth2AuditLog oAuth2AuditLog)
void	destroy ()

非公開メンバ関数
boolean	tryToEstablishJMSConnection ()
boolean	tryToEstablishJMSConnectionImpl ()
void	loggingThroughJMS (OAuth2AuditLog oAuth2AuditLog)
void	loggingThroughFile (OAuth2AuditLog oAuth2AuditLog)
boolean	isJmsConfigChanged ()
Boolean	isEnabledOAuthAuditnLogging ()
Set< String >	getJmsBrokerURISet ()
String	getJmsUserName ()
String	getJmsPassword ()

非公開変数類
Logger	log
final String	BROKER_URL_PREFIX = "failover:("
final String	BROKER_URL_SUFFIX = ")?timeout=5000&jms.useAsyncSend=true"
final int	ACK_MODE = Session.AUTO_ACKNOWLEDGE
final String	CLIENT_QUEUE_NAME = "oauth2.audit.logging"
final boolean	transacted = false
volatile PooledConnectionFactory	pooledConnectionFactory
Set< String >	jmsBrokerURISet
String	jmsUserName
String	jmsPassword
AppConfiguration	appConfiguration
final ReentrantLock	lock = new ReentrantLock()
boolean	updateState
Boolean	enabledOAuthAuditnLogging

詳解

関数詳解

destroy()

void org.xdi.oxauth.audit.ApplicationAuditLogger.destroy ( )

inline

                              {
                if (this.pooledConnectionFactory == null)
                        return;
                this.pooledConnectionFactory.clear();
                this.pooledConnectionFactory = null;
        }

getJmsBrokerURISet()

Set<String> org.xdi.oxauth.audit.ApplicationAuditLogger.getJmsBrokerURISet ( )

inlineprivate

                                                 {
                return appConfiguration.getJmsBrokerURISet();
        }

getJmsPassword()

String org.xdi.oxauth.audit.ApplicationAuditLogger.getJmsPassword ( )

inlineprivate

                                        {
                return appConfiguration.getJmsPassword();
        }

getJmsUserName()

String org.xdi.oxauth.audit.ApplicationAuditLogger.getJmsUserName ( )

inlineprivate

                                        {
                return appConfiguration.getJmsUserName();
        }

init()

void org.xdi.oxauth.audit.ApplicationAuditLogger.init ( )

inline

                           {
                if (BooleanUtils.isNotTrue(isEnabledOAuthAuditnLogging())) {
                        return;
                }

                tryToEstablishJMSConnection();
        }

isEnabledOAuthAuditnLogging()

Boolean org.xdi.oxauth.audit.ApplicationAuditLogger.isEnabledOAuthAuditnLogging ( )

inlineprivate

                                                      {
                if (this.updateState) {
                        this.enabledOAuthAuditnLogging = appConfiguration.getEnabledOAuthAuditLogging();
                }

                return this.enabledOAuthAuditnLogging;
        }

isJmsConfigChanged()

boolean org.xdi.oxauth.audit.ApplicationAuditLogger.isJmsConfigChanged ( )

inlineprivate

                                             {
                return !Objects.equal(this.jmsUserName, getJmsUserName()) || !Objects.equal(this.jmsPassword, getJmsPassword())
                                || !Objects.equal(this.jmsBrokerURISet, getJmsBrokerURISet());
        }

loggingThroughFile()

void org.xdi.oxauth.audit.ApplicationAuditLogger.loggingThroughFile ( OAuth2AuditLog  oAuth2AuditLog )

inlineprivate

                                                                       {
                try {
                        log.info(ServerUtil.asPrettyJson(oAuth2AuditLog));
                } catch (IOException e) {
                        log.error("Can't serialize the audit log", e);
                }
        }

loggingThroughJMS()

void org.xdi.oxauth.audit.ApplicationAuditLogger.loggingThroughJMS ( OAuth2AuditLog  oAuth2AuditLog )

inlineprivate

                                                                      {
                QueueConnection connection = null;
                try {
                        connection = pooledConnectionFactory.createQueueConnection();
                        connection.start();

                        QueueSession session = connection.createQueueSession(transacted, ACK_MODE);
                        MessageProducer producer = session.createProducer(session.createQueue(CLIENT_QUEUE_NAME));

                        TextMessage txtMessage = session.createTextMessage();
                        txtMessage.setText(ServerUtil.asPrettyJson(oAuth2AuditLog));
                        producer.send(txtMessage);
                } catch (JMSException e) {
                        log.error("Can't send message", e);
                } catch (IOException e) {
                        log.error("Can't serialize the audit log", e);
                } catch (Exception e) {
                        log.error("Can't send message, please check your activeMQ configuration.", e);
                } finally {
                        if (connection == null)
                                return;
                        try {
                                connection.close();
                        } catch (JMSException e) {
                                log.error("Can't close connection.");
                        }
                }
        }

sendMessage()

void org.xdi.oxauth.audit.ApplicationAuditLogger.sendMessage ( OAuth2AuditLog  oAuth2AuditLog )

inline

                                                               {
                if (BooleanUtils.isNotTrue(isEnabledOAuthAuditnLogging())) {
                        return;
                }

                if ((this.pooledConnectionFactory == null) || isJmsConfigChanged()) {
                        if (tryToEstablishJMSConnection())
                                loggingThroughJMS(oAuth2AuditLog);
                        else
                                loggingThroughFile(oAuth2AuditLog);
                } else {
                        loggingThroughJMS(oAuth2AuditLog);
                }
        }

tryToEstablishJMSConnection()

boolean org.xdi.oxauth.audit.ApplicationAuditLogger.tryToEstablishJMSConnection ( )

inlineprivate

                                                      {
                lock.lock();
                try {
                        // Check if another thread init JMS pool already
                        if ((this.pooledConnectionFactory != null) && !isJmsConfigChanged()) {
                                return tryToEstablishJMSConnectionImpl();
                        }

                return true;
                } finally {
                        lock.unlock();
                }
        }

tryToEstablishJMSConnectionImpl()

boolean org.xdi.oxauth.audit.ApplicationAuditLogger.tryToEstablishJMSConnectionImpl ( )

inlineprivate

                                                          {
                destroy();

                Set<String> jmsBrokerURISet = getJmsBrokerURISet();
                if (BooleanUtils.isNotTrue(isEnabledOAuthAuditnLogging()) || CollectionUtils.isEmpty(jmsBrokerURISet))
                        return false;

                this.jmsBrokerURISet = new HashSet<String>(jmsBrokerURISet);
                this.jmsUserName = getJmsUserName();
                this.jmsPassword = getJmsPassword();

                Iterator<String> jmsBrokerURIIterator = jmsBrokerURISet.iterator();

                StringBuilder uriBuilder = new StringBuilder();
                while (jmsBrokerURIIterator.hasNext()) {
                        String jmsBrokerURI = jmsBrokerURIIterator.next();
                        uriBuilder.append("tcp://");
                        uriBuilder.append(jmsBrokerURI);
                        if (jmsBrokerURIIterator.hasNext())
                                uriBuilder.append(",");
                }

                String brokerUrl = BROKER_URL_PREFIX + uriBuilder + BROKER_URL_SUFFIX;

                ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(this.jmsUserName, this.jmsPassword,
                                brokerUrl);
                this.pooledConnectionFactory = new PooledConnectionFactory(connectionFactory);

                pooledConnectionFactory.setIdleTimeout(5000);
                pooledConnectionFactory.setMaxConnections(10);
                pooledConnectionFactory.start();

                return true;
        }

updateConfiguration()

void org.xdi.oxauth.audit.ApplicationAuditLogger.updateConfiguration ( @Observes @ConfigurationUpdate AppConfiguration  appConfiguration )

inline

                                                                                                          {
                this.updateState = true;
        }

メンバ詳解

ACK_MODE

final int org.xdi.oxauth.audit.ApplicationAuditLogger.ACK_MODE = Session.AUTO_ACKNOWLEDGE

private

appConfiguration

AppConfiguration org.xdi.oxauth.audit.ApplicationAuditLogger.appConfiguration

private

BROKER_URL_PREFIX

final String org.xdi.oxauth.audit.ApplicationAuditLogger.BROKER_URL_PREFIX = "failover:("

private

BROKER_URL_SUFFIX

final String org.xdi.oxauth.audit.ApplicationAuditLogger.BROKER_URL_SUFFIX = ")?timeout=5000&jms.useAsyncSend=true"

private

CLIENT_QUEUE_NAME

final String org.xdi.oxauth.audit.ApplicationAuditLogger.CLIENT_QUEUE_NAME = "oauth2.audit.logging"

private

enabledOAuthAuditnLogging

Boolean org.xdi.oxauth.audit.ApplicationAuditLogger.enabledOAuthAuditnLogging

private

jmsBrokerURISet

Set<String> org.xdi.oxauth.audit.ApplicationAuditLogger.jmsBrokerURISet

private

jmsPassword

String org.xdi.oxauth.audit.ApplicationAuditLogger.jmsPassword

private

jmsUserName

String org.xdi.oxauth.audit.ApplicationAuditLogger.jmsUserName

private

lock

final ReentrantLock org.xdi.oxauth.audit.ApplicationAuditLogger.lock = new ReentrantLock()

private

log

Logger org.xdi.oxauth.audit.ApplicationAuditLogger.log

private

pooledConnectionFactory

volatile PooledConnectionFactory org.xdi.oxauth.audit.ApplicationAuditLogger.pooledConnectionFactory

private

transacted

final boolean org.xdi.oxauth.audit.ApplicationAuditLogger.transacted = false

private

updateState

boolean org.xdi.oxauth.audit.ApplicationAuditLogger.updateState

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxAuth/Server/src/main/java/org/xdi/oxauth/audit/ApplicationAuditLogger.java