Package org.apache.activemq.broker

Examples of org.apache.activemq.broker.BrokerService.stop()

310
311
312
313
314
315
316
317
318
319
320
                       
            LOG.info("Success");

        } finally {
            if (broker != null) {
                broker.stop();
            }
        }
    }

    /*
 
View Full Code Here
338
339
340
341
342
343
344
345
346
347
348
            assertTrue("Should have created a journal directory at " + journalFile.getAbsolutePath(), journalFile.exists());

            LOG.info("Success");
        } finally {
            if (broker != null) {
                broker.stop();
            }
        }
    }

    /*
 
View Full Code Here
371
372
373
374
375
376
377
378
379
380
381
            assertTrue("Should have not created a journal directory at " + journalFile.getAbsolutePath(), !journalFile.exists());

            LOG.info("Success");
        } finally {
            if (broker != null) {
                broker.stop();
            }
        }

    }
View Full Code Here
385
386
387
388
389
390
391
392
393
394
395
        broker = createBroker(new FileSystemResource(CONF_ROOT + "memory-example.xml"));
        try {
            assertEquals("Broker Config Error (brokerName)", "brokerMemoryConfigTest", broker.getBrokerName());
        } finally {
            if (broker != null) {
                broker.stop();
            }
        }

        broker = createBroker("org/apache/activemq/config/config.xml");
        try {
View Full Code Here
394
395
396
397
398
399
400
401
402
403
404
        broker = createBroker("org/apache/activemq/config/config.xml");
        try {
            assertEquals("Broker Config Error (brokerName)", "brokerXmlConfigHelper", broker.getBrokerName());
        } finally {
            if (broker != null) {
                broker.stop();
            }
        }
    }

    /*
 
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
                consumer.close();
                session.close();
                connection.close();

                broker.stop();
            }
        });
    }

    public void runTest(Task task) throws Exception {
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
            } catch (final Throwable t) {
                t.printStackTrace();
            }
            try {
                if (brokerService2 != null) {
                    brokerService2.stop();
                }
            } catch (final Throwable t) {
                t.printStackTrace();
            }
        }
View Full Code Here
79
80
81
82
83
84
85
86
                in.close();
            }
        }

        connection.close();
        broker.stop();
    }
}
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
        for (int i =0; i < 1000; i++) {
            Message msg = session.createTextMessage("test message:"+i);
            producer.send(msg);
        }
        connection.stop();
        broker.stop();
    }
   
    public void testVersionConversion() throws Exception{
        File testDir = new File("target/activemq-data/kahadb/versionDB");
        IOHelper.deleteFile(testDir);
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
        for (int i = 0; i < 1000; i++) {
            TextMessage msg  = (TextMessage) topicConsumer.receive(10000);
            //System.err.println(msg.getText());
            assertNotNull(msg);
        }
        broker.stop();
       
    }

   
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.