Venu Gopal's Weblog: Venu Gopal's Weblog

Here is a code snippet that shows how to subscribe to a user state using Sun Diameter Sh API . The Notifications from the Home subscriber server(HSS) can be received by a Message Driver Bean(MDB). The code snippet of the MDB is also shown below.

<br/> try {<br/> InitialContext context = new InitialContext();<br/> UserProfileServer hss = (UserProfileServer) context.lookup("openims");<br/> UserProfileConnection upc = hss.createConnection();<br/> SubscribeKey subScribeKey = new SubscribeKey();<br/> subScribeKey.addDataReference(DataReference.IMS_USER_STATE);<br/> subScribeKey.addServiceIndicator("default_sp");<br/> subScribeKey.setExpiryTime("5000");<br/> UserIdentity uID = new UserIdentity("sip:bob-AT-open-ims-DOT-test", UserIdentityType.PUBLIC_USER_ID);<br/> subScribeKey.setUserIdentity(uID);<br/> subScribeKey.validate();<br/> UserProfileSubscriptionResponse response = upc.subscribe(subScribeKey, false);<br/> ProfileData data = response.getProfileData();<br/> } catch (ConnectException ex) {<br/> Logger.getLogger(NotificationServlet.class.getName()).log(Level.SEVERE, null, ex);<br/> } catch (KeyValidationException ex) {<br/> Logger.getLogger(NotificationServlet.class.getName()).log(Level.SEVERE, null, ex);<br/> } catch (NamingException ex) {<br/> Logger.getLogger(NotificationServlet.class.getName()).log(Level.SEVERE, null, ex);<br/> }<br/>

<br/> @MessageDriven(mappedName = "SubscriptionNotifier",messageListenerInterface = com.sun.diameter.application.sh.api.UserProfileMessageListener.class,<br/> activationConfig = {<br/> @ActivationConfigProperty(propertyName = "DestinationType", propertyValue = "com.sun.diameter.application.sh.api.UserProfileMessageListener"),<br/> @ActivationConfigProperty(propertyName = "clientId", propertyValue = "SubscribeNotifierBean"),<br/> @ActivationConfigProperty(propertyName = "subscriptionName", propertyValue = "SubscribeNotifierBean")<br/> })<br/> public class SubscribeNotifierBean implements UserProfileMessageListener {<br/> public SubscribeNotifierBean() {<br/> }<br/> public void doPNR(UserProfileNotificationRequest upnr) {<br/> try {<br/> InitialContext context = new InitialContext();<br/> // one can use the the realm name obtained from the UserProfileNotificationRequest to map to appropriate<br/> //resource.<br/> UserProfileServer hss = (UserProfileServer) context.lookup("openims");<br/> hss.createConnection().sendPushNotificationResponse(upnr, 2001, false);<br/> } catch (ConnectException ex) {<br/> Logger.getLogger(SubscribeNotifierBean.class.getName()).log(Level.SEVERE, null, ex);<br/> } catch (NamingException ex) {<br/> Logger.getLogger(SubscribeNotifierBean.class.getName()).log(Level.SEVERE, null, ex);<br/> }<br/> }<br/>

The below Admin console snaps of Sailfin 2.0 show Home Subscriber server (pone) configured with Connector Pool(openims_pool) and Connector resource (openims)

Here are simple steps :
1.Using Sailfin 2.0 Admin console(Sailfin 2.0 also supports cli commands)
a)Create a Diameter application
b)Create a Diameter Peer ---- Diameter Peer screen also allows you to configure connector pool and resource.
2.Write a SIP Servlet with code snippet shown above
3.Write a MDB as shown above
4.Deploy the sar and jar and you should be done.