Examples of addSubscription()

Examples of org.apache.ws.notification.subscription.SubscriptionTable.addSubscription()

47
48
49
50
51
52
53
54
55
56
57
      table    = mgr.createSubscriptionTable(  );
      t1       = createSubscription( 1 );
      t2       = createSubscription( 2 );

      table.addSubscription( t1 );
      table.addSubscription( t2 );

      assertEquals( 2,
                    table.getSubscriptionCount(  ) );

      t1       = (Subscription) roundTrip( t1 );
View Full Code Here

Examples of org.cipango.kaleo.location.event.RegResource.addSubscription()

326
327
328
329
330
331
332
333
334
335
336
   
        if (subscription == null)
        {
          subscription = new Subscription(regResource, session, now + expires*1000);
          subscription.setState(State.ACTIVE, Reason.SUBSCRIBE);
          regResource.addSubscription(subscription);
         
          session.setAttribute(Constants.SUBSCRIPTION_ATTRIBUTE, uri);
         
          if (_log.isDebugEnabled())
            _log.debug("added reg subscription {} to registration resource {}",
View Full Code Here

Examples of org.cipango.kaleo.presence.Presentity.addSubscription()

320
321
322
323
324
325
326
327
328
329
330
   
        if (subscription == null)
        {
          subscription = new Subscription(presentity, session, now + expires*1000, subscriberUri);
          subscription.addListener(_watcherInfo.getSubscriptionListener());
          presentity.addSubscription(subscription);
         
          switch (subHandling)
          {
          case ALLOW:
            subscription.setState(State.ACTIVE, Reason.SUBSCRIBE, true);
View Full Code Here

Examples of org.cipango.kaleo.presence.watcherinfo.WatcherResource.addSubscription()

454
455
456
457
458
459
460
461
462
463
464
   
        if (subscription == null)
        {
          subscription = new Subscription(resource, session, now + expires*1000, subscriberUri);
          subscription.setState(State.ACTIVE, Reason.SUBSCRIBE);
          resource.addSubscription(subscription);
         
          session.setAttribute(Constants.SUBSCRIPTION_ATTRIBUTE, uri);
         
          if (_log.isDebugEnabled())
            _log.debug("added presence.winfo subscription {} to resource {}",
View Full Code Here

Examples of org.exolab.jms.tools.migration.proxy.Consumer.addSubscription()

159
160
161
162
163
164
165
166
167
168
169
                        consumer = new Consumer(name, null);
                        consumers.put(name, consumer);
                    }
                    Subscription subscription = getSubscription(name,
                                                                destination);
                    consumer.addSubscription(subscription);
                }
            } else {
                final String name = destination.getName();
                Consumer consumer = (Consumer) consumers.get(name);
                if (consumer == null) {
View Full Code Here

Examples of org.exolab.jms.tools.migration.proxy.Consumer.addSubscription()

169
170
171
172
173
174
175
176
177
178
179
                if (consumer == null) {
                    consumer = new Consumer((JmsQueue) destination);
                    consumers.put(name, consumer);
                }
                Subscription subscription = getSubscription(name, destination);
                consumer.addSubscription(subscription);
            }
        }
        _database.commit();
        return consumers.values();
    }
View Full Code Here

Examples of org.wso2.carbon.billing.core.BillingEngine.addSubscription()

226
227
228
229
230
231
232
233
234
235
236
        subscription.setCustomer(customer);
        subscription.setActive(true);
        subscription.setActiveSince(subscriptionInfoBean.getActiveSince());
        subscription.setActiveUntil(subscriptionInfoBean.getActiveUntil());

        billingEngine.addSubscription(subscription);
    }

    public static Subscription getCurrentSubscription(UserRegistry userRegistry) throws Exception {
        BillingEngine billingEngine = billingManager.getBillingEngine(StratosConstants.MULTITENANCY_SCHEDULED_TASK_ID);
View Full Code Here

Examples of org.wso2.carbon.billing.core.DataAccessManager.addSubscription()

28
29
30
31
32
33
34
35
36
37
38
public class BillingDataAccessService extends AbstractAdmin{
    private static Log log = LogFactory.getLog(BillingDataAccessService.class);

    public int addSubscription (Subscription subscription) throws Exception {
        DataAccessManager dataAccessManager = Util.getDataAccessManager();
        return dataAccessManager.addSubscription(subscription);
    }

    public Customer getCustomerWithName (String customerName) throws Exception {
        DataAccessManager dataAccessManager = Util.getDataAccessManager();
        Customer customer = null;
View Full Code Here

Examples of org.wso2.carbon.billing.mgt.services.BillingDataAccessService.addSubscription()

678
679
680
681
682
683
684
685
686
687
688
        String planName=tenantBean.getUsagePlan();
        subscription.setSubscriptionPlan(planName);
        int subscriptionId = 0;
        try {
            BillingDataAccessService dataAccessService = new BillingDataAccessService();
            subscriptionId = dataAccessService.addSubscription(subscription);
        } catch (Exception e) {
            log.error("Could not add new subscription for tenant: " +
                    tenantBean.getTenantDomain() + " " + e.getMessage(), e);
            return false;
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.