public final class MessageTracker extends Object
Constructor and Description |
---|
MessageTracker(Channel channel,
int limit) |
Modifier and Type | Method and Description |
---|---|
MessageOutputStream |
openMessage()
Open a message, blocking if necessary.
|
MessageOutputStream |
openMessageUninterruptibly()
Open a message, blocking if necessary, and deferring any interrupts which occur while blocking.
|
public MessageTracker(Channel channel, int limit)
public MessageOutputStream openMessage() throws IOException, InterruptedException
IOException
- if the channel failed to open the messageInterruptedException
- if blocking was interruptedpublic MessageOutputStream openMessageUninterruptibly() throws IOException
IOException
- if the channel failed to open the messageCopyright © 2020 JBoss by Red Hat. All rights reserved.