View Javadoc
1   /**
2    * This Source Code Form is subject to the terms of the Mozilla Public
3    * License, v. 2.0. If a copy of the MPL was not distributed with this
4    * file, You can obtain one at http://mozilla.org/MPL/2.0/.
5    *
6    * If it is not possible or desirable to put the notice in a particular
7    * file, then You may include the notice in a location (such as a LICENSE
8    * file in a relevant directory) where a recipient would be likely to look
9    * for such a notice.
10  
11   * 
12   */
13   
14  /*  ---------------------------------------------------------------------------
15   *  U.S. Government, Department of the Army
16   *  Army Materiel Command
17   *  Research Development Engineering Command
18   *  Communications Electronics Research Development and Engineering Center
19   *  ---------------------------------------------------------------------------
20   */
21  
22  package org.miloss.fgsms.wsn.broker;
23  
24  import javax.annotation.Resource;
25  import javax.jws.WebMethod;
26  import javax.jws.WebParam;
27  import javax.jws.WebResult;
28  import javax.jws.WebService;
29  import javax.jws.soap.SOAPBinding;
30  import javax.xml.bind.annotation.XmlSeeAlso;
31  import javax.xml.datatype.DatatypeFactory;
32  import javax.xml.ws.WebServiceContext;
33  import org.apache.log4j.Logger;
34  import org.oasis_open.docs.wsn.b_2.*;
35  import org.oasis_open.docs.wsn.brw_2.*;
36  
37  /**
38   *
39   * @author Administrator
40   */
41  @WebService(name = "PausableSubscriptionManager", targetNamespace = "http://docs.oasis-open.org/wsn/brw-2", serviceName = "PausableSubscriptionManagerService", portName = "PausableSubscriptionManagerPort"
42  ,wsdlLocation = "brw-2impl.wsdl")
43  @SOAPBinding(parameterStyle = SOAPBinding.ParameterStyle.BARE)
44  @XmlSeeAlso({
45      org.oasis_open.docs.wsrf.r_2.ObjectFactory.class,
46      org.oasis_open.docs.wsrf.bf_2.ObjectFactory.class,
47      org.oasis_open.docs.wsn.t_1.ObjectFactory.class,
48      org.oasis_open.docs.wsn.b_2.ObjectFactory.class,
49      org.oasis_open.docs.wsn.br_2.ObjectFactory.class
50  })
51  public class PausableSubscriptionManagerService implements org.oasis_open.docs.wsn.brw_2.PausableSubscriptionManager {
52  
53      private DatatypeFactory df = null;
54      @Resource
55      private WebServiceContext ctx;
56      final static Logger log = Logger.getLogger("WS-NotificationBroker");
57  
58      /**
59       *
60       * @param renewRequest
61       * @return returns org.oasis_open.docs.wsn.b_2.RenewResponse
62       * @throws UnacceptableTerminationTimeFault
63       * @throws ResourceUnknownFault
64       */
65      @WebMethod(operationName = "Renew", action = "Renew")
66      @WebResult(name = "RenewResponse", targetNamespace = "http://docs.oasis-open.org/wsn/b-2", partName = "RenewResponse")
67      public RenewResponse renew(
68              @WebParam(name = "Renew", targetNamespace = "http://docs.oasis-open.org/wsn/b-2", partName = "RenewRequest") Renew renewRequest)
69              throws ResourceUnknownFault, UnacceptableTerminationTimeFault {
70          return null;
71      }
72  
73      /**
74       *
75       * @param unsubscribeRequest
76       * @return returns org.oasis_open.docs.wsn.b_2.UnsubscribeResponse
77       * @throws UnableToDestroySubscriptionFault
78       * @throws ResourceUnknownFault
79       */
80      @WebMethod(operationName = "Unsubscribe", action = "Unsubscribe")
81      @WebResult(name = "UnsubscribeResponse", targetNamespace = "http://docs.oasis-open.org/wsn/b-2", partName = "UnsubscribeResponse")
82      public UnsubscribeResponse unsubscribe(
83              @WebParam(name = "Unsubscribe", targetNamespace = "http://docs.oasis-open.org/wsn/b-2", partName = "UnsubscribeRequest") Unsubscribe unsubscribeRequest)
84              throws ResourceUnknownFault, UnableToDestroySubscriptionFault {
85          SingletonBroker.getInstance();
86          SingletonBroker.RemoveSubscription(unsubscribeRequest.getAny());
87          UnsubscribeResponse res = new UnsubscribeResponse();
88          return res;
89      }
90  
91      /**
92       *
93       * @param pauseSubscriptionRequest
94       * @return returns org.oasis_open.docs.wsn.b_2.PauseSubscriptionResponse
95       * @throws PauseFailedFault
96       * @throws ResourceUnknownFault
97       */
98      @WebMethod(operationName = "PauseSubscription", action = "PauseSubscription")
99      @WebResult(name = "PauseSubscriptionResponse", targetNamespace = "http://docs.oasis-open.org/wsn/b-2", partName = "PauseSubscriptionResponse")
100     public PauseSubscriptionResponse pauseSubscription(
101             @WebParam(name = "PauseSubscription", targetNamespace = "http://docs.oasis-open.org/wsn/b-2", partName = "PauseSubscriptionRequest") PauseSubscription pauseSubscriptionRequest)
102             throws PauseFailedFault, ResourceUnknownFault {
103         SingletonBroker.getInstance();
104         SingletonBroker.PauseSubscription(pauseSubscriptionRequest);
105         PauseSubscriptionResponse res = new PauseSubscriptionResponse();
106         return res;
107     }
108 
109     /**
110      *
111      * @param resumeSubscriptionRequest
112      * @return returns org.oasis_open.docs.wsn.b_2.ResumeSubscriptionResponse
113      * @throws ResumeFailedFault
114      * @throws ResourceUnknownFault
115      */
116     @WebMethod(operationName = "ResumeSubscription", action = "ResumeSubscription")
117     @WebResult(name = "ResumeSubscriptionResponse", targetNamespace = "http://docs.oasis-open.org/wsn/b-2", partName = "ResumeSubscriptionResponse")
118     public ResumeSubscriptionResponse resumeSubscription(
119             @WebParam(name = "ResumeSubscription", targetNamespace = "http://docs.oasis-open.org/wsn/b-2", partName = "ResumeSubscriptionRequest") ResumeSubscription resumeSubscriptionRequest)
120             throws ResourceUnknownFault, ResumeFailedFault {
121            SingletonBroker.getInstance();
122         SingletonBroker.ResumeSubscription(resumeSubscriptionRequest);
123         ResumeSubscriptionResponse res = new ResumeSubscriptionResponse();
124         return res;
125     }
126 }