1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
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
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
61
62
63
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
76
77
78
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
94
95
96
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
112
113
114
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 }