Package org.apache.airavata.ws.monitor.MonitorUtil

Examples of org.apache.airavata.ws.monitor.MonitorUtil.EventType

159
160
161
162
163
164
165
166
167
168
169
            logger.warn("Failed to process notification: " + message, e);
        }
    }

    private void handleEvent(EventData event, boolean forward, Graph graph) {
        EventType type = event.getType();
        String nodeID = event.getNodeID();
        Node node = graph.getNode(nodeID);

        if (type == MonitorUtil.EventType.WORKFLOW_INVOKED) {
            workflowStarted(graph, forward);
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
        // Repaints only the active canvas.
        this.xbayaGUI.getGraphCanvas().repaint();
    }

    private void handleEvent(EventData event, boolean forward) {
        EventType type = event.getType();
        //todo currrently we do not set the workflowID properly its just node ID
        URI workflowID = event.getWorkflowID();

        List<GraphCanvas> graphCanvases = this.xbayaGUI.getGraphCanvases();
        boolean found = false;
View Full Code Here
300
301
302
303
304
305
306
307
308
309
310
     * @param event
     * @param forward
     * @param graph
     */
    private void handleEvent(EventData event, boolean forward, Graph graph) {
        EventType type = event.getType();
        String nodeID = event.getNodeID();
        Node node = graph.getNode(nodeID);
        System.out.println(type);;
        // logger.info("type: " + type);
        if (type == MonitorUtil.EventType.WORKFLOW_INVOKED) {
View Full Code Here
183
184
185
186
187
188
189
190
191
192
193
        // Repaints only the active canvas.
        this.xbayaGUI.getGraphCanvas().repaint();
    }

    private void handleEvent(EventData event, boolean forward) {
        EventType type = event.getType();
        //todo currrently we do not set the workflowID properly its just node ID
        URI workflowID = event.getWorkflowID();

        List<GraphCanvas> graphCanvases = this.xbayaGUI.getGraphCanvases();
        boolean found = false;
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
     * @param event
     * @param forward
     * @param graph
     */
    private void handleEvent(EventData event, boolean forward, Graph graph) {
        EventType type = event.getType();
        String nodeID = event.getNodeID();
        Node node = graph.getNode(nodeID);
        System.out.println(type);
        ;
        // logger.info("type: " + type);
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
            logger.error("Error occured during Exception saving to the Registry");
        }
    }

    private void handleEvent(EventData event, boolean forward, Graph graph) throws AiravataAPIInvocationException {
        EventType type = event.getType();
        String nodeID = event.getNodeID();
        Node node = graph.getNode(nodeID);

        if (type == MonitorUtil.EventType.WORKFLOW_INVOKED) {
            workflowStarted(graph, forward);
View Full Code Here
195
196
197
198
199
200
201
202
203
204
205
    private String getWorkflowInput(String nodeID) throws MonitorException {
        logger.debug("Node:" + nodeID);
        List<EventData> events = this.eventData.getEvents();
        for (EventData event : events) {
            EventType type = event.getType();
            // TODO change this to read from the notification from GPEL.
            if (type != EventType.INVOKING_SERVICE) {
                continue;
            }
            String id = event.getNodeID();
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
    private String getOutput(String nodeID, String messageName, String parameterName) throws MonitorException {
        List<EventData> events = this.eventData.getEvents();
        for (EventData event : events) {
            // We need to find the notification that contains the output of the
            // service invocation.
            EventType type = event.getType();
            if (!(type == EventType.SENDING_RESULT || type == EventType.RECEIVED_RESULT)) {
                continue;
            }
            String id = event.getNodeID();
            if (!nodeID.equals(id)) {
View Full Code Here
TOP

Related Classes of org.apache.airavata.ws.monitor.MonitorUtil.EventType

  • org.apache.airavata.xbaya.interpretor.WorkflowInterpretorEventListener
  • org.apache.airavata.xbaya.modifier.WorkflowModifier
  • org.apache.airavata.xbaya.ui.monitor.MonitorEventHandler
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.