Examples of unsubscribe()

Examples of org.jivesoftware.smackx.pubsub.Node.unsubscribe()

46
47
48
49
50
51
52
53
54
55
56
   
                if(sub.booleanValue()) { // contains the new value (soll)
                    node.subscribe(jid);
                    System.out.println(jid + " subscribed to " + node.getId());
                } else {
                    node.unsubscribe(jid);
                    System.out.println(jid + " unsubscribed from " + node.getId());
                }
            } catch(Exception ex) {
                ex.printStackTrace();
            }
View Full Code Here

Examples of org.jresearch.gossip.dao.ForumDAO.unsubscribe()

84
85
86
87
88
89
90
91
92
93
94
      uname = user.getName();
      email = user.getInfo().getEmail();
    }
    try {
     
      if (dao.unsubscribe(email, uname, sForm.getTid())) {
        if (user.getStatus() == 0) {
          setStatusMessage(request, "mails.OK1");
        }
      } else if (user.getStatus() == 0) {
        errors.add(ActionErrors.GLOBAL_ERROR, new ActionError(
View Full Code Here

Examples of org.olat.core.util.notifications.NotificationsManager.unsubscribe()

1230
1231
1232
1233
1234
1235
1236
1237
1238
1239
1240
    for (Iterator iterator = l.iterator(); iterator.hasNext();) {
      Subscriber subscriber = (Subscriber) iterator.next();
      Long resId = subscriber.getPublisher().getResId();
      Long groupKey = group.getKey();
      if (resId != null && groupKey != null && resId.equals(groupKey)) {
        notiMgr.unsubscribe(subscriber);
      }
    }
  }

  /**
 
View Full Code Here

Examples of org.olat.course.run.calendar.CourseCalendarSubscription.unsubscribe()

144
145
146
147
148
149
150
151
152
153
154
        confirmRemoveDialog = activateOkCancelDialog(ureq, translate("cal.icalfeed.remove.title"), translate("cal.icalfeed.remove.confirmation_message"), confirmRemoveDialog);
      } else if (command.equals(CMD_UNSUBSCRIBE)) {
        currentCalendarID = ureq.getParameter(PARAM_ID);
        KalendarRenderWrapper calendarWrapper = findKalendarRenderWrapper(currentCalendarID);
        CalendarSubscription subscription = new CourseCalendarSubscription(calendarWrapper.getKalendar(), ureq.getUserSession().getGuiPreferences());
        subscription.unsubscribe();
       
        for (Iterator<KalendarRenderWrapper> it=calendars.iterator(); it.hasNext(); ) {
          KalendarRenderWrapper calendar = it.next();
          if (calendarWrapper.getKalendar().getCalendarID().equals(calendar.getKalendar().getCalendarID())) {
            it.remove();
View Full Code Here

Examples of org.projectodd.stilts.stomp.client.ClientSubscription.unsubscribe()

116
117
118
119
120
121
122
123
124
125
126
        Assert.assertTrue("No latch timeout", outboundLatch.await(10, TimeUnit.SECONDS));
        Assert.assertTrue("Contains msg1", outbound.contains("msg1"));
        Assert.assertTrue("Contains msg2", outbound.contains("msg2"));

        subscription.unsubscribe();
        client.disconnect();
    }

    @Test
    public void testSendWithTxCommit() throws Exception {
View Full Code Here

Examples of org.red5.server.api.scope.IBroadcastScope.unsubscribe()

521
522
523
524
525
526
527
528
529
530
531
        if (stream instanceof IBroadcastStream) {
          IBroadcastStream bs = (IBroadcastStream) stream;
          if (bs.getPublishedName() != null) {
            IBroadcastScope bsScope = getBroadcastScope(conn.getScope(), bs.getPublishedName());
            if (bsScope != null) {
              bsScope.unsubscribe(bs.getProvider());
              if (conn instanceof BaseConnection) {
                ((BaseConnection) conn).unregisterBasicScope(bsScope);
              }
            }
            bs.close();
View Full Code Here

Examples of org.rioproject.monitor.service.channel.ServiceChannel.unsubscribe()

228
229
230
231
232
233
234
235
236
237
238
        boolean update = (this.svcElement != null);
        ServiceElement preElem = svcElement;
        this.svcElement = newElem;

        ServiceChannel channel = ServiceChannel.getInstance();
        channel.unsubscribe(localServiceChannelClient);
        for (AssociationDescriptor aDesc : svcElement.getAssociationDescriptors()) {
            if (aDesc.getAssociationType() == AssociationType.COLOCATED) {
                channel.subscribe(localServiceChannelClient, aDesc, ServiceChannelEvent.Type.PROVISIONED);
            }
        }
View Full Code Here

Examples of org.serviceconnector.api.cln.SCPublishService.unsubscribe()

79
80
81
82
83
84
85
86
87
88
89
      LOGGER.error("run", e);
    } finally {
      try {
        SCSubscribeMessage msg = new SCSubscribeMessage();
        msg.setSessionInfo("kill server");
        service.unsubscribe(5, msg);
        sc.detach(2); // detaches from SC, stops communication
      } catch (Exception e) {
        LOGGER.info("cleanup " + e.toString());
      }
    }
View Full Code Here

Examples of org.serviceconnector.server.StatefulServer.unsubscribe()

148
149
150
151
152
153
154
155
156
157
158
      // reset msgType, might have been modified in below unsubscribe try
      reqMessage.setMessageType(this.getKey());
      // set up callback for normal client unsubscribe operation
      callback = new CscUnsubscribeCommandCallback(request, response, responderCallback, cascSubscription);
      try {
        server.unsubscribe(reqMessage, callback, otiOnSCMillis - (i * Constants.WAIT_FOR_FREE_CONNECTION_INTERVAL_MILLIS));
        // delete unreferenced nodes in queue
        publishMessageQueue.removeNonreferencedNodes();
        // no exception has been thrown - get out of wait loop
        break;
      } catch (ConnectionPoolBusyException ex) {
View Full Code Here

Examples of org.springframework.data.keyvalue.redis.connection.Subscription.unsubscribe()

618
619
620
621
622
623
624
625
626
627
628
        synchronized (localMonitor) {
          if (connection != null) {
            Subscription sub = connection.getSubscription();
            if (sub != null) {
              sub.pUnsubscribe();
              sub.unsubscribe();
            }
          }
        }
      }
    }
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.