rcomp-mail/src/main/java/component/mail/MailComponent.java

package component.mail;

import javax.mail.Session;

import org.osgi.service.component.annotations.Component;
import org.osgi.service.component.annotations.Reference;
import org.reactivestreams.Publisher;
import org.reactivestreams.Subscriber;

import component.api.MComponent;

@Component(property="name=mail")
public class MailComponent implements MComponent {
    
    @Reference
    Session session;

    @Override
    public <T> Publisher<T> from(String topic, Class<? extends T> type) {
        throw new RuntimeException();
    }  
    
    @Override
    public <T> Subscriber<T> to(String destination, Class<? extends T> type) {
        return new MailDestination<T>(destination, type);
    }

}