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);