Modifier and Type | Method and Description |
---|---|
static Message |
Proton.message() |
static Message |
Proton.message(Header header,
DeliveryAnnotations deliveryAnnotations,
MessageAnnotations messageAnnotations,
Properties properties,
ApplicationProperties applicationProperties,
Section body,
Footer footer) |
Modifier and Type | Method and Description |
---|---|
Message |
AmqpSession.createBinaryMessage(byte[] value) |
Message |
AmqpSession.createBinaryMessage(byte[] value,
int offset,
int len) |
Message |
AmqpSession.createTextMessage(String value) |
Message |
MessageDelivery.getMessage() |
Modifier and Type | Method and Description |
---|---|
MessageDelivery |
AmqpSender.send(Message message) |
Constructor and Description |
---|
MessageDelivery(Message message) |
MessageDelivery(Message message,
org.fusesource.hawtbuf.Buffer encoded) |
Modifier and Type | Method and Description |
---|---|
Message |
EncodedMessage.decode() |
Modifier and Type | Method and Description |
---|---|
protected void |
InboundTransformer.populateMessage(javax.jms.Message jms,
Message amqp) |
Modifier and Type | Interface and Description |
---|---|
interface |
ProtonJMessage |
Modifier and Type | Method and Description |
---|---|
static Message |
Message.Factory.create() |
static Message |
Message.Factory.create(Header header,
DeliveryAnnotations deliveryAnnotations,
MessageAnnotations messageAnnotations,
Properties properties,
ApplicationProperties applicationProperties,
Section body,
Footer footer) |
Modifier and Type | Class and Description |
---|---|
class |
MessageImpl |
Modifier and Type | Method and Description |
---|---|
Message |
Messenger.get()
Returns the message from the head of the incoming message
queue.
|
Modifier and Type | Method and Description |
---|---|
void |
Messenger.put(Message message)
Places the content contained in the message onto the outgoing
queue of the Messenger.
|
Modifier and Type | Method and Description |
---|---|
Message |
MessengerImpl.get() |
Modifier and Type | Method and Description |
---|---|
void |
MessengerImpl.put(Message m) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.