Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   *
   * Licensed to the Apache Software Foundation (ASF) under one
   * or more contributor license agreements.  See the NOTICE file
   * distributed with this work for additional information
   * regarding copyright ownership.  The ASF licenses this file
   * to you under the Apache License, Version 2.0 (the
   * "License"); you may not use this file except in compliance
   * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  * KIND, either express or implied.  See the License for the
  * specific language governing permissions and limitations
  * under the License.
  *
  */
 
 package org.apache.airavata.ws.monitor;
 
 import java.net.URI;
 
 
 
     private static final Logger logger = LoggerFactory.getLogger(WsmgClient.class);
 
     private Monitor monitor;
 
     private URI brokerURL;
 
     private String topic;
 
     private boolean pullMode;
 
     private URI messageBoxURL;
 
     private WseMsgBrokerClient wseClient;
 
     private String subscriptionID;
 
     private MessagePuller messagePuller;
 
     private long timeout = 20000L;
 
     private long interval = 1000L;
    
Constructs a WsmgClient.

Parameters:
monitor
 
     public WsmgClient(Monitor monitor) {
         this. = monitor;
 
         MonitorConfiguration configuration = monitor.getConfiguration();
         // We need to copy these because the configuration might change.
         this. = configuration.getBrokerURL();
         this. = configuration.getTopic();
         this. = configuration.isPullMode();
         this. = configuration.getMessageBoxURL();
 
         this. = new WseMsgBrokerClient();
         this..init(this..toString());
     }

    
Subscribes to the notification.

 
     public synchronized void subscribe() throws MonitorException {
         try {
             if (this.) {
                 EndpointReference messageBoxEPR = this..createPullMsgBox(this..toString(),getTimeout());
                 this. = this..subscribe(messageBoxEPR.getAddress(), this.null);
                 this. = this..startPullingEventsFromMsgBox(messageBoxEPRthisgetInterval(), getTimeout());
             } else {
                 String[] endpoints = this..startConsumerService(2222, this);
                 this. = this..subscribe(endpoints[0], this.null);
             }
         } catch (IOException e) {
             throw new MonitorException("Failed to subscribe."e);
         } catch (RuntimeException e) {
             throw new MonitorException("Failed to subscribe."e);
        }
    }

    
Unsubscribes from the notification.

    public synchronized void unsubscribe() throws MonitorException {
        // This method needs to be synchronized along with subscribe() because
        // unsubscribe() might be called while subscribe() is being executed.
        if (this. == null) {
            throw new IllegalStateException();
        }
        try {
            if (this.) {
                this..stopPulling();
            } else {
                this..shutdownConsumerService();
            }
            this..unSubscribe(this.);
        } catch (MsgBrokerClientException e) {
            throw new MonitorException("Failed to unsubscribe."e);
        }
    }

    
    public void handleNotification(SOAPEnvelope message) {
        String soapBody = message.getBody().toString();
        this.handleNotification(soapBody);
    }

    

Parameters:
message
    public void handleNotification(String message) {
        try {
            XmlElement event = XMLUtil.stringToXmlElement(message);
            this..handleNotification(event);
        } catch (Exception e) {
            // Just log them because they can be unrelated messages sent to
            // this topic by accident.
            .warn("Could not parse received notification: " + messagee);
        }
    }
    public long getTimeout() {
        return ;
    }
    public void setTimeout(long timeout) {
        this. = timeout;
    }
    public long getInterval() {
        return ;
    }
    public void setInterval(long interval) {
        this. = interval;
    }
New to GrepCode? Check out our FAQ X