Modifier and Type | Method and Description |
---|---|
Object |
ConsumerView.getField(ServerConsumer consumer,
String fieldName) |
JsonObjectBuilder |
ConsumerView.toJson(ServerConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
boolean |
ConsumerFilterPredicate.test(ServerConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
void |
PagedReferenceImpl.acknowledge(Transaction tx,
AckReason reason,
ServerConsumer consumer) |
void |
PagedReferenceImpl.acknowledge(Transaction tx,
ServerConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
void |
CoreSessionCallback.browserFinished(ServerConsumer consumer) |
void |
CoreSessionCallback.disconnect(ServerConsumer consumerId,
SimpleString queueName) |
boolean |
CoreSessionCallback.hasCredits(ServerConsumer consumer) |
int |
CoreSessionCallback.sendLargeMessage(MessageReference ref,
Message message,
ServerConsumer consumer,
long bodySize,
int deliveryCount) |
int |
CoreSessionCallback.sendLargeMessageContinuation(ServerConsumer consumer,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
CoreSessionCallback.sendMessage(MessageReference ref,
Message message,
ServerConsumer consumer,
int deliveryCount) |
boolean |
CoreSessionCallback.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 |
Queue.acknowledge(MessageReference ref,
AckReason reason,
ServerConsumer consumer) |
void |
Queue.acknowledge(MessageReference ref,
ServerConsumer consumer) |
void |
MessageReference.acknowledge(Transaction tx,
AckReason reason,
ServerConsumer consumer) |
void |
Queue.acknowledge(Transaction tx,
MessageReference ref,
AckReason reason,
ServerConsumer consumer) |
void |
MessageReference.acknowledge(Transaction tx,
ServerConsumer consumer) |
void |
Queue.expire(MessageReference ref,
ServerConsumer consumer) |
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 |
QueueImpl.acknowledge(MessageReference ref,
AckReason reason,
ServerConsumer consumer) |
void |
QueueImpl.acknowledge(MessageReference ref,
ServerConsumer consumer) |
void |
MessageReferenceImpl.acknowledge(Transaction tx,
AckReason reason,
ServerConsumer consumer) |
void |
QueueImpl.acknowledge(Transaction tx,
MessageReference ref,
AckReason reason,
ServerConsumer consumer) |
void |
MessageReferenceImpl.acknowledge(Transaction tx,
ServerConsumer consumer) |
void |
QueueImpl.expire(MessageReference ref,
ServerConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerPlugin.afterCloseConsumer(ServerConsumer consumer,
boolean failed)
After a consumer is closed
|
default void |
ActiveMQServerPlugin.afterCreateConsumer(ServerConsumer consumer)
After a consumer has been created
|
default void |
ActiveMQServerPlugin.afterDeliver(ServerConsumer consumer,
MessageReference reference)
After a message is delivered to a client consumer
|
default void |
ActiveMQServerPlugin.beforeCloseConsumer(ServerConsumer consumer,
boolean failed)
Before a consumer is closed
|
default void |
ActiveMQServerPlugin.beforeDeliver(ServerConsumer consumer,
MessageReference reference)
Before a message is delivered to a client consumer
|
default void |
ActiveMQServerPlugin.messageAcknowledged(MessageReference ref,
AckReason reason,
ServerConsumer consumer)
A message has been acknowledged
|
default void |
ActiveMQServerPlugin.messageExpired(MessageReference message,
SimpleString messageExpiryAddress,
ServerConsumer consumer)
A message has been expired
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingActiveMQServerPlugin.afterCloseConsumer(ServerConsumer consumer,
boolean failed)
After a consumer is closed
|
void |
LoggingActiveMQServerPlugin.afterCreateConsumer(ServerConsumer consumer)
After a consumer has been created
|
void |
NotificationActiveMQServerPlugin.afterDeliver(ServerConsumer consumer,
MessageReference reference) |
void |
LoggingActiveMQServerPlugin.afterDeliver(ServerConsumer consumer,
MessageReference reference)
After a message is delivered to a client consumer
|
void |
LoggingActiveMQServerPluginLogger.afterDeliverDetails(String messageID,
SimpleString queueAddress,
SimpleString queueName,
String consumerSessionID,
long consumerID,
MessageReference reference,
ServerConsumer consumer) |
void |
LoggingActiveMQServerPlugin.beforeCloseConsumer(ServerConsumer consumer,
boolean failed)
Before a consumer is closed
|
void |
LoggingActiveMQServerPluginLogger.beforeCloseConsumer(ServerConsumer consumer,
String sessionID,
boolean failed) |
void |
LoggingActiveMQServerPluginLogger.beforeDeliver(ServerConsumer consumer,
MessageReference reference) |
void |
LoggingActiveMQServerPlugin.beforeDeliver(ServerConsumer consumer,
MessageReference reference)
Before a message is delivered to a client consumer
|
void |
LoggingActiveMQServerPlugin.messageAcknowledged(MessageReference ref,
AckReason reason,
ServerConsumer consumer)
A message has been acknowledged
|
void |
NotificationActiveMQServerPlugin.messageExpired(MessageReference message,
SimpleString messageExpiryAddress,
ServerConsumer consumer) |
void |
LoggingActiveMQServerPlugin.messageExpired(MessageReference message,
SimpleString messageExpiryAddress,
ServerConsumer consumer) |
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,
SimpleString queueName) |
boolean |
SessionCallback.hasCredits(ServerConsumer consumerID)
This one gives a chance for Proton to have its own flow control.
|
int |
SessionCallback.sendLargeMessage(MessageReference reference,
Message message,
ServerConsumer consumerID,
long bodySize,
int deliveryCount) |
int |
SessionCallback.sendLargeMessageContinuation(ServerConsumer consumerID,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
SessionCallback.sendMessage(MessageReference ref,
Message 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 © 2018 JBoss by Red Hat. All rights reserved.