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()

         
         sess.unsubscribe("sub1");
         
         sess.unsubscribe("sub2");
         
         sess.unsubscribe("sub3");
            
      }
      finally
      {        
         ServerManagement.undeployQueue("ExpiryQueue");

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

         }
         
         cons1.close();
         cons2.close();
         cons3.close();
         sess.unsubscribe("sub1");
         
         counters = (List)
         ServerManagement.getAttribute(ServerManagement.getServerPeerObjectName(), "MessageCounters");
      
         assertNotNull(counters);

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

            
            
            Session session = getSession();
            try
            {
               session.unsubscribe(name);
            }
            catch (Throwable t)
            {
               log.warn("Unsubscribe failed: ", t);
            }

View Full Code Here

Examples of javax.jms.Session.unsubscribe()


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


      session.unsubscribe("sub1");


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


      disconnect();

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

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


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


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

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

         getLog().debug("Closing the subscriber");


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


      }
      finally
      {

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

      try
      {
         Session session = getSession();
         if (trace)
            log.trace("unsubscribe " + session + " name=" + name);
         session.unsubscribe(name);
      }
      finally
      {
         unlock();
      }

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

        // create kipper
        Topic kipper = sess.createTopic("kipper");
        TopicSubscriber subscriber = sess.createDurableSubscriber(kipper, "kipper");


        subscriber.close();
        sess.unsubscribe("kipper");


        //Do something to show connection is active.
        sess.rollback();
        conn.close();
    }

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

        TopicSubscriber subscriber = sess.createDurableSubscriber(kipper, "kipper");


        subscriber.close();
        try
        {
            sess.unsubscribe("kipper");


            //Do something to show connection is active.
            sess.rollback();


            fail("Exception was not thrown");

View Full Code Here

Examples of javax.jms.Session.unsubscribe()

        String topicName = "kipper";
        Topic topic = sess.createTopic(topicName);
        TopicSubscriber subscriber = sess.createDurableSubscriber(topic, topicName);


        subscriber.close();
        sess.unsubscribe(topicName);


        //Do something to show connection is active.
        sess.rollback();
        conn.close();
    }

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.