Examples of ClientNotSubscribedException

Examples of org.apache.hadoop.hdfs.notifier.ClientNotSubscribedException

591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
        NotifierUtils.asString(event));
   
    synchronized (subscriptions) {
      clientsForEvent = subscriptions.get(eventKey);
      if (clientsForEvent == null) {
        throw new ClientNotSubscribedException();
      }

      synchronized (clientsForEvent) {
        if (!clientsForEvent.contains(clientId)) {
          throw new ClientNotSubscribedException();
        }
        clientsForEvent.remove(clientId);
        clientData.subscriptions.remove(clientsForEvent);
       
        if (clientsForEvent.size() == 0) {
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

291
292
293
294
295
296
297
298
299
300
301
            logger.debug("Calling consume for topic: " + topic.toStringUtf8() + ", subscriberId: "
                         + subscriberId.toStringUtf8() + ", messageSeqId: " + messageSeqId);
        TopicSubscriber topicSubscriber = new TopicSubscriber(topic, subscriberId);
        // Check that this topic subscription on the client side exists.
        if (!topicSubscriber2Channel.containsKey(topicSubscriber)) {
            throw new ClientNotSubscribedException(
                "Cannot send consume message since client is not subscribed to topic: " + topic.toStringUtf8()
                + ", subscriberId: " + subscriberId.toStringUtf8());
        }
        PubSubData pubSubData = new PubSubData(topic, null, subscriberId, OperationType.CONSUME, null, null, null);
        // Send the consume message to the server using the same subscribe
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

451
452
453
454
455
456
457
458
459
460
461
        // Channel created for the TopicSubscriber once the server has sent
        // an ack response to the initial subscribe request.
        if (!topicSubscriber2Channel.containsKey(topicSubscriber)) {
            logger.error("Client is not yet subscribed to topic: " + topic.toStringUtf8() + ", subscriberId: "
                         + subscriberId.toStringUtf8());
            throw new ClientNotSubscribedException("Client is not yet subscribed to topic: " + topic.toStringUtf8()
                                                   + ", subscriberId: " + subscriberId.toStringUtf8());
        }

        // Register the MessageHandler with the subscribe Channel's
        // Response Handler.
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

488
489
490
491
492
493
494
495
496
497
498
        // Channel created for the TopicSubscriber once the server has sent
        // an ack response to the initial subscribe request.
        if (!topicSubscriber2Channel.containsKey(topicSubscriber)) {
            logger.error("Client is not yet subscribed to topic: " + topic.toStringUtf8() + ", subscriberId: "
                         + subscriberId.toStringUtf8());
            throw new ClientNotSubscribedException("Client is not yet subscribed to topic: " + topic.toStringUtf8()
                                                   + ", subscriberId: " + subscriberId.toStringUtf8());
        }

        // Unregister the MessageHandler for the subscribe Channel's
        // Response Handler.
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

54
55
56
57
58
59
60
61
62
63
64
            pubSubData.callback.operationFinished(pubSubData.context, null);
            break;
        case CLIENT_NOT_SUBSCRIBED:
            // For Unsubscribe requests, the server says that the client was
            // never subscribed to the topic.
            pubSubData.callback.operationFailed(pubSubData.context, new ClientNotSubscribedException(
                                                    "Client was never subscribed to topic: " + pubSubData.topic.toStringUtf8() + ", subscriberId: "
                                                    + pubSubData.subscriberId.toStringUtf8()));
            break;
        case SERVICE_DOWN:
            // Response was service down failure so just invoke the callback's
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

329
330
331
332
333
334
335
336
337
338
339
            logger.debug("Calling consume for topic: " + topic.toStringUtf8() + ", subscriberId: "
                         + subscriberId.toStringUtf8() + ", messageSeqId: " + messageSeqId);
        TopicSubscriber topicSubscriber = new TopicSubscriber(topic, subscriberId);
        // Check that this topic subscription on the client side exists.
        if (!topicSubscriber2Channel.containsKey(topicSubscriber)) {
            throw new ClientNotSubscribedException(
                "Cannot send consume message since client is not subscribed to topic: " + topic.toStringUtf8()
                + ", subscriberId: " + subscriberId.toStringUtf8());
        }
        PubSubData pubSubData = new PubSubData(topic, null, subscriberId, OperationType.CONSUME, null, null, null);
        // Send the consume message to the server using the same subscribe
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

506
507
508
509
510
511
512
513
514
515
516
        // Channel created for the TopicSubscriber once the server has sent
        // an ack response to the initial subscribe request.
        if (!topicSubscriber2Channel.containsKey(topicSubscriber)) {
            logger.error("Client is not yet subscribed to topic: " + topic.toStringUtf8() + ", subscriberId: "
                         + subscriberId.toStringUtf8());
            throw new ClientNotSubscribedException("Client is not yet subscribed to topic: " + topic.toStringUtf8()
                                                   + ", subscriberId: " + subscriberId.toStringUtf8());
        }

        // Register the MessageHandler with the subscribe Channel's
        // Response Handler.
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

562
563
564
565
566
567
568
569
570
571
572
        // Channel created for the TopicSubscriber once the server has sent
        // an ack response to the initial subscribe request.
        if (!topicSubscriber2Channel.containsKey(topicSubscriber)) {
            logger.error("Client is not yet subscribed to topic: " + topic.toStringUtf8() + ", subscriberId: "
                         + subscriberId.toStringUtf8());
            throw new ClientNotSubscribedException("Client is not yet subscribed to topic: " + topic.toStringUtf8()
                                                   + ", subscriberId: " + subscriberId.toStringUtf8());
        }

        // Unregister the MessageHandler for the subscribe Channel's
        // Response Handler.
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

315
316
317
318
319
320
321
322
323
324
325
        SubscribeResponseHandler subscribeResponseHandler =
            channelManager.getSubscribeResponseHandler(topicSubscriber);
        // Check that this topic subscription on the client side exists.
        if (null == subscribeResponseHandler ||
            !subscribeResponseHandler.hasSubscription(topicSubscriber)) {
            throw new ClientNotSubscribedException(
                "Cannot send consume message since client is not subscribed to topic: "
                + topic.toStringUtf8() + ", subscriberId: " + subscriberId.toStringUtf8());
        }
        // Send the consume message to the server using the same subscribe
        // channel that the topic subscription uses.
View Full Code Here

Examples of org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

52
53
54
55
56
57
58
59
60
61
62
            pubSubData.getCallback().operationFinished(pubSubData.context, null);
            break;
        case CLIENT_NOT_SUBSCRIBED:
            // For closesubscription requests, the server says that the client was
            // never subscribed to the topic.
            pubSubData.getCallback().operationFailed(pubSubData.context, new ClientNotSubscribedException(
                                                    "Client was never subscribed to topic: " +
                                                        pubSubData.topic.toStringUtf8() + ", subscriberId: " +
                                                        pubSubData.subscriberId.toStringUtf8()));
            break;
        case SERVICE_DOWN:
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.