Package com.microsoft.windowsazure.services.servicebus.models

Examples of com.microsoft.windowsazure.services.servicebus.models.BrokeredMessage

356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
    @Test
    public void renewQueueMessageLockWorks() throws Exception {
        // Arrange
        String queueName = "TestRenewSubscriptionLockMessageWorks";
        service.createQueue(new QueueInfo(queueName));
        service.sendQueueMessage(queueName, new BrokeredMessage("Hello Again"));

        // Act
        BrokeredMessage message = service.receiveQueueMessage(queueName,
                PEEK_LOCK_5_SECONDS).getValue();
        service.renewQueueLock(queueName, message.getMessageId(),
                message.getLockToken());

        // Assert
        assertNotNull(message);
    }
View Full Code Here
396
397
398
399
400
401
402
403
404
405
406
                new QueueInfo(sourceQueueName)
                        .setForwardTo(destinationQueueInfo.getUri().toString()))
                .getValue();

        // Act
        service.sendQueueMessage(sourceQueueName, new BrokeredMessage(
                "Hello source queue!"));
        ReceiveQueueMessageResult receiveQueueMessageResult = service
                .receiveQueueMessage(destinationQueueName,
                        RECEIVE_AND_DELETE_5_SECONDS);
View Full Code Here
421
422
423
424
425
426
427
428
429
430
431
        service.createQueue(sourceQueueInfo).getValue();
        service.updateQueue(sourceQueueInfo.setForwardTo(destinationQueueInfo
                .getUri().toString()));

        // Act
        service.sendQueueMessage(sourceQueueName, new BrokeredMessage(
                "Hello source queue!"));
        ReceiveQueueMessageResult receiveQueueMessageResult = service
                .receiveQueueMessage(destinationQueueName,
                        RECEIVE_AND_DELETE_5_SECONDS);
View Full Code Here
447
448
449
450
451
452
453
454
455
456
457
        service.createSubscription(sourceTopicName, new SubscriptionInfo(
                sourceSubscriptionName).setForwardTo(destinationQueueInfo
                .getUri().toString()));

        // Act
        service.sendTopicMessage(sourceTopicName, new BrokeredMessage(
                "Hello source queue!"));
        ReceiveQueueMessageResult receiveQueueMessageResult = service
                .receiveQueueMessage(destinationQueueName,
                        RECEIVE_AND_DELETE_5_SECONDS);
View Full Code Here
474
475
476
477
478
479
480
481
482
483
484
                sourceTopicName, new SubscriptionInfo(sourceSubscriptionName))
                .getValue();
        service.updateSubscription(sourceTopicName, sourceSubscriptionInfo
                .setForwardTo(destinationQueueInfo.getUri().toString()));
        // Act
        service.sendTopicMessage(sourceTopicName, new BrokeredMessage(
                "Hello source queue!"));
        ReceiveQueueMessageResult receiveQueueMessageResult = service
                .receiveQueueMessage(destinationQueueName,
                        RECEIVE_AND_DELETE_5_SECONDS);
View Full Code Here
499
500
501
502
503
504
505
506
507
508
509
                new QueueInfo(sourceQueueName)
                        .setForwardTo(destinationTopicInfo.getUri().toString()))
                .getValue();

        // Act
        service.sendQueueMessage(sourceQueueName, new BrokeredMessage(
                "Hello source queue!"));
        ReceiveSubscriptionMessageResult receiveSubscriptionMessageResult = service
                .receiveSubscriptionMessage(destinationTopicName,
                        destinationSubscriptionName,
                        RECEIVE_AND_DELETE_5_SECONDS);
View Full Code Here
527
528
529
530
531
532
533
534
535
536
537
        service.createQueue(sourceQueueInfo).getValue();
        service.updateQueue(sourceQueueInfo.setForwardTo(destinationTopicInfo
                .getUri().toString()));

        // Act
        service.sendQueueMessage(sourceQueueName, new BrokeredMessage(
                "Hello source queue!"));
        ReceiveSubscriptionMessageResult receiveSubscriptionMessageResult = service
                .receiveSubscriptionMessage(destinationTopicName,
                        destinationSubscriptionName,
                        RECEIVE_AND_DELETE_5_SECONDS);
View Full Code Here
558
559
560
561
562
563
564
565
566
567
568
        service.createSubscription(sourceTopicName, new SubscriptionInfo(
                sourceSubscriptionName).setForwardTo(destinationTopicInfo
                .getUri().toString()));

        // Act
        service.sendTopicMessage(sourceTopicName, new BrokeredMessage(
                "Hello source queue!"));
        ReceiveSubscriptionMessageResult receiveSubscriptionMessageResult = service
                .receiveSubscriptionMessage(destinationTopicName,
                        destinationSubscriptionName,
                        RECEIVE_AND_DELETE_5_SECONDS);
View Full Code Here
592
593
594
595
596
597
598
599
600
601
602
        service.updateSubscription(sourceTopicName, sourceSubscriptionInfo
                .setForwardTo(destinationTopicInfo.getUri().toString()));
        Thread.sleep(1000);

        // Act
        service.sendTopicMessage(sourceTopicName, new BrokeredMessage(
                "Hello source queue!"));
        ReceiveSubscriptionMessageResult receiveSubscriptionMessageResult = service
                .receiveSubscriptionMessage(destinationTopicName,
                        destinationSubscriptionName,
                        RECEIVE_AND_DELETE_5_SECONDS);
View Full Code Here
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
    @Test
    public void peekLockMessageWorks() throws Exception {
        // Arrange
        String queueName = "TestPeekLockMessageWorks";
        service.createQueue(new QueueInfo(queueName));
        service.sendQueueMessage(queueName, new BrokeredMessage("Hello Again"));

        // Act
        BrokeredMessage message = service.receiveQueueMessage(queueName,
                PEEK_LOCK_5_SECONDS).getValue();

        // Assert
        byte[] data = new byte[100];
        int size = message.getBody().read(data);
        assertEquals(11, size);
        assertEquals("Hello Again", new String(data, 0, size));
    }
View Full Code Here
TOP

Related Classes of com.microsoft.windowsazure.services.servicebus.models.BrokeredMessage

  • com.microsoft.windowsazure.services.servicebus.implementation.BrokerProperties
  • com.microsoft.windowsazure.services.servicebus.implementation.ServiceBusRestProxy
  • com.microsoft.windowsazure.services.servicebus.ServiceBusIntegrationTest
  • java.io.ByteArrayInputStream
    • Copyright © 2018 www.massapicom. 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.