Package | Description |
---|---|
org.apache.qpid.proton.messenger | |
org.apache.qpid.proton.messenger.impl |
Modifier and Type | Method and Description |
---|---|
void |
Messenger.recv()
Receives an arbitrary number of messages into the
incoming queue of the Messenger.
|
void |
Messenger.recv(int count)
Receives up to the specified number of messages into the
incoming queue of the Messenger.
|
void |
Messenger.send()
Blocks until the outgoing queue is empty and, in the event that
an outgoing window has been set, until the messages in that
window have been received by the target to which they were
sent, or the operation times out.
|
void |
Messenger.send(int n) |
boolean |
Messenger.work(long timeout)
Sends or receives any outstanding messages queued for a
messenger.
|
Modifier and Type | Method and Description |
---|---|
void |
MessengerImpl.recv() |
void |
MessengerImpl.recv(int n) |
void |
MessengerImpl.send() |
void |
MessengerImpl.send(int n) |
boolean |
MessengerImpl.work(long timeout) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.