29292930293129322933293429352936293729382939
config, PagingTest.PAGE_SIZE, PagingTest.PAGE_MAX, new HashMap<String, AddressSettings>()); server.start(); locator = createInVMNonHALocator(); sf = locator.createSessionFactory();
29632964296529662967296829692970297129722973
30243025302630273028302930303031303230333034
settings.put(PagingTest.ADDRESS.toString(), set); HornetQServer server = createServer(true, config, 1024, 10 * 1024, settings); server.start(); final int numberOfMessages = 1000; try {
31663167316831693170317131723173317431753176
settings.put(PagingTest.ADDRESS.toString(), set); HornetQServer server = createServer(true, config, 1024, 1024 * 1024, settings); server.start(); final int numberOfMessages = 30000; try {
32643265326632673268326932703271327232733274
config, PagingTest.PAGE_SIZE, PagingTest.PAGE_MAX, new HashMap<String, AddressSettings>()); server.start(); try { locator.setBlockOnNonDurableSend(true);
33093310331133123313331433153316331733183319
server = createServer(true, config, PagingTest.PAGE_SIZE, PagingTest.PAGE_MAX, new HashMap<String, AddressSettings>()); server.start(); sf = locator.createSessionFactory(); session = sf.createSession(null, null, false, true, true, false, 0);
33713372337333743375337633773378337933803381
config, PagingTest.PAGE_SIZE, PagingTest.PAGE_MAX, new HashMap<String, AddressSettings>()); server.start(); try { server.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true, false);
139140141142143144145146147148149
config, PagingTest.PAGE_SIZE, PagingTest.PAGE_MAX, new HashMap<String, AddressSettings>()); server.start(); final int messageSize = 1024; final int numberOfMessages = 5000;
206207208209210211212213214215216
server = createServer(true, config, PagingTest.PAGE_SIZE, PagingTest.PAGE_MAX, new HashMap<String, AddressSettings>()); server.start(); locator = createInVMNonHALocator(); sf = locator.createSessionFactory(); Queue queue = server.locateQueue(ADDRESS);
262263264265266267268269270271272
server = createServer(true, config, PagingTest.PAGE_SIZE, PagingTest.PAGE_MAX, new HashMap<String, AddressSettings>()); server.start(); waitForServer(server); queue = server.locateQueue(ADDRESS);