AutoCloseable, CloseableDataSenderImplpublic interface DataSender extends Closeable
| Modifier and Type | Method | Description |
|---|---|---|
void |
closeWhenFinished() |
A blocking method that closes the sender when its work is done, i.e., all
messages have been consumed by receivers from the queue.
|
void |
sendData(byte[] data) |
Send the given data to the queue.
|
void sendData(byte[] data)
throws IOException
data - the data that should be sentIOException - if an exception occurs during the communication with the
queuevoid closeWhenFinished()
Copyright © 2017. All rights reserved.