Examples of unsubscribe()

Examples of org.xmlBlaster.client.I_XmlBlasterAccess.unSubscribe()

71
72
73
74
75
76
77
78
79
80
81
            if (ch == 'p') {
               con.publish(new MsgUnit("<key oid='EmailDemo'/>", "Hi"
                     .getBytes(), "<qos/>"));
            }
            if (ch == 'u') {
               con.unSubscribe("<key oid='EmailDemo'/>", "<qos/>");
               break;
            }
         }

         con.disconnect(null);
View Full Code Here

Examples of org.xmlBlaster.client.I_XmlBlasterAccess.unSubscribe()

113
114
115
116
117
118
119
120
121
122
123
            catch( InterruptedException ie) {} // wait a second to receive update()


            UnSubscribeKey uk = new UnSubscribeKey(con.getGlobal(), subRet.getSubscriptionId());
            UnSubscribeQos uq = new UnSubscribeQos(con.getGlobal());
            UnSubscribeReturnQos[] urq = con.unSubscribe(uk.toXml(), uq.toXml());

            EraseKey ek = new EraseKey(con.getGlobal(), "AllProtocols");
            EraseQos eq = new EraseQos(con.getGlobal());
            EraseReturnQos[] eraseArr = con.erase(ek.toXml(), eq.toXml());
View Full Code Here

Examples of org.xmlBlaster.client.I_XmlBlasterAccess.unSubscribe()

171
172
173
174
175
176
177
178
179
180
181
            else
               fail("testCreation failed: " + e.getMessage());
         }

         try {
            xmlBlasterAccess.unSubscribe((String)null, null);
         }
         catch (XmlBlasterException e) {
            if (e.isUser())
               log.info("Exception is OK if not connected: " + e.getErrorCode());
            else
View Full Code Here

Examples of org.xmlBlaster.client.I_XmlBlasterAccess.unSubscribe()

181
182
183
184
185
186
187
188
189
190
191
            else
               fail("testCreation failed: " + e.getMessage());
         }

         try {
            xmlBlasterAccess.unSubscribe((UnSubscribeKey)null, null);
         }
         catch (XmlBlasterException e) {
            if (e.isUser())
               log.info("Exception is OK if not connected: " + e.getErrorCode());
            else
View Full Code Here

Examples of org.xmlBlaster.client.I_XmlBlasterAccess.unSubscribe()

103
104
105
106
107
108
109
110
111
112
113
         //----------- Unsubscribe from the previous message --------
         log.fine("Unsubscribe ...");
         stop.restart();
         try {
            blasterConnection.unSubscribe(xmlKey, "<qos></qos>");
            log.info("Unsubscribe done" + stop.nice());
         } catch(XmlBlasterException e) {
            log.severe("Unsubscribe failed, XmlBlasterException: " + e.getMessage());
         }
View Full Code Here

Examples of org.xmlBlaster.engine.admin.I_AdminSession.unSubscribe()

419
420
421
422
423
424
425
426
427
428
429
      // first unsubscribe (in case it did already an initial update previously, this is needed to remove the subscription
      // (and thereby its outdate subscription qos from persistence). On a back replication, i.e. where you have more than
      // one sources you don't want to do this.
      if (individualInfo.getBoolean("replication.forceNewSubscription", true)) {
         try {
            session.unSubscribe(this.dataTopic, "");
         }
         catch (Throwable ex) {
         }
      }
     
View Full Code Here

Examples of org.xmlBlaster.engine.admin.I_AdminSession.unSubscribe()

199
200
201
202
203
204
205
206
207
208
209
         I_AdminSession receiver = ((ServerScope)glob).getAuthenticate().getSubjectInfoByName(dispatchManager.getSessionName()).getSessionByPubSessionId(dispatchManager.getSessionName().getPublicSessionId());
         String[] subIds = receiver.getSubscriptions();
         if (log.isLoggable(Level.FINE))
            log.fine(receiver.getLoginName() + "/" + receiver.getPublicSessionId() + " toPolling, removing " + subIds.length + " subscriptions");
         for (int i=0; i<subIds.length; i++) {
            receiver.unSubscribe(Constants.SUBSCRIPTIONID_URL_PREFIX+subIds[i], null);
         }
      } catch (Throwable e) {
         e.printStackTrace();
      }
   }
View Full Code Here

Examples of org.zkoss.zss.model.Book.unsubscribe()

335
336
337
338
339
340
341
342
343
344
345
      return;
    }
    for (EventListener listener : bookListeners.keySet()) {
      boolean subscribed = bookListeners.get(listener);
      if (subscribed) {
        book.unsubscribe(listener);
        bookListeners.put(listener, Boolean.FALSE);
      }
    }
  }
 
View Full Code Here

Examples of redis.clients.jedis.JedisPubSub.unsubscribe()

496
497
498
499
500
501
502
503
504
505
506
      }

      public void onPSubscribe(String pattern, int subscribedChannels) {
      }
  };
  pubsub.unsubscribe();
    }

    @Test(expected = JedisConnectionException.class)
    public void handleClientOutputBufferLimitForSubscribeTooSlow()
      throws InterruptedException {
View Full Code Here

Examples of rx.Scheduler.Worker.unsubscribe()

42
43
44
45
46
47
48
49
50
51
52
                try {
                    action.call(p);
                } catch (Exception e) {
                    p.onError(e);
                } finally {
                    worker.unsubscribe();
                }
            }

        });
        return HystrixFuture.create(p, new Action0() {
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.