| Package | Description |
|---|---|
| org.hobbit.core.rabbit.consume | |
| org.hobbit.core.rabbit.paired |
| Modifier and Type | Field and Description |
|---|---|
protected Map<String,DataReceiveState> |
QueueingConsumerBasedImpl.streamStats |
protected Map<String,DataReceiveState> |
MessageConsumerImpl.streamStats
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
QueueingConsumerBasedImpl.processMessageData(byte[] messageData,
DataReceiveState state) |
protected void |
MessageConsumerImpl.processMessageData(byte[] messageData,
DataReceiveState state)
Deprecated.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<String,DataReceiveState> |
PairedConsumerImpl.streamStats |
| Modifier and Type | Method and Description |
|---|---|
protected void |
PairedConsumerImpl.processMessageData(byte[] messageData,
DataReceiveState state) |
Copyright © 2017–2018. All rights reserved.