| Package | Description |
|---|---|
| org.hobbit.core.components | |
| org.hobbit.core.components.stream | |
| org.hobbit.core.rabbit | |
| org.hobbit.core.rabbit.consume | |
| org.hobbit.core.rabbit.paired |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractEvaluationModule
This abstract class implements basic functions that can be used to implement
a task generator.
|
protected class |
AbstractEvaluationStorage.ExpectedResponseReceiver
Receiver handling the expected responses.
|
protected class |
AbstractEvaluationStorage.SystemResponseReceiver
Receiver handling the responses coming from the system.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractStreamingEvaluationModule
This abstract class implements basic functions that can be used to implement
a task generator.
|
protected class |
AbstractStreamingSystemAdapter.GeneratedDataHandler
A simple internal handler class that calls
StreamingGeneratedDataReceivingComponent.receiveGeneratedData(InputStream) with
the given InputStream. |
protected class |
AbstractStreamingSystemAdapter.GeneratedTaskHandler
A simple internal handler class that calls
AbstractStreamingTaskGenerator.generateTask(InputStream) with the
given InputStream. |
protected class |
AbstractStreamingTaskGenerator.GeneratedDataHandler
A simple internal handler class that calls
AbstractStreamingTaskGenerator.generateTask(InputStream) with the
given InputStream. |
| Modifier and Type | Field and Description |
|---|---|
private IncomingStreamHandler |
DataReceiverImpl.dataHandler |
private IncomingStreamHandler |
DataReceiverImpl.Builder.dataHandler |
| Modifier and Type | Method and Description |
|---|---|
IncomingStreamHandler |
DataReceiver.getDataHandler() |
IncomingStreamHandler |
DataReceiverImpl.getDataHandler() |
| Modifier and Type | Method and Description |
|---|---|
DataReceiverImpl.Builder |
DataReceiverImpl.Builder.dataHandler(IncomingStreamHandler dataHandler)
Sets the handler that is called if data is incoming.
|
| Constructor and Description |
|---|
DataReceiverImpl(RabbitQueue queue,
IncomingStreamHandler handler,
MessageConsumerBuilder consumerBuilder,
int maxParallelProcessedMsgs,
String name) |
| Modifier and Type | Field and Description |
|---|---|
private IncomingStreamHandler |
StreamHandlerCall.handler |
| Constructor and Description |
|---|
StreamHandlerCall(String streamId,
InputStream stream,
IncomingStreamHandler handler) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
PairedStreamHandler |
Copyright © 2017–2018. All rights reserved.