public void onNext()

in rcomp-mail/src/main/java/org/apache/karaf/rcomp/mail/MailDestination.java [47:56]

• 10 lines of code
• 2 McCabe index (conditional complexity)

    public void onNext(T message) {
        try {
            Address[] addresses = new Address[]{new InternetAddress(destination)};
            Transport.send(convertTo(message), addresses);
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            subscription.request(1);
        }
    }