rcomp-api/src/main/java/component/api/MComponent.java

package component.api;

import org.reactivestreams.Publisher;
import org.reactivestreams.Subscriber;

public interface MComponent<T> {
    Publisher<T> from(String destination);
    Subscriber<T> to(String destination);
}