Package org.hornetq.api.core.client

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

825
826
827
828
829
830
831
832
833
834
835
   protected void doTestF(final ClientSessionFactory sf, final int threadNum) throws Exception
   {
      long start = System.currentTimeMillis();

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


      final int numMessages = 100;

      final int numSessions = 10;
View Full Code Here
840
841
842
843
844
845
846
847
848
849
850
      for (int i = 0; i < numSessions; i++)
      {
         SimpleString subName = new SimpleString(threadNum + "sub" + i);

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

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

         ClientConsumer consumer = sessConsume.createConsumer(subName);
View Full Code Here
852
853
854
855
856
857
858
859
860
861
862
         sessions.add(sessConsume);
      }

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

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

      sendMessages(sessSend, producer, numMessages, threadNum);
View Full Code Here
890
891
892
893
894
895
896
897
898
899
900
   protected void doTestG(final ClientSessionFactory sf, final int threadNum) throws Exception
   {
      long start = System.currentTimeMillis();

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

      final int numMessages = 100;

      final int numSessions = 10;
View Full Code Here
904
905
906
907
908
909
910
911
912
913
914
      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.start();

         sessConsume.createQueue(MultiThreadRandomReattachTestBase.ADDRESS, subName, null, false);
View Full Code Here
919
920
921
922
923
924
925
926
927
928
929
         sessions.add(sessConsume);
      }

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


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

      sendMessages(sessSend, producer, numMessages, threadNum);
View Full Code Here
971
972
973
974
975
976
977
978
979
980
981
   protected void doTestH(final ClientSessionFactory sf, final int threadNum) throws Exception
   {
      long start = System.currentTimeMillis();

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


      final int numMessages = 100;

      final int numSessions = 10;
View Full Code Here
986
987
988
989
990
991
992
993
994
995
996
      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
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
         sessions.add(sessConsume);
      }

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

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

      sendMessages(sessSend, producer, numMessages, threadNum);
View Full Code Here
1053
1054
1055
1056
1057
1058
1059
1060
1061
1062
1063
   }

   protected void doTestI(final ClientSessionFactory sf, final int threadNum) throws Exception
   {
      ClientSession sessCreate = sf.createSession(false, true, true);
      sessCreate.addMetaData("data", RandomUtil.randomString());


      sessCreate.createQueue(MultiThreadRandomReattachTestBase.ADDRESS,
                             new SimpleString(threadNum + MultiThreadRandomReattachTestBase.ADDRESS.toString()),
                             null,
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.