Package | Description |
---|---|
org.apache.activemq.artemis.api.core.client | |
org.apache.activemq.artemis.spi.core.remoting |
Modifier and Type | Method and Description |
---|---|
ConsumerContext |
ClientConsumer.getConsumerContext()
The server's ID associated with this consumer.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SessionContext.handleReceiveContinuation(ConsumerContext consumerID,
byte[] chunk,
int flowControlSize,
boolean isContinues) |
protected void |
SessionContext.handleReceiveLargeMessage(ConsumerContext consumerID,
org.apache.activemq.artemis.core.client.impl.ClientLargeMessageInternal clientLargeMessage,
long largeMessageSize) |
protected void |
SessionContext.handleReceiveMessage(ConsumerContext consumerID,
org.apache.activemq.artemis.core.client.impl.ClientMessageInternal message) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.