Modifier and Type | Method and Description |
---|---|
void |
CoreSessionCallback.browserFinished(ServerConsumer consumer) |
void |
CoreSessionCallback.disconnect(ServerConsumer consumerId,
String queueName) |
boolean |
CoreSessionCallback.hasCredits(ServerConsumer consumer) |
int |
CoreSessionCallback.sendLargeMessage(MessageReference ref,
ServerMessage message,
ServerConsumer consumer,
long bodySize,
int deliveryCount) |
int |
CoreSessionCallback.sendLargeMessageContinuation(ServerConsumer consumer,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
CoreSessionCallback.sendMessage(MessageReference ref,
ServerMessage message,
ServerConsumer consumer,
int deliveryCount) |
boolean |
CoreSessionCallback.updateDeliveryCountAfterCancel(ServerConsumer consumer,
MessageReference ref,
boolean failed) |
Modifier and Type | Method and Description |
---|---|
void |
ProtonSessionIntegrationCallback.browserFinished(ServerConsumer consumer) |
void |
ProtonSessionIntegrationCallback.disconnect(ServerConsumer consumer,
String queueName) |
boolean |
ProtonSessionIntegrationCallback.hasCredits(ServerConsumer consumer) |
int |
ProtonSessionIntegrationCallback.sendLargeMessage(MessageReference ref,
ServerMessage message,
ServerConsumer consumer,
long bodySize,
int deliveryCount) |
int |
ProtonSessionIntegrationCallback.sendLargeMessageContinuation(ServerConsumer consumer,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
ProtonSessionIntegrationCallback.sendMessage(MessageReference ref,
ServerMessage message,
ServerConsumer consumer,
int deliveryCount) |
boolean |
ProtonSessionIntegrationCallback.updateDeliveryCountAfterCancel(ServerConsumer consumer,
MessageReference ref,
boolean failed) |
Modifier and Type | Method and Description |
---|---|
void |
StompSession.browserFinished(ServerConsumer consumer) |
void |
StompSession.disconnect(ServerConsumer consumerId,
String queueName) |
boolean |
StompSession.hasCredits(ServerConsumer consumerID) |
int |
StompSession.sendLargeMessage(MessageReference ref,
ServerMessage msg,
ServerConsumer consumer,
long bodySize,
int deliveryCount) |
int |
StompSession.sendLargeMessageContinuation(ServerConsumer consumer,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
StompSession.sendMessage(MessageReference ref,
ServerMessage serverMessage,
ServerConsumer consumer,
int deliveryCount) |
boolean |
StompSession.updateDeliveryCountAfterCancel(ServerConsumer consumer,
MessageReference ref,
boolean failed) |
Modifier and Type | Method and Description |
---|---|
ServerConsumer |
ServerSession.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ServerConsumer |
ServerSession.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage,
Integer credits) |
ServerConsumer |
ServerSession.locateConsumer(long consumerID) |
Modifier and Type | Method and Description |
---|---|
Set<ServerConsumer> |
ServerSession.getServerConsumers() |
Modifier and Type | Method and Description |
---|---|
void |
SlowConsumerDetectionListener.onSlowConsumer(ServerConsumer consumer) |
Modifier and Type | Class and Description |
---|---|
class |
ServerConsumerImpl
Concrete implementation of a ClientConsumer.
|
Modifier and Type | Field and Description |
---|---|
protected Map<Long,ServerConsumer> |
ServerSessionImpl.consumers |
Modifier and Type | Method and Description |
---|---|
ServerConsumer |
ServerSessionImpl.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ServerConsumer |
ServerSessionImpl.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage,
Integer credits) |
ServerConsumer |
ServerSessionImpl.locateConsumer(long consumerID) |
Modifier and Type | Method and Description |
---|---|
Set<ServerConsumer> |
ServerSessionImpl.getServerConsumers() |
Modifier and Type | Method and Description |
---|---|
void |
SessionCallback.browserFinished(ServerConsumer consumer)
Some protocols (Openwire) needs a special message with the browser is finished.
|
void |
SessionCallback.disconnect(ServerConsumer consumerId,
String queueName) |
boolean |
SessionCallback.hasCredits(ServerConsumer consumerID)
This one gives a chance for Proton to have its own flow control.
|
int |
SessionCallback.sendLargeMessage(MessageReference reference,
ServerMessage message,
ServerConsumer consumerID,
long bodySize,
int deliveryCount) |
int |
SessionCallback.sendLargeMessageContinuation(ServerConsumer consumerID,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
SessionCallback.sendMessage(MessageReference ref,
ServerMessage message,
ServerConsumer consumerID,
int deliveryCount) |
boolean |
SessionCallback.updateDeliveryCountAfterCancel(ServerConsumer consumer,
MessageReference ref,
boolean failed)
Use this to updates specifics on the message after a redelivery happened.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.