| Package | Description |
|---|---|
| org.hobbit.core.rabbit | |
| org.hobbit.core.rabbit.paired | |
| org.hobbit.core.utils |
| Modifier and Type | Field and Description |
|---|---|
protected IdGenerator |
DataSenderImpl.idGenerator |
protected IdGenerator |
DataSenderImpl.Builder.idGenerator |
| Modifier and Type | Method and Description |
|---|---|
DataSenderImpl.Builder |
DataSenderImpl.Builder.idGenerator(IdGenerator idGenerator)
Sets the Id generator used to create unique stream Ids.
|
| Constructor and Description |
|---|
DataSenderImpl(RabbitQueue queue,
IdGenerator idGenerator,
int messageSize,
int deliveryMode,
int messageConfirmBuffer,
String name) |
| Modifier and Type | Method and Description |
|---|---|
PairedDataSender.Builder |
PairedDataSender.Builder.idGenerator(IdGenerator idGenerator)
Sets the Id generator used to create unique stream Ids.
|
| Constructor and Description |
|---|
PairedDataSender(RabbitQueue queue,
IdGenerator idGenerator,
int messageSize,
int deliveryMode,
int messageConfirmBuffer,
String name) |
| Modifier and Type | Class and Description |
|---|---|
class |
RandomIdGenerator |
class |
SteppingIdGenerator |
Copyright © 2017–2018. All rights reserved.