org.openmrs.hl7

Class HL7InQueueProcessor

java.lang.Object

org.openmrs.hl7.HL7InQueueProcessor

@Transactional
public class HL7InQueueProcessor
extends java.lang.Object

Processes message in the HL7 inbound queue. Messages are moved into either the archive or error table depending on success or failure of the processing. You may, however, set a global property that causes the processor to ignore messages regarding unknown patients from a non-local HL7 source. (i.e. those messages neither go to the archive or the error table.)

Version:

1.0

Constructor Summary

Constructors

Constructor and Description
HL7InQueueProcessor() Empty constructor (requires context to be set using setContext(Context) method before any other calls are made)

Method Summary

Modifier and Type	Method and Description
void	processHL7InQueue() Starts up a thread to process all existing HL7InQueue entries
void	processHL7InQueue(HL7InQueue hl7InQueue) Process a single queue entry from the inbound HL7 queue
boolean	processNextHL7InQueue() Transform the next pending HL7 inbound queue entry.

Methods inherited from class java.lang.Object

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

Constructor Detail

HL7InQueueProcessor

public HL7InQueueProcessor()

Empty constructor (requires context to be set using setContext(Context) method before any other calls are made)

Method Detail

processHL7InQueue

public void processHL7InQueue(HL7InQueue hl7InQueue)

Process a single queue entry from the inbound HL7 queue

Parameters:

hl7InQueue - queue entry to be processed

processNextHL7InQueue

public boolean processNextHL7InQueue()

Transform the next pending HL7 inbound queue entry. If there are no pending items in the queue, this method simply returns quietly.

Returns:

true if a queue entry was processed, false if queue was empty

processHL7InQueue

public void processHL7InQueue()
                       throws ca.uhn.hl7v2.HL7Exception

Starts up a thread to process all existing HL7InQueue entries

Throws:

ca.uhn.hl7v2.HL7Exception