KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > activemq > broker > store > JPARecoveryBrokerTest


1 /**
2  *
3  * Licensed to the Apache Software Foundation (ASF) under one or more
4  * contributor license agreements. See the NOTICE file distributed with
5  * this work for additional information regarding copyright ownership.
6  * The ASF licenses this file to You under the Apache License, Version 2.0
7  * (the "License"); you may not use this file except in compliance with
8  * the License. You may obtain a copy of the License at
9  *
10  * http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing, software
13  * distributed under the License is distributed on an "AS IS" BASIS,
14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  * See the License for the specific language governing permissions and
16  * limitations under the License.
17  */
18 package org.apache.activemq.broker.store;
19
20 import java.util.Properties JavaDoc;
21
22 import junit.framework.Test;
23
24 import org.apache.activemq.broker.BrokerService;
25 import org.apache.activemq.broker.RecoveryBrokerTest;
26 import org.apache.activemq.store.jpa.JPAPersistenceAdapter;
27
28 /**
29  * Used to verify that recovery works correctly against
30  *
31  * @version $Revision$
32  */
33 public class JPARecoveryBrokerTest extends RecoveryBrokerTest {
34
35     protected BrokerService createBroker() throws Exception JavaDoc {
36         BrokerService service = new BrokerService();
37         service.setDeleteAllMessagesOnStartup(true);
38         JPAPersistenceAdapter pa = new JPAPersistenceAdapter();
39         Properties JavaDoc props = new Properties JavaDoc();
40         props.setProperty("openjpa.ConnectionDriverName", "org.apache.derby.jdbc.EmbeddedDriver");
41         props.setProperty("openjpa.ConnectionURL", "jdbc:derby:activemq-data/derby;create=true");
42         props.setProperty("openjpa.jdbc.SynchronizeMappings", "buildSchema");
43         props.setProperty("openjpa.Log", "DefaultLevel=WARN,SQL=TRACE");
44         pa.setEntityManagerProperties(props);
45         service.setPersistenceAdapter(pa);
46         return service;
47         
48     }
49     
50     protected BrokerService createRestartedBroker() throws Exception JavaDoc {
51         BrokerService service = new BrokerService();
52         JPAPersistenceAdapter pa = new JPAPersistenceAdapter();
53         Properties JavaDoc props = new Properties JavaDoc();
54         props.setProperty("openjpa.ConnectionDriverName", "org.apache.derby.jdbc.EmbeddedDriver");
55         props.setProperty("openjpa.ConnectionURL", "jdbc:derby:activemq-data/derby;create=true");
56         props.setProperty("openjpa.jdbc.SynchronizeMappings", "buildSchema");
57         props.setProperty("openjpa.Log", "DefaultLevel=WARN,SQL=TRACE");
58         pa.setEntityManagerProperties(props);
59         service.setPersistenceAdapter(pa);
60         return service;
61     }
62     
63     public static Test suite() {
64         return suite(JPARecoveryBrokerTest.class);
65     }
66     
67     public static void main(String JavaDoc[] args) {
68         junit.textui.TestRunner.run(suite());
69     }
70
71 }
72
Popular Tags