Skip to content
Snippets Groups Projects
Commit 0bb04b14 authored by Björn Vonheiden's avatar Björn Vonheiden
Browse files

Abstract functional Transport interface from workload generator.

Abstract the Interface to be more generic.
parent 002d873c
No related branches found
No related tags found
No related merge requests found
package theodolite.commons.workloadgeneration.functions; package theodolite.commons.workloadgeneration.functions;
import kieker.common.record.IMonitoringRecord;
/** /**
* This interface describes a function that consumes a {@link IMonitoringRecord}. This function is * This interface describes a function that consumes a message {@code T}. This function is dedicated
* dedicated to be used to transport individual messages to the messaging system. * to be used to transport individual messages to the messaging system.
* *
* @param <T> the type of records to send as messages. * @param <T> the type of records to send as messages.
*/ */
@FunctionalInterface @FunctionalInterface
public interface Transport<T extends IMonitoringRecord> { public interface Transport<T> {
void transport(final T message); void transport(final T message);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment