Class JmsAuditMessageQueue

java.lang.Object

org.openehealth.ipf.commons.audit.queue.AbstractAuditMessageQueue

org.openehealth.ipf.commons.audit.queue.JmsAuditMessageQueue

All Implemented Interfaces:

AuditMessageQueue

public class JmsAuditMessageQueue
extends AbstractAuditMessageQueue

Message Queue that sends audit messages into a JMS queue. It is strongly recommended that the connection factory implements a pool or caches connections for performance reasons. Use an instance of JmsAuditMessageListener to asynchronously receive the audit messages and send them to a repository.

This is primarily meant to send audit messages to a JMS-based relay that eventually sends the audit record to an audit repository. Therefore, RFC 5425 metadata is placed in X-IPF-ATNA-* JMS properties, so the listener is able to restore them.

Since:

3.5

Author:

Dmytro Rud, Christian Ohr

See Also:

• JmsAuditMessageListener

Field Summary

Fields inherited from interface AuditMessageQueue

X_IPF_ATNA_APPLICATION, X_IPF_ATNA_HOSTNAME, X_IPF_ATNA_PROCESSID, X_IPF_ATNA_TIMESTAMP

Constructor Summary

Constructors

Constructor	Description
JmsAuditMessageQueue(jakarta.jms.ConnectionFactory connectionFactory, String queueName, String userName, String password)

Method Summary

Modifier and Type	Method	Description
protected void	handle(AuditContext auditContext, String auditMessage)

Methods inherited from class AbstractAuditMessageQueue

audit, setPretty

Methods inherited from class Object

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

Methods inherited from interface AuditMessageQueue

flush, shutdown

Constructor Details

JmsAuditMessageQueue

public JmsAuditMessageQueue(jakarta.jms.ConnectionFactory connectionFactory,
 String queueName,
 String userName,
 String password)

Parameters:

connectionFactory - JMS connection factory

queueName - JMS destination of ATNA messages

userName - user name for JMS authentication

password - user password for JMS authentication

Method Details

handle

protected void handle(AuditContext auditContext,
 String auditMessage)

Specified by:

handle in class AbstractAuditMessageQueue