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 org.wso2.carbon.event.client.broker.BrokerClient.unsubscribe()

                ele.setText("Should not receive"+i);
                brokerClient.publish("/bar", ele);
            }
            
            
            brokerClient.unsubscribe(subscribtionId);
            
            Thread.sleep(3000);
//        
//        BrokerClient brokerClient = new BrokerClient("http://127.0.0.1:5555/services/EventBrokerService");
//        SubscriptionDetails[] details = brokerClient.getAllSubscriptions();

View Full Code Here

Examples of org.wso2.carbon.registry.eventing.services.EventingService.unsubscribe()


        SuperTenantCarbonContext.startTenantFlow();
        try {
            SuperTenantCarbonContext currentContext = SuperTenantCarbonContext.getCurrentContext();
            currentContext.setTenantId(tenantId, true);
            return eventingService.unsubscribe(subscriptionId);
        } finally {
            SuperTenantCarbonContext.endTenantFlow();
        }
    }

View Full Code Here

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

            log.fine("unSubscribe arrived ...");
            //UnSubscribeReturnQos[] ret;


            if (oid != null) {
               UnSubscribeKey xmlKey = new UnSubscribeKey(glob, oid);
               /*ret = */xmlBlaster.unSubscribe(xmlKey.toXml(), qos);
            }
            else if (key != null) {
               /*ret = */xmlBlaster.unSubscribe(key, qos);
            }
            else {

View Full Code Here

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

            if (oid != null) {
               UnSubscribeKey xmlKey = new UnSubscribeKey(glob, oid);
               /*ret = */xmlBlaster.unSubscribe(xmlKey.toXml(), qos);
            }
            else if (key != null) {
               /*ret = */xmlBlaster.unSubscribe(key, qos);
            }
            else {
               String str = "Please call servlet with some 'key.oid=...' or 'key=<key ...' when unsubscribing";
               log.severe(str);
               htmlOutput(str, res);

View Full Code Here

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

            if (log.isLoggable(Level.FINE)) log.fine("unSubscribe arrived ...");
            UnSubscribeReturnQos[] ret;


            if (oid != null) {
               UnSubscribeKey xmlKey = new UnSubscribeKey(glob, oid);
               ret = xmlBlaster.unSubscribe(xmlKey.toXml(), qos);
            }
            else if (key != null) {
               ret = xmlBlaster.unSubscribe(key, qos);
            }
            else {

View Full Code Here

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

            if (oid != null) {
               UnSubscribeKey xmlKey = new UnSubscribeKey(glob, oid);
               ret = xmlBlaster.unSubscribe(xmlKey.toXml(), qos);
            }
            else if (key != null) {
               ret = xmlBlaster.unSubscribe(key, qos);
            }
            else {
               String str = "Please call servlet with some 'key.oid=...' or 'key=<key ...' when unsubscribing";
               log.warning(str);
               throw new XmlBlasterException(this.initialGlobal, ErrorCode.USER_CONFIGURATION, ME, str);

View Full Code Here

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

         getEngineGlobal(this.global).getRequestBroker().getAuthenticate(null).removeClientListener(this);
         getEngineGlobal(this.global).getRequestBroker().removeSubscriptionListener(this);
         I_XmlBlasterAccess conn = this.global.getXmlBlasterAccess();
         if (this.sqlTopic != null) {
            UnSubscribeKey key = new UnSubscribeKey(this.global, this.sqlTopic);
            conn.unSubscribe(key, new UnSubscribeQos(this.global));
         }
         conn.disconnect(new DisconnectQos(this.global));
         this.replications.clear();
         this.replSlaveMap.clear();
         this.topicToPrefixMap.clear();

View Full Code Here

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

         catch( InterruptedException i) {} // wait a second to receive update()




         UnSubscribeKey uk = new UnSubscribeKey(glob, subRet.getSubscriptionId());
         UnSubscribeQos uq = new UnSubscribeQos(glob);
         UnSubscribeReturnQos[] urq = con.unSubscribe(uk, uq);
         if (urq.length > 0) log.info("Unsubscribed from topic");


         EraseKey ek = new EraseKey(glob, "HelloWorld3");
         EraseQos eq = new EraseQos(glob);
         EraseReturnQos[] eraseArr = con.erase(ek, eq);

View Full Code Here

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

      if (con == null) {
         if (log.isLoggable(Level.FINE)) log.fine("forwardUnSubscribe - Nothing to forward");
         return null;
      }


      return con.unSubscribe(new UnSubscribeKey(this.glob, xmlKey), new UnSubscribeQos(this.glob, unSubscribeQos.getData()));
   }


   /**
    * @return null if no forwarding is done, if we are the master of this message ourself<br />
    *         msgUnit.length==0 if message is

View Full Code Here

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

         catch( InterruptedException i) {} // wait a second to receive update()




         UnSubscribeKey uk = new UnSubscribeKey(glob, subRet.getSubscriptionId());
         UnSubscribeQos uq = new UnSubscribeQos(glob);
         con.unSubscribe(uk, uq);


         EraseKey ek = new EraseKey(glob, "HelloWorldMime");
         EraseQos eq = new EraseQos(glob);
         EraseReturnQos[] eraseArr = con.erase(ek, eq);

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.