Examples of org.apache.hedwig.client.api.Subscriber.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


        sendXExpectLastY(pub, sub, topic, subidUnbounded, 10000, 10000);
        sub.unsubscribe(topic, subidUnbounded);


        sendXExpectLastY(pub, sub, topic, subid20, 1000, 20);
        sub.unsubscribe(topic, subid20);


        sendXExpectLastY(pub, sub, topic, subid5, 1000, 5);
        sub.unsubscribe(topic, subid5);


        client.close();


        sendXExpectLastY(pub, sub, topic, subid20, 1000, 20);
        sub.unsubscribe(topic, subid20);


        sendXExpectLastY(pub, sub, topic, subid5, 1000, 5);
        sub.unsubscribe(topic, subid5);


        client.close();
    }


    @Test(timeout=60000)

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.