/**
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.openejb.core.stateful;
import junit.framework.TestCase;
import org.apache.openejb.core.ivm.naming.InitContextFactory;
import org.apache.openejb.config.ConfigurationFactory;
import org.apache.openejb.config.EjbModule;
import org.apache.openejb.assembler.classic.Assembler;
import org.apache.openejb.assembler.classic.ProxyFactoryInfo;
import org.apache.openejb.assembler.classic.TransactionServiceInfo;
import org.apache.openejb.assembler.classic.SecurityServiceInfo;
import org.apache.openejb.assembler.classic.StatefulSessionContainerInfo;
import org.apache.openejb.jee.EjbJar;
import org.apache.openejb.jee.StatefulBean;
import javax.naming.InitialContext;
import javax.ejb.CreateException;
import javax.ejb.EJBException;
import javax.ejb.EJBHome;
import javax.ejb.EJBObject;
import javax.ejb.PostActivate;
import javax.ejb.PrePassivate;
import javax.ejb.Init;
import javax.ejb.Remove;
import javax.annotation.PostConstruct;
import java.util.List;
import java.util.Arrays;
import java.util.ArrayList;
import java.rmi.RemoteException;
import java.io.Serializable;
/**
* @version $Rev: 1299871 $ $Date: 2012-03-12 14:16:48 -0700 (Mon, 12 Mar 2012) $
*/
public class Compat3to2Test extends TestCase {
public void test() throws Exception {
System.setProperty(javax.naming.Context.INITIAL_CONTEXT_FACTORY, InitContextFactory.class.getName());
ConfigurationFactory config = new ConfigurationFactory();
Assembler assembler = new Assembler();
assembler.createProxyFactory(config.configureService(ProxyFactoryInfo.class));
assembler.createTransactionManager(config.configureService(TransactionServiceInfo.class));
assembler.createSecurityService(config.configureService(SecurityServiceInfo.class));
// containers
StatefulSessionContainerInfo statefulContainerInfo = config.configureService(StatefulSessionContainerInfo.class);
statefulContainerInfo.properties.setProperty("PoolSize", "0");
statefulContainerInfo.properties.setProperty("BulkPassivate", "1");
statefulContainerInfo.properties.setProperty("Frequency", "0");
assembler.createContainer(statefulContainerInfo);
EjbJar ejbJar = new EjbJar();
StatefulBean bean = ejbJar.addEnterpriseBean(new StatefulBean(TargetBean.class));
bean.setHomeAndRemote(TargetHome.class, Target.class);
assembler.createApplication(config.configureApplication(new EjbModule(getClass().getClassLoader(), getClass().getSimpleName(), "test", ejbJar, null)));
calls.clear();
InitialContext ctx = new InitialContext();
TargetHome home = (TargetHome) ctx.lookup("TargetBeanRemoteHome");
assertNotNull(home);
Target target = home.create("Fuzz");
assertNotNull(target);
String name = target.getName();
assertEquals("Fuzz", name);
target.remove();
assertCalls(Call.values());
}
private void assertCalls(Call... expectedCalls) {
List expected = Arrays.asList(expectedCalls);
assertEquals(join("\n", expected), join("\n", calls));
}
public static List<Call> calls = new ArrayList<Call>();
public static enum Call {
// construction
Constructor, PostConstruct, EjbCreate, EjbPassivate1,
// business method
EjbActivate1, BusinessMethod, EjbPassivate2,
// remove
EjbActivate2, EjbRemove
}
public static class TargetBean implements Serializable {
private int activates = 0;
private int passivates = 0;
private String name;
public TargetBean() {
calls.add(Call.Constructor);
}
@PostConstruct
public void construct() {
calls.add(Call.PostConstruct);
}
@Init
public void beanCreate(String name) throws CreateException {
calls.add(Call.EjbCreate);
this.name = name;
}
public String getName() {
calls.add(Call.BusinessMethod);
return name;
}
@PostActivate
public void beanActivate() throws EJBException, RemoteException {
calls.add((Call) Enum.valueOf(Call.class, "EjbActivate" + (++activates)));
}
@PrePassivate
public void beanPassivate() throws EJBException, RemoteException {
calls.add((Call) Enum.valueOf(Call.class, "EjbPassivate" + (++passivates)));
}
@Remove
public void beanRemove() throws EJBException, RemoteException {
calls.add(Call.EjbRemove);
}
}
public static interface TargetHome extends EJBHome {
Target create(String name) throws RemoteException, CreateException;
}
public static interface Target extends EJBObject {
String getName();
}
private String join(String delimeter, List items) {
StringBuilder sb = new StringBuilder();
for (Object item : items) {
sb.append(item.toString()).append(delimeter);
}
return sb.toString();
}
}