public class JmsAuditMessageQueue extends Object
JmsAuditMessageListener
to asynchronously receive the audit
messages and send them off to a respository.JmsAuditMessageListener
Constructor and Description |
---|
JmsAuditMessageQueue(javax.jms.ConnectionFactory connectionFactory,
String queueName,
String userName,
String password) |
Modifier and Type | Method and Description |
---|---|
void |
audit(AuditContext auditContext,
AuditMessage... auditMessages) |
void |
flush()
Forces all unsent messages in the queue to be sent
|
protected void |
handle(AuditContext auditContext,
String... auditRecords) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
shutdown
public JmsAuditMessageQueue(javax.jms.ConnectionFactory connectionFactory, String queueName, String userName, String password)
connectionFactory
- JMS connection factoryqueueName
- JMS destination of ATNA messagesuserName
- user name for JMS authenticationpassword
- user password for JMS authenticationjavax.jms.JMSException
- if no connection could be establishedprotected void handle(AuditContext auditContext, String... auditRecords)
public void flush()
AuditMessageQueue
public void audit(AuditContext auditContext, AuditMessage... auditMessages)
audit
in interface AuditMessageQueue
Copyright © 2018 Open eHealth Foundation. All rights reserved.