Package org.hornetq.api.core.client

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

1090
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
   }

   protected void doTestJ(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
1099
1100
1101
1102
1103
1104
1105
1106
1107
1108
1109
                             new SimpleString(threadNum + MultiThreadRandomReattachTestBase.ADDRESS.toString()),
                             null,
                             false);

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

      sess.start();

      ClientConsumer consumer = sess.createConsumer(new SimpleString(threadNum + MultiThreadRandomReattachTestBase.ADDRESS.toString()));
View Full Code Here
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
1136
   }

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

      s.createQueue(MultiThreadRandomReattachTestBase.ADDRESS,
                    new SimpleString(threadNum + MultiThreadRandomReattachTestBase.ADDRESS.toString()),
                    null,
                    false);
View Full Code Here
1158
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
      for (int i = 0; i < numSessions; i++)
      {
         ClientSession session = sf.createSession(false, false, false);
        
         session.addMetaData("data", RandomUtil.randomString());

         session.close();
      }
   }
View Full Code Here
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
                             new SimpleString(threadNum + MultiThreadRandomReattachTestBase.ADDRESS.toString()),
                             null,
                             false);

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

      sess.stop();

      sess.start();
View Full Code Here
264
265
266
267
268
269
270
271
272
273
274
   protected abstract boolean checkSize(ClientMessage message);

   protected ClientSession createAutoCommitSession(final ClientSessionFactory sf) throws Exception
   {
      ClientSession session = sf.createSession(false, true, true);
      session.addMetaData("someData", RandomUtil.randomString());
      session.addMetaData("someData2", RandomUtil.randomString());
      return session;
   }

   protected ClientSession createTransactionalSession(final ClientSessionFactory sf) throws Exception
View Full Code Here
265
266
267
268
269
270
271
272
273
274
275
   protected ClientSession createAutoCommitSession(final ClientSessionFactory sf) throws Exception
   {
      ClientSession session = sf.createSession(false, true, true);
      session.addMetaData("someData", RandomUtil.randomString());
      session.addMetaData("someData2", RandomUtil.randomString());
      return session;
   }

   protected ClientSession createTransactionalSession(final ClientSessionFactory sf) throws Exception
   {
View Full Code Here
272
273
274
275
276
277
278
279
280
281
282
   }

   protected ClientSession createTransactionalSession(final ClientSessionFactory sf) throws Exception
   {
      ClientSession session = sf.createSession(false, false, false);
      session.addMetaData("someData", RandomUtil.randomString());
      session.addMetaData("someData2", RandomUtil.randomString());
     
      return session;
   }
View Full Code Here
273
274
275
276
277
278
279
280
281
282
283
   protected ClientSession createTransactionalSession(final ClientSessionFactory sf) throws Exception
   {
      ClientSession session = sf.createSession(false, false, false);
      session.addMetaData("someData", RandomUtil.randomString());
      session.addMetaData("someData2", RandomUtil.randomString());
     
      return session;
   }

   protected void doTestA(final ClientSessionFactory sf, final int threadNum, final ClientSession session2) throws Exception
View Full Code Here
438
439
440
441
442
443
444
445
446
447
448
         sessions.add(sessConsume);
      }

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

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

      sendMessages(sessSend, producer, numMessages, threadNum);
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.