Package org.hornetq.api.core.client

Examples of org.hornetq.api.core.client.ClientSession.addMetaData()

504
505
506
507
508
509
510
511
512
513
514
   protected void doTestC(final ClientSessionFactory sf, final int threadNum) throws Exception
   {
      long start = System.currentTimeMillis();

      ClientSession s = sf.createSession(false, false, false);
      s.addMetaData("some-data", RandomUtil.randomString());


      final int numMessages = 100;

      final int numSessions = 10;
View Full Code Here
532
533
534
535
536
537
538
539
540
541
542
         sessions.add(sessConsume);
      }

      ClientSession sessSend = sf.createSession(false, false, false);
      sessSend.addMetaData("some-data", RandomUtil.randomString());


      ClientProducer producer = sessSend.createProducer(MultiThreadRandomReattachTestBase.ADDRESS);

      sendMessages(sessSend, producer, numMessages, threadNum);
View Full Code Here
617
618
619
620
621
622
623
624
625
626
627
   protected void doTestD(final ClientSessionFactory sf, final int threadNum) throws Exception
   {
      long start = System.currentTimeMillis();

      ClientSession s = sf.createSession(false, false, false);
      s.addMetaData("some-data", RandomUtil.randomString());


      final int numMessages = 100;

      final int numSessions = 10;
View Full Code Here
632
633
634
635
636
637
638
639
640
641
642
      for (int i = 0; i < numSessions; i++)
      {
         SimpleString subName = new SimpleString(threadNum + " sub" + i);

         ClientSession sessConsume = sf.createSession(false, false, false);
         sessConsume.addMetaData("data", RandomUtil.randomString());

         sessConsume.createQueue(MultiThreadRandomReattachTestBase.ADDRESS, subName, null, false);

         ClientConsumer consumer = sessConsume.createConsumer(subName);
View Full Code Here
644
645
646
647
648
649
650
651
652
653
654
         sessions.add(sessConsume);
      }

      ClientSession sessSend = sf.createSession(false, false, false);
      sessSend.addMetaData("some-data", RandomUtil.randomString());


      ClientProducer producer = sessSend.createProducer(MultiThreadRandomReattachTestBase.ADDRESS);

      sendMessages(sessSend, producer, numMessages, threadNum);
View Full Code Here
762
763
764
765
766
767
768
769
770
771
772
   protected void doTestE(final ClientSessionFactory sf, final int threadNum) throws Exception
   {
      long start = System.currentTimeMillis();

      ClientSession s = sf.createSession(false, false, false);
      s.addMetaData("some-data", RandomUtil.randomString());


      final int numMessages = 100;

      final int numSessions = 10;
View Full Code Here
777
778
779
780
781
782
783
784
785
786
787
      for (int i = 0; i < numSessions; i++)
      {
         SimpleString subName = new SimpleString(threadNum + "sub" + i);

         ClientSession sessConsume = sf.createSession(false, true, true);
         sessConsume.addMetaData("some-data", RandomUtil.randomString());


         sessConsume.start();

         sessConsume.createQueue(MultiThreadRandomReattachTestBase.ADDRESS, subName, null, false);
View Full Code Here
578
579
580
581
582
583
584
585
586
587
588
     
      server.getAddressSettingsRepository().addMatch("TestAD", setting);
     
      ClientSessionFactory consumerCF = locator.createSessionFactory();
      ClientSession consumerSession = consumerCF.createSession(true, true);
      consumerSession.addMetaData("consumer", "consumer");
      consumerSession.createTemporaryQueue("TestAD", "Q1");
      ClientConsumer consumer = consumerSession.createConsumer("Q1");
      consumerSession.start();
     
      final ClientProducerImpl prod = (ClientProducerImpl)session.createProducer("TestAD");
View Full Code Here
492
493
494
495
496
497
498
499
500
501
502
                                   ra.getTransactionBatchSize(),
                                   isDeliveryTransacted,
                                   spec.isUseLocalTx(),
                                   spec.getTransactionTimeout());

         result.addMetaData("resource-adapter", "inbound");
         result.addMetaData("jms-session", "");
         String clientID = ra.getClientID() == null?spec.getClientID():ra.getClientID();
         if (clientID != null)
         {
            result.addMetaData("jms-client-id", clientID);
View Full Code Here
493
494
495
496
497
498
499
500
501
502
503
                                   isDeliveryTransacted,
                                   spec.isUseLocalTx(),
                                   spec.getTransactionTimeout());

         result.addMetaData("resource-adapter", "inbound");
         result.addMetaData("jms-session", "");
         String clientID = ra.getClientID() == null?spec.getClientID():ra.getClientID();
         if (clientID != null)
         {
            result.addMetaData("jms-client-id", clientID);
         }
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.