Class MllpSocketBuffer
- java.lang.Object
-
- org.apache.camel.component.mllp.internal.MllpSocketBuffer
-
public class MllpSocketBuffer extends Object
An OutputStream modeled after the ByteArrayOutputStream specifically for MLLP operations.
-
-
Constructor Summary
Constructors Constructor Description MllpSocketBuffer(MllpEndpoint endpoint)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
bufferSize()
int
capacity()
void
closeMllpEnvelope()
void
closeSocket(Socket socket)
void
closeSocket(Socket socket, String logMessage)
static String
formatAddressString(SocketAddress sourceAddress, SocketAddress targetAddress)
byte[]
getBuffer()
Get the internal buffer.int
getEndOfBlockIndex()
byte[]
getLeadingOutOfBandData()
int
getMllpPayloadLength()
int
getStartOfBlockIndex()
byte[]
getTrailingOutOfBandData()
boolean
hasCompleteEnvelope()
boolean
hasEndOfBlock()
boolean
hasEndOfData()
boolean
hasLeadingOutOfBandData()
boolean
hasOutOfBandData()
boolean
hasStartOfBlock()
boolean
hasTrailingOutOfBandData()
static boolean
isConnectionValid(Socket socket)
boolean
isEmpty()
boolean
isEndOfDataRequired()
void
openMllpEnvelope()
void
readFrom(Socket socket)
void
readFrom(Socket socket, int receiveTimeout, int readTimeout)
void
reset()
void
resetSocket(Socket socket)
void
resetSocket(Socket socket, String logMessage)
void
setEnvelopedMessage(byte[] hl7Payload)
void
setEnvelopedMessage(byte[] hl7Payload, int offset, int length)
int
size()
byte[]
toByteArray()
byte[]
toByteArrayAndReset()
String
toHl7String()
String
toHl7String(String charsetName)
String
toHl7String(Charset charset)
String
toHl7StringAndReset()
String
toHl7StringAndReset(String charsetName)
byte[]
toMllpPayload()
byte[]
toMllpPayloadAndReset()
String
toPrintFriendlyHl7String()
Convert the enveloped contents of the buffer (excluding enveloping characters) to a print-friendly String representation.String
toPrintFriendlyHl7StringAndReset()
String
toPrintFriendlyString()
Convert the entire contents of the buffer (including enveloping characters) to a print-friendly String representation.String
toPrintFriendlyStringAndReset()
String
toString()
String
toString(String charsetName)
String
toString(Charset charset)
String
toStringAndReset()
String
toStringAndReset(String charsetName)
void
write(byte[] b)
void
write(byte[] sourceBytes, int offset, int writeCount)
void
write(int b)
void
writeTo(Socket socket)
-
-
-
Constructor Detail
-
MllpSocketBuffer
public MllpSocketBuffer(MllpEndpoint endpoint)
-
-
Method Detail
-
isEndOfDataRequired
public boolean isEndOfDataRequired()
-
isEmpty
public boolean isEmpty()
-
write
public void write(int b)
-
write
public void write(byte[] b)
-
write
public void write(byte[] sourceBytes, int offset, int writeCount)
-
openMllpEnvelope
public void openMllpEnvelope()
-
closeMllpEnvelope
public void closeMllpEnvelope()
-
setEnvelopedMessage
public void setEnvelopedMessage(byte[] hl7Payload)
-
setEnvelopedMessage
public void setEnvelopedMessage(byte[] hl7Payload, int offset, int length)
-
reset
public void reset()
-
readFrom
public void readFrom(Socket socket) throws MllpSocketException, SocketTimeoutException
-
readFrom
public void readFrom(Socket socket, int receiveTimeout, int readTimeout) throws MllpSocketException, SocketTimeoutException
-
writeTo
public void writeTo(Socket socket) throws MllpSocketException
- Throws:
MllpSocketException
-
toByteArray
public byte[] toByteArray()
-
toByteArrayAndReset
public byte[] toByteArrayAndReset()
-
toStringAndReset
public String toStringAndReset()
-
toPrintFriendlyString
public String toPrintFriendlyString()
Convert the entire contents of the buffer (including enveloping characters) to a print-friendly String representation.- Returns:
- print-friendly String
-
toPrintFriendlyStringAndReset
public String toPrintFriendlyStringAndReset()
-
toHl7String
public String toHl7String()
-
toHl7StringAndReset
public String toHl7StringAndReset()
-
toPrintFriendlyHl7String
public String toPrintFriendlyHl7String()
Convert the enveloped contents of the buffer (excluding enveloping characters) to a print-friendly String representation.- Returns:
- print-friendly String
-
toPrintFriendlyHl7StringAndReset
public String toPrintFriendlyHl7StringAndReset()
-
toMllpPayload
public byte[] toMllpPayload()
-
toMllpPayloadAndReset
public byte[] toMllpPayloadAndReset()
-
getMllpPayloadLength
public int getMllpPayloadLength()
-
getStartOfBlockIndex
public int getStartOfBlockIndex()
-
getEndOfBlockIndex
public int getEndOfBlockIndex()
-
hasCompleteEnvelope
public boolean hasCompleteEnvelope()
-
hasStartOfBlock
public boolean hasStartOfBlock()
-
hasEndOfBlock
public boolean hasEndOfBlock()
-
hasEndOfData
public boolean hasEndOfData()
-
hasOutOfBandData
public boolean hasOutOfBandData()
-
hasLeadingOutOfBandData
public boolean hasLeadingOutOfBandData()
-
hasTrailingOutOfBandData
public boolean hasTrailingOutOfBandData()
-
getLeadingOutOfBandData
public byte[] getLeadingOutOfBandData()
-
getTrailingOutOfBandData
public byte[] getTrailingOutOfBandData()
-
size
public int size()
-
capacity
public int capacity()
-
bufferSize
public int bufferSize()
-
getBuffer
public byte[] getBuffer()
Get the internal buffer. USE WITH CAUTION!!- Returns:
-
closeSocket
public void closeSocket(Socket socket)
-
resetSocket
public void resetSocket(Socket socket)
-
isConnectionValid
public static boolean isConnectionValid(Socket socket)
-
formatAddressString
public static String formatAddressString(SocketAddress sourceAddress, SocketAddress targetAddress)
-
-