public interface AMQPSessionCallback
Modifier and Type | Method and Description |
---|---|
void |
ack(Object brokerConsumer,
Object message) |
boolean |
bindingQuery(String address) |
void |
cancel(Object brokerConsumer,
Object message,
boolean updateCounts) |
void |
close() |
void |
closeSender(Object brokerConsumer) |
void |
commitCurrentTX() |
void |
createDurableQueue(String address,
String queueName) |
Object |
createSender(ProtonPlugSender protonSender,
String queue,
String filer,
boolean browserOnly) |
void |
createTemporaryQueue(String queueName) |
void |
createTemporaryQueue(String address,
String queueName) |
void |
deleteQueue(String address) |
org.apache.qpid.proton.message.ProtonJMessage |
encodeMessage(Object message,
int deliveryCount) |
org.apache.qpid.proton.amqp.Binary |
getCurrentTXID() |
String |
getPubSubPrefix() |
void |
init(AMQPSessionContext session,
SASLResult saslResult) |
void |
offerProducerCredit(String address,
int credits,
int threshold,
org.apache.qpid.proton.engine.Receiver receiver) |
void |
onFlowConsumer(Object consumer,
int credits,
boolean drain) |
boolean |
queueQuery(String queueName) |
void |
resumeDelivery(Object consumer) |
void |
rollbackCurrentTX(boolean lastMessageReceived) |
void |
serverSend(org.apache.qpid.proton.engine.Receiver receiver,
org.apache.qpid.proton.engine.Delivery delivery,
String address,
int messageFormat,
io.netty.buffer.ByteBuf messageEncoded) |
void |
start() |
void |
startSender(Object brokerConsumer) |
String |
tempQueueName() |
void init(AMQPSessionContext session, SASLResult saslResult) throws Exception
Exception
void start()
void onFlowConsumer(Object consumer, int credits, boolean drain)
Object createSender(ProtonPlugSender protonSender, String queue, String filer, boolean browserOnly) throws Exception
Exception
void createTemporaryQueue(String address, String queueName) throws Exception
Exception
void createDurableQueue(String address, String queueName) throws Exception
Exception
void offerProducerCredit(String address, int credits, int threshold, org.apache.qpid.proton.engine.Receiver receiver)
org.apache.qpid.proton.message.ProtonJMessage encodeMessage(Object message, int deliveryCount) throws Exception
Exception
org.apache.qpid.proton.amqp.Binary getCurrentTXID()
String tempQueueName()
void rollbackCurrentTX(boolean lastMessageReceived) throws Exception
Exception
void cancel(Object brokerConsumer, Object message, boolean updateCounts) throws Exception
brokerConsumer
- message
- updateCounts
- this identified if the cancel was because of a failure or just cleaning up the
client's cache.
in some implementations you could call this failedException
void resumeDelivery(Object consumer)
void serverSend(org.apache.qpid.proton.engine.Receiver receiver, org.apache.qpid.proton.engine.Delivery delivery, String address, int messageFormat, io.netty.buffer.ByteBuf messageEncoded) throws Exception
delivery
- address
- messageFormat
- messageEncoded
- a Heap Buffer ByteBuffer (safe to convert into byte[])Exception
String getPubSubPrefix()
Copyright © 2016 The Apache Software Foundation. All rights reserved.