src/main/java/org/eclipse/openk/core/bpmn/gridmeasure/tasks/ServiceMeasureRejected.java

/*
******************************************************************************
* Copyright © 2018 PTA GmbH.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* 
*     http://www.eclipse.org/legal/epl-v10.html
* 
******************************************************************************
*/
package org.eclipse.openk.core.bpmn.gridmeasure.tasks;

import javax.mail.MessagingException;
import org.apache.log4j.Logger;
import org.eclipse.openk.api.mail.EmailTemplatePaths;
import org.eclipse.openk.core.bpmn.base.ProcessException;
import org.eclipse.openk.core.bpmn.base.tasks.ServiceTask;
import org.eclipse.openk.core.bpmn.gridmeasure.PlgmProcessSubject;
import org.eclipse.openk.core.controller.BackendConfig;
import org.eclipse.openk.core.controller.EmailManager;
import org.eclipse.openk.core.controller.PgmEmail;
import org.eclipse.openk.core.messagebroker.Producer;


public class ServiceMeasureRejected extends ServiceTask<PlgmProcessSubject> {
    private static final Logger LOGGER = Logger.getLogger(ServiceMeasureRejected.class.getName());
    public ServiceMeasureRejected() {
        super("Service task 'zurückgewiesen'");
    }

    @Override
    protected void onLeaveStep(PlgmProcessSubject model) throws ProcessException {

        try {
            EmailTemplatePaths paths = BackendConfig.getInstance().getEmailTemplatePaths();
            String template = paths.getRejectedEmailTemplate();
            EmailManager emailManager = new PgmEmail(model, template, true);
            emailManager.sendEmail();
        } catch (MessagingException e) {
            LOGGER.error("Error in ServiceMeasureRejected onLeaveStep (EmailManager)", e);
            throw new ProcessException("Error in ServiceMeasureRejected onLeaveStep (EmailManager)");
        }
        LOGGER.debug(">>execute: Send Mail on 'zurückgewiesen'");

        try (Producer prod = createMessageQueueProducer()) {
            prod.sendMessageAsJson(model.getGridMeasure(), "rejected");
        } catch (Exception e) {
            LOGGER.error("Error in ServiceMeasureCanceled onLeaveStep (RabbitMQ)", e);
            throw new ProcessException("Error in ServiceMeasureCanceled onLeaveStep (RabbitMQ)");
        }
        LOGGER.debug(">>execute: basicPublish RabbitMQ");
    }


}