diff --git a/workload-generator-commons/src/main/java/theodolite/commons/workloadgeneration/functions/Transport.java b/workload-generator-commons/src/main/java/theodolite/commons/workloadgeneration/functions/Transport.java index 7c95e24f2b97d6259ec8c1bb4c75a356ef477287..7e5100a4e99f13a98156311a9d892c9626b2318a 100644 --- a/workload-generator-commons/src/main/java/theodolite/commons/workloadgeneration/functions/Transport.java +++ b/workload-generator-commons/src/main/java/theodolite/commons/workloadgeneration/functions/Transport.java @@ -1,15 +1,13 @@ package theodolite.commons.workloadgeneration.functions; -import kieker.common.record.IMonitoringRecord; - /** - * This interface describes a function that consumes a {@link IMonitoringRecord}. This function is - * dedicated to be used to transport individual messages to the messaging system. + * This interface describes a function that consumes a message {@code T}. This function is dedicated + * to be used to transport individual messages to the messaging system. * * @param <T> the type of records to send as messages. */ @FunctionalInterface -public interface Transport<T extends IMonitoringRecord> { +public interface Transport<T> { void transport(final T message);