Open Kilda Java Documentation
Public Member Functions | List of all members
org.openkilda.wfm.topology.OutputCollectorMock Class Reference
Inheritance diagram for org.openkilda.wfm.topology.OutputCollectorMock:

Public Member Functions

List< Integer > emit (String streamId, Collection< Tuple > anchors, List< Object > tuple)
 
void emitDirect (int taskId, String streamId, Collection< Tuple > anchors, List< Object > tuple)
 
void ack (Tuple input)
 
void fail (Tuple input)
 
void resetTimeout (Tuple input)
 
void reportError (Throwable error)
 
int getMessagesCount (String streamId)
 
List< Integer > emit (String streamId, Tuple anchor, List< Object > tuple)
 

Detailed Description

Created by atopilin on 31/07/2017.

Definition at line 31 of file OutputCollectorMock.java.

Member Function Documentation

◆ ack()

void org.openkilda.wfm.topology.OutputCollectorMock.ack ( Tuple  input)

Definition at line 47 of file OutputCollectorMock.java.

◆ emit() [1/2]

List<Integer> org.openkilda.wfm.topology.OutputCollectorMock.emit ( String  streamId,
Collection< Tuple >  anchors,
List< Object >  tuple 
)

Definition at line 35 of file OutputCollectorMock.java.

◆ emit() [2/2]

List<Integer> org.openkilda.wfm.topology.OutputCollectorMock.emit ( String  streamId,
Tuple  anchor,
List< Object >  tuple 
)

Definition at line 70 of file OutputCollectorMock.java.

◆ emitDirect()

void org.openkilda.wfm.topology.OutputCollectorMock.emitDirect ( int  taskId,
String  streamId,
Collection< Tuple >  anchors,
List< Object >  tuple 
)

Definition at line 42 of file OutputCollectorMock.java.

◆ fail()

void org.openkilda.wfm.topology.OutputCollectorMock.fail ( Tuple  input)

Definition at line 52 of file OutputCollectorMock.java.

◆ getMessagesCount()

int org.openkilda.wfm.topology.OutputCollectorMock.getMessagesCount ( String  streamId)

Definition at line 66 of file OutputCollectorMock.java.

◆ reportError()

void org.openkilda.wfm.topology.OutputCollectorMock.reportError ( Throwable  error)

Definition at line 62 of file OutputCollectorMock.java.

◆ resetTimeout()

void org.openkilda.wfm.topology.OutputCollectorMock.resetTimeout ( Tuple  input)

Definition at line 57 of file OutputCollectorMock.java.

The documentation for this class was generated from the following file: