List of unsubscribe() Examples

Examples of unsubscribe()

com.alibaba.dubbo.registry.Registry.unsubscribe()
com.comcast.cns.persistence.CNSSubscriptionCassandraPersistence.unsubscribe()
com.comcast.cns.persistence.ICNSSubscriptionPersistence.unsubscribe()
Unsubscribe from a topic. @param arn subscription arn @throws Exception
com.genesys.wsclient.EventSubscription.unsubscribe()
com.opengamma.livedata.LiveDataClient.unsubscribe()
Deletes a market data subscription. @param user the user credentials, not null @param fullyQualifiedSpecification what market data you no longer want to subscribe to. @param listener the listener that receives the results of the unsubscription request
gov.nasa.arc.mct.platform.spi.SubscriptionManager.unsubscribe()
Remove the subscription from the specified feed. The mechanism for removing the subscription (and even whether it is necessary) is at the sole discretion of the providers. @param feedIDs opaque string representing a unique identifier for the feed (this string must be recognized uniquely among multiple feeds). A concrete example of this would be the URL for an ATOM feed.
javax.jms.QueueSession.unsubscribe()
javax.jms.Session.unsubscribe()
javax.jms.TopicSession.unsubscribe()
net.timewalker.ffmq3.local.destination.LocalTopic.unsubscribe()
Unsubscribe all durable consumers for a given client ID and subscription name
net.timewalker.ffmq3.local.session.LocalSession.unsubscribe()
org.apache.airavata.wsmg.client.WseMsgBrokerClient.unSubscribe()
org.apache.airavata.wsmg.client.WsntMsgBrokerClient.unSubscribe()
org.apache.cocoon.portal.event.EventManager.unsubscribe()
Unsubscribes a receiver for all events.
org.apache.cxf.wsn.client.Subscription.unsubscribe()
org.apache.hedwig.client.api.Subscriber.unsubscribe()
Unsubscribe from a topic that the subscriberId user has previously subscribed to. @param topic Topic name of the subscription @param subscriberId ID of the subscriber @throws CouldNotConnectException If we are not able to connect to the server host @throws ClientNotSubscribedException If the client is not currently subscribed to the topic @throws ServiceDownException If the server was down and unable to complete the request @throws InvalidSubscriberIdException If the subscriberId is not valid. We may want to set aside certain formats of subscriberId's for different purposes. e.g. local vs. hub subscriber
org.apache.servicemix.wsn.client.Subscription.unsubscribe()
org.apache.servicemix.wsn.jbi.JbiNotificationBroker.unsubscribe()
org.apache.tomcat.bayeux.ChannelImpl.unsubscribe()
org.apache.vysper.xmpp.modules.extension.xep0060_pubsub.model.LeafNode.unsubscribe()
Remove a subscription of a JID with a given subscription ID. @param subscriptionID the subscription ID of the JID. @param subscriber the JID of the subscriber. @return true if the subscription has been removed, false otherwise.
org.apache.ws.eventing.Subscription.unsubscribe()
DOCUMENT_ME
org.axonframework.saga.annotation.AsyncAnnotatedSagaManager.unsubscribe()
org.cometd.bayeux.client.ClientSessionChannel.unsubscribe()

Equivalent to {@link #unsubscribe(ClientSessionChannel.MessageListener,ClientSessionChannel.MessageListener) unsubscribe(listener, null)}.
@param listener the listener to unsubscribe
org.cspoker.server.embedded.chat.room.TableChatRoom.unSubscribe()
org.directwebremoting.Hub.unsubscribe()
Reverse the action of {@link #subscribe(String,MessageListener)} @param topicName The topic to subscribe to. @param listener The object to notify of matching calls to publish()
org.fusesource.mqtt.client.BlockingConnection.unsubscribe()
org.infinispan.objectfilter.impl.predicateindex.be.PredicateNode.unsubscribe()
org.jboss.jms.client.JBossSession.unsubscribe()
org.jboss.jms.delegate.SessionEndpoint.unsubscribe()
Unsubscribe the client from the durable subscription specified by subscriptionName @param subscriptionName the Name of the durable subscription to unsubscribe from @throws JMSException if the unsubscribe fails
org.jboss.jms.server.endpoint.SessionEndpoint.unsubscribe()
Unsubscribe the client from the durable subscription specified by subscriptionName @param subscriptionName the Name of the durable subscription to unsubscribe from @throws JMSException if the unsubscribe fails
org.jboss.seam.remoting.messaging.RemoteSubscriber.unsubscribe()
org.jivesoftware.smackx.pubsub.Node.unsubscribe()
Remove the subscription related to the specified JID. This will only work if there is only 1 subscription. If there are multiple subscriptions, use {@link #unsubscribe(String,String)}. @param jid The JID used to subscribe to the node @throws XMPPException
org.jresearch.gossip.dao.ForumDAO.unsubscribe()
DOCUMENT ME! @param email @param name @param tid @return DOCUMENT ME! @throws SQLException DOCUMENT ME!
org.olat.core.util.notifications.NotificationsManager.unsubscribe()
org.olat.course.run.calendar.CourseCalendarSubscription.unsubscribe()
org.projectodd.stilts.stomp.client.ClientSubscription.unsubscribe()
org.red5.server.api.scope.IBroadcastScope.unsubscribe()
Disconnect from a consumer. @param consumer Consumer to disconnect @return true when successfully unsubscribed,false otherwise.
org.rioproject.monitor.service.channel.ServiceChannel.unsubscribe()
org.serviceconnector.api.cln.SCPublishService.unsubscribe()
Unsubscribe from SC with default operation timeout. Unsubscribe may be called multiple times. Nothing happens if the subscription turns inactive in meantime. @throws SCServiceException unsubscribe from SC failed
error message received from SC
org.serviceconnector.server.StatefulServer.unsubscribe()
Unsubscribe. @param message the message @param callback the callback @param timeoutMillis the timeout millis @throws ConnectionPoolBusyException the connection pool busy exception
org.springframework.data.keyvalue.redis.connection.Subscription.unsubscribe()
Cancels the current subscription for all channels given by name.
org.wso2.carbon.event.client.broker.BrokerClient.unsubscribe()
org.wso2.carbon.registry.eventing.services.EventingService.unsubscribe()
Remove subscription corresponding to the given unique identifier. @param id unique identifier. @return the status of the operation.
org.xmlBlaster.client.I_XmlBlasterAccess.unSubscribe()
r.org/xmlBlaster/doc/requirements/interface.unSubscribe.html">interface.unSubscribe requirement @throws XmlBlasterException like ErrorCode.USER_NOT_CONNECTED and others
org.xmlBlaster.engine.admin.I_AdminSession.unSubscribe()
@param qos The qos XML string (e.g. "" or "") @return The status string
org.zkoss.zss.model.Book.unsubscribe()
Unsubscribe the specified listener from listening to this book @param listener
redis.clients.jedis.JedisPubSub.unsubscribe()
rx.Scheduler.Worker.unsubscribe()
rx.Subscription.unsubscribe()
rx.subscriptions.CompositeSubscription.unsubscribe()
rx.subscriptions.MultipleAssignmentSubscription.unsubscribe()

Examples of javax.jms.Session.unsubscribe()

            assertEquals("message" + i, tm.getText());
         }


         cons.close();


         session.unsubscribe("mysub1");
      }
      finally
      {
         if (conn != null)
         {

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

            assertEquals("message" + i, tm.getText());
         }


         cons.close();


         session.unsubscribe("mysub1");
      }
      finally
      {
         if (conn != null)
         {

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

        //check the dur sub's underlying queue now has msg count 0
        assertEquals("Msg count should be 0", 0, ((AMQSession<?, ?>) session2).getQueueDepth(subQueue, true));


        consumer2.close();
        _logger.info("Unsubscribe session2/consumer2");
        session2.unsubscribe("MySubscription");
        
        ((AMQSession<?, ?>) session2).sync();
        
        if(isJavaBroker())
        {

View Full Code Here

Examples of javax.jms.TopicSession.unsubscribe()


      TopicSession ts = conn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);


      try
      {
         ts.unsubscribe("invalid-subscription-name");
         fail("this should fail");
      }
      catch(javax.jms.InvalidDestinationException e)
      {
         // OK

View Full Code Here

Examples of javax.jms.TopicSession.unsubscribe()

    */
   public void removeDurableSubscription() throws Exception
   {


      TopicSession session = topicDurableConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
      session.unsubscribe("test");
   }


   /**
    * The JUnit setup method
    *

View Full Code Here

Examples of javax.jms.TopicSession.unsubscribe()


      sub1.close();
      sub2.close();
      sub3.close();


      session.unsubscribe("sub1");


      topicConnection.stop();
      topicConnection.close();


      disconnect();

View Full Code Here

Examples of javax.jms.TopicSession.unsubscribe()

         getLog().debug("Closing the send session");
         sendSession.close();


         getLog().debug("Removing the subscription");
         subSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
         subSession.unsubscribe("test");


      }
      finally
      {
         getLog().debug("Closing the connection");

View Full Code Here

Examples of javax.jms.TopicSession.unsubscribe()

         assertTrue("Should get Message2", message.getText().equals("Message2"));
         getLog().debug("Closing the subscriber");


         getLog().debug("Removing the subscription");
         subSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
         subSession.unsubscribe("test");
         subSession.close();


      }
      finally
      {

View Full Code Here

Examples of net.timewalker.ffmq3.local.destination.LocalTopic.unsubscribe()

        {
            Iterator topics = topicMap.values().iterator();
            while (topics.hasNext())
            {
                LocalTopic topic = (LocalTopic)topics.next();
                topic.unsubscribe(clientID,subscriptionName);
            }
        }
        
        // Then delete subscription related queues
        String subscriberID = clientID+"-"+subscriptionName;

View Full Code Here

Examples of net.timewalker.ffmq3.local.session.LocalSession.unsubscribe()

    }
    
    private UnsubscribeResponse processUnsubscribe( UnsubscribeQuery query ) throws JMSException
    {
      LocalSession session = lookupSession(query);
      session.unsubscribe(query.getSubscriptionName());


        return new UnsubscribeResponse();
    }
    
    private PingResponse processPing( PingQuery query ) throws JMSException

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.