Classes in this File | Line Coverage | Branch Coverage | Complexity | ||||
MllpEncoder |
|
| 1.75;1.75 |
1 | /* | |
2 | The contents of this file are subject to the Mozilla Public License Version 1.1 | |
3 | (the "License"); you may not use this file except in compliance with the License. | |
4 | You may obtain a copy of the License at http://www.mozilla.org/MPL/ | |
5 | Software distributed under the License is distributed on an "AS IS" basis, | |
6 | WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License for the | |
7 | specific language governing rights and limitations under the License. | |
8 | ||
9 | The Original Code is "MllpEncoder.java". Description: | |
10 | "Encodes a message string into an MLLP output stream" | |
11 | ||
12 | The Initial Developer of the Original Code is University Health Network. Copyright (C) | |
13 | 2013. All Rights Reserved. | |
14 | ||
15 | Contributor(s): ______________________________________. | |
16 | ||
17 | Alternatively, the contents of this file may be used under the terms of the | |
18 | GNU General Public License (the "GPL"), in which case the provisions of the GPL are | |
19 | applicable instead of those above. If you wish to allow use of your version of this | |
20 | file only under the terms of the GPL and not to allow others to use your version | |
21 | of this file under the MPL, indicate your decision by deleting the provisions above | |
22 | and replace them with the notice and other provisions required by the GPL License. | |
23 | If you do not delete the provisions above, a recipient may use your version of | |
24 | this file under either the MPL or the GPL. | |
25 | */ | |
26 | ||
27 | package ca.uhn.hl7v2.llp; | |
28 | ||
29 | import java.io.*; | |
30 | import java.nio.charset.Charset; | |
31 | ||
32 | /** | |
33 | * MllpEncoder encodes a String into an OutputStream | |
34 | * | |
35 | * @author Christian Ohr | |
36 | */ | |
37 | class MllpEncoder { | |
38 | ||
39 | protected Charset charset; | |
40 | protected boolean omitBOM; | |
41 | ||
42 | 773 | MllpEncoder(Charset charset, boolean omitBOM) { |
43 | 773 | this.charset = charset; |
44 | 773 | this.omitBOM = omitBOM; |
45 | 773 | } |
46 | ||
47 | /** | |
48 | * Returns a HL7 message string extracted from the MLLP stream | |
49 | * | |
50 | * @param in MLLP input stream | |
51 | * @return HL7 message string | |
52 | * @throws java.io.IOException | |
53 | * @throws ca.uhn.hl7v2.llp.LLPException | |
54 | */ | |
55 | public void putMessage(String message, OutputStream out) throws IOException, LLPException { | |
56 | // Try to enforce sending the message in one frame. Multiple calls to write() | |
57 | // may cause multiple frames being sent. | |
58 | 1446 | byte[] bytes = toByteArray(message); |
59 | 1446 | byte[] outBytes = new byte[bytes.length + 3]; |
60 | 1446 | outBytes[0] = MllpConstants.START_BYTE; |
61 | 1446 | System.arraycopy(bytes, 0, outBytes, 1, bytes.length); |
62 | 1446 | outBytes[outBytes.length - 2] = MllpConstants.END_BYTE1; |
63 | 1446 | outBytes[outBytes.length - 1] = MllpConstants.END_BYTE2; |
64 | ||
65 | 1446 | out.write(outBytes); |
66 | 1441 | out.flush(); |
67 | 1441 | } |
68 | ||
69 | /** | |
70 | * Converts the extract byte sequence into a String. This method must respect | |
71 | * a Charset, which is either statically configured or may be obtained at runtime. | |
72 | * | |
73 | * @param data HL7 message as byte sequence | |
74 | * @return HL7 message String using correct charset | |
75 | */ | |
76 | protected byte[] toByteArray(String message) { | |
77 | 1361 | return asByteArray(message, charset, omitBOM); |
78 | } | |
79 | ||
80 | protected static byte[] asByteArray(String message, Charset charset, boolean omitBOM) { | |
81 | try { | |
82 | 1446 | byte[] b = message.getBytes(charset.name()); |
83 | 1446 | return omitBOM ? CharSetUtil.withoutBOM(b) : b; |
84 | 0 | } catch (UnsupportedEncodingException e) { |
85 | // never happens | |
86 | 0 | return null; |
87 | } | |
88 | } | |
89 | ||
90 | } |