public interface SessionCallback
Modifier and Type | Method and Description |
---|---|
void |
closed() |
void |
disconnect(org.apache.activemq.artemis.core.server.ServerConsumer consumerId,
String queueName) |
boolean |
hasCredits(org.apache.activemq.artemis.core.server.ServerConsumer consumerID)
This one gives a chance for Proton to have its own flow control.
|
boolean |
isWritable(ReadyListener callback) |
int |
sendLargeMessage(org.apache.activemq.artemis.core.server.ServerMessage message,
org.apache.activemq.artemis.core.server.ServerConsumer consumerID,
long bodySize,
int deliveryCount) |
int |
sendLargeMessageContinuation(org.apache.activemq.artemis.core.server.ServerConsumer consumerID,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
sendMessage(org.apache.activemq.artemis.core.server.ServerMessage message,
org.apache.activemq.artemis.core.server.ServerConsumer consumerID,
int deliveryCount) |
void |
sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
sendProducerCreditsMessage(int credits,
SimpleString address) |
boolean hasCredits(org.apache.activemq.artemis.core.server.ServerConsumer consumerID)
void sendProducerCreditsMessage(int credits, SimpleString address)
void sendProducerCreditsFailMessage(int credits, SimpleString address)
int sendMessage(org.apache.activemq.artemis.core.server.ServerMessage message, org.apache.activemq.artemis.core.server.ServerConsumer consumerID, int deliveryCount)
int sendLargeMessage(org.apache.activemq.artemis.core.server.ServerMessage message, org.apache.activemq.artemis.core.server.ServerConsumer consumerID, long bodySize, int deliveryCount)
int sendLargeMessageContinuation(org.apache.activemq.artemis.core.server.ServerConsumer consumerID, byte[] body, boolean continues, boolean requiresResponse)
void closed()
void disconnect(org.apache.activemq.artemis.core.server.ServerConsumer consumerId, String queueName)
boolean isWritable(ReadyListener callback)
Copyright © 2015. All rights reserved.