Examples of unsubscribe()


Examples of com.alibaba.dubbo.registry.Registry.unsubscribe()

                } catch (Throwable t) {
                  logger.warn(t.getMessage(), t);
                }
                try {
                  overrideListeners.remove(overrideSubscribeUrl);
                  registry.unsubscribe(overrideSubscribeUrl, overrideSubscribeListener);
                } catch (Throwable t) {
                  logger.warn(t.getMessage(), t);
                }
            }
        };
View Full Code Here

Examples of com.comcast.cns.persistence.CNSSubscriptionCassandraPersistence.unsubscribe()

     
      assertTrue("Subscriptions are not identical: " + s + "; " + sdup, s.equals(sdup));
     
      long beforeUnsubscribeCount = subscriptionHandler.getCountSubscription(t.getArn(), "subscriptionDeleted");

      subscriptionHandler.unsubscribe(s.getArn());
     
      long afterUnsubscribeCount = subscriptionHandler.getCountSubscription(t.getArn(), "subscriptionDeleted");

      l = subscriptionHandler.listSubscriptions(null, null, userId1);
View Full Code Here

Examples of com.comcast.cns.persistence.ICNSSubscriptionPersistence.unsubscribe()

     
      assertTrue("Subscriptions are not identical: " + s + "; " + sdup, s.equals(sdup));
     
      long beforeUnsubscribeCount = subscriptionHandler.getCountSubscription(t.getArn(), "subscriptionDeleted");

      subscriptionHandler.unsubscribe(s.getArn());
     
      long afterUnsubscribeCount = subscriptionHandler.getCountSubscription(t.getArn(), "subscriptionDeleted");

      l = subscriptionHandler.listSubscriptions(null, null, userId1);
View Full Code Here

Examples of com.genesys.wsclient.EventSubscription.unsubscribe()

      .operationName("NotReady")
      .execute();
   
    Thread.sleep(1000);
   
    subscription.unsubscribe();
   
    Thread.sleep(1000);
  }
 
  @Test
View Full Code Here

Examples of com.opengamma.livedata.LiveDataClient.unsubscribe()

  }

  @Override
  public void unsubscribe(UserPrincipal user, LiveDataSpecification fullyQualifiedSpecification, LiveDataListener listener) {
    LiveDataClient underlying = identifyUnderlying(fullyQualifiedSpecification);
    underlying.unsubscribe(user, fullyQualifiedSpecification, listener);
  }

  @Override
  public void unsubscribe(UserPrincipal user, Collection<LiveDataSpecification> fullyQualifiedSpecifications, LiveDataListener listener) {
    Map<LiveDataClient, List<LiveDataSpecification>> split = splitCollection(fullyQualifiedSpecifications);
View Full Code Here

Examples of gov.nasa.arc.mct.platform.spi.SubscriptionManager.unsubscribe()

        SubscriptionManager manager = getSubscriptionManager();
        if (manager != null) {

          for (FeedProvider feed:removedSubscriptions) {
                LOGGER.debug("removing subscription for {0}", feed.getSubscriptionId());
                manager.unsubscribe(feed.getSubscriptionId());
                activeFeeds.remove(feed);
            }
         
          List<String> newlyAddedSubscriptionIds = new ArrayList<String> (newSubscriptions.size());
            for (FeedProvider feed:newSubscriptions) {
View Full Code Here

Examples of javax.jms.QueueSession.unsubscribe()

    public void testQueueSessionCannoutUnsubscribe() throws Exception
    {
        QueueSession queueSession = getQueueSession();
        try
        {
            queueSession.unsubscribe("abc");
            fail("expected exception did not occur");
        }
        catch (javax.jms.IllegalStateException s)
        {
            // PASS
View Full Code Here

Examples of javax.jms.Session.unsubscribe()

      try
      {
         MessageConsumer cons = sess.createDurableSubscriber(topic, subName);
         cons.close();
         sess.unsubscribe(subName);
         log.trace("Successfully created and unsubscribed subscription");
         return true;
      }
      catch (JMSSecurityException e)
      {
View Full Code Here

Examples of javax.jms.Session.unsubscribe()

         assertEquals(NUM_MESSAGES, count);

         durable.close();

         sess1.unsubscribe("mySubscription");
      }
      finally
      {
         if (conn1 != null)
         {
View Full Code Here

Examples of javax.jms.Session.unsubscribe()

            producer.send(tm);
         }

         log.debug("all " + NUM_MESSAGES + " messages sent");

         sess2.unsubscribe("mySubscription1");

         log.debug("unsubscribed 'mySubscription1'");

         conn2.close();
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.