Package | Description |
---|---|
ca.uhn.hl7v2.protocol | |
ca.uhn.hl7v2.protocol.impl |
Modifier and Type | Method and Description |
---|---|
Transportable |
ApplicationRouter.processMessage(Transportable theMessage)
Attempts to route the given message to the associated
Application
and obtain a response. |
Transportable |
TransportLayer.receive()
Gets the next message from the remote system.
|
Transportable |
Processor.receive(String theAckId,
long theTimeoutMillis)
Gets the message with the given acknowledgement ID from
the incoming message list.
|
Transportable[] |
SafeStorage.restore()
Returns all messages that have been stored.
|
Modifier and Type | Method and Description |
---|---|
AcceptValidator.AcceptRuling |
AcceptValidator.check(Transportable theMessage)
Returns a ruling regarding whether the given message can be accepted
for further processing (ie determines CE, CR, or CA for enhanced mode,
and AR for original mode).
|
void |
SafeStorage.discard(Transportable theMessage)
If the given message exists in the store, it is removed.
|
Transportable |
ApplicationRouter.processMessage(Transportable theMessage)
Attempts to route the given message to the associated
Application
and obtain a response. |
void |
TransportLayer.send(Transportable theMessage)
Sends a message to a remote HL7 service.
|
void |
Processor.send(Transportable theMessage,
int maxRetries,
long retryIntervalMillis)
Sends a message to a remote system via an underlying
TransportLayer . |
void |
SafeStorage.store(Transportable theMessage)
Stores a message so that it can be reliably retrieved and sent to
the proper application, even if this service is restarted in the mean
time.
|
Modifier and Type | Class and Description |
---|---|
class |
TransportableImpl
Default implementation of
Transportable . |
Modifier and Type | Method and Description |
---|---|
Transportable |
URLTransport.doReceive() |
Transportable |
JMSTransport.doReceive() |
Transportable |
AbstractJMSTransport.doReceive() |
abstract Transportable |
AbstractTransport.doReceive()
Called by receive(), which then adds common metadata.
|
Transportable |
MLLPTransport.doReceive() |
Transportable |
AcceptAcknowledger.AcceptACK.getMessage() |
Transportable |
ApplicationRouterImpl.processMessage(Transportable theMessage) |
Transportable |
AbstractTransport.receive()
Delegates to
doReceive() and adds common metadata
to the resulting Transportable before it is returned. |
Transportable |
ProcessorImpl.receive(String theAckId,
long theTimeoutMillis) |
Transportable[] |
NullSafeStorage.restore()
Returns an empty array.
|
protected Transportable |
JMSTransport.toTransportable(javax.jms.Message theMessage)
Copies data from the given Message into a Transportable.
|
protected Transportable |
AbstractJMSTransport.toTransportable(javax.jms.Message theMessage)
Copies data from the given Message into a Transportable.
|
Modifier and Type | Method and Description |
---|---|
void |
NullSafeStorage.discard(Transportable theMessage)
Does nothing.
|
void |
URLTransport.doSend(Transportable theMessage)
Writes the given message to the URL.
|
void |
JMSTransport.doSend(Transportable theMessage) |
void |
AbstractJMSTransport.doSend(Transportable theMessage) |
abstract void |
AbstractTransport.doSend(Transportable theMessage)
The method send() delegates to this method after checking whether we are
connected.
|
void |
MLLPTransport.doSend(Transportable theMessage) |
Transportable |
ApplicationRouterImpl.processMessage(Transportable theMessage) |
void |
AbstractTransport.send(Transportable theMessage)
Delegates to
doSend() after checking that we are connected. |
void |
ProcessorImpl.send(Transportable theMessage,
int maxRetries,
long retryIntervalMillis) |
void |
NullSafeStorage.store(Transportable theMessage)
Does nothing.
|
protected javax.jms.Message |
JMSTransport.toMessage(Transportable theSource)
Fills a JMS message object with text and metadata from the given
Transportable . |
protected javax.jms.Message |
AbstractJMSTransport.toMessage(Transportable theSource)
Fills a JMS message object with text and metadata from the given
Transportable . |
static AcceptAcknowledger.AcceptACK |
AcceptAcknowledger.validate(ProcessorContext theContext,
Transportable theMessage)
Validates the given message against our accept validators, attempts to commit
the message to safe storage, and returns an ACK message indicating acceptance
or rejection at the accept level (see enhanced mode processing rules in HL7
chapter 2, v2.5).
|
Constructor and Description |
---|
AcceptACK(boolean isAcceptable,
Transportable theAck) |
Copyright © 2001–2017 University Health Network. All rights reserved.