<<< the source code and configuration only for stateful EJB >>>
========================= TestHAEjbStatefulBean.java
================================================
package it.ibm.com.it42021.test.ejb;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.rmi.RemoteException;
import java.util.Random;
import javax.ejb.EJBException;
import javax.ejb.EJBHome;
import javax.ejb.EJBObject;
import javax.ejb.Handle;
import javax.ejb.RemoveException;
import javax.ejb.SessionBean;
import javax.ejb.SessionContext;
/**
* @author ....
*/
public class TestHAEjbStatefulBean implements SessionBean, TestHAEjbStatefulRemote {
public SessionContext ctx = null;
public String beanName = null;
public int maxItems = 0;
public int nextItem = 0;
public TestHAEjbStatefulBean() {
super();
System.out.println("CTOR: TestHAEjbStatefulBean");
}
public void ejbActivate() throws EJBException, RemoteException {
System.out.println("ejbActivate");
}
public void ejbPassivate() throws EJBException, RemoteException {
System.out.println("ejbPassivate");
}
public void ejbRemove() throws EJBException, RemoteException {
System.out.println("ejbRemove: "+beanName);
}
public void setSessionContext(SessionContext ctx) throws EJBException,
RemoteException {
this.ctx = ctx;
System.out.println("setSessionContext");
}
public EJBHome getEJBHome() throws RemoteException {
EJBHome home = null;
if ( ctx != null ) {
home = ctx.getEJBHome();
}
System.out.println("getEJBHome: "+home);
return home;
}
public Handle getHandle() throws RemoteException {
Handle handle = null;
if ( ctx != null ) {
EJBObject object = ctx.getEJBObject();
if ( object != null ) {
handle = object.getHandle();
}
}
System.out.println("getHandle: "+handle);
return handle;
}
public Object getPrimaryKey() throws RemoteException {
Object key = null;
if ( ctx != null ) {
EJBObject object = ctx.getEJBObject();
if ( object != null ) {
key = object.getPrimaryKey();
}
}
System.out.println("getPrimaryKey: "+key);
return key;
}
public boolean isIdentical(EJBObject obj) throws RemoteException {
System.out.println("isIdentical: "+obj);
return false;
}
public void remove() throws RemoteException, RemoveException {
System.out.println("remove: "+beanName);
}
public void ejbCreate(String beanName) {
this.beanName = beanName;
maxItems = new Random().nextInt( 3 ) + 1;
nextItem = maxItems;
System.out.println("ejbCreate: bean ["+ beanName + "] with ["
+maxItems+"] items to consume.");
}
public String whoAreYou(String requester) throws RemoteException {
String serverName = null;
String answer = null;
try {
serverName = InetAddress.getLocalHost().getHostName();
} catch (UnknownHostException e) {
try {
serverName =
InetAddress.getLocalHost().getHostAddress();
} catch (UnknownHostException e1) {
serverName = "<unknown host>";
}
}
answer = "[from requester="+requester+"] bean ["+beanName+"] from
server ["+serverName+"]";
System.out.println("whoAreYou: "+beanName+", requester: "+requester);
return answer;
}
public int getMaxItems() throws RemoteException {
System.out.println("getMaxItems: "+beanName+", maxItems: "+maxItems);
return maxItems;
}
public int getNextItem() throws RemoteException {
if ( nextItem < 0 ) {
throw new RemoteException("No more items.");
}
System.out.println("getNextItem: "+beanName+", nextItem: "+nextItem);
return nextItem--;
}
// JBoss 3.2.x
public boolean isModified() {
System.out.println("isModified: false");
return false;
}
}
======================== TestHAEjbStatefulHomeRemote
=====================================================
package it.ibm.com.it42021.test.ejb;
import java.rmi.RemoteException;
import javax.ejb.CreateException;
import javax.ejb.EJBHome;
/**
* @author ...
*/
public interface TestHAEjbStatefulHomeRemote extends EJBHome {
public TestHAEjbStatefulRemote create(String beanName) throws RemoteException,
CreateException;
}
======================== TestHAEjbStatefulRemote
=====================================================
package it.ibm.com.it42021.test.ejb;
import java.rmi.RemoteException;
import javax.ejb.EJBObject;
/**
* @author ...
*/
public interface TestHAEjbStatefulRemote extends EJBObject {
public String whoAreYou(String requester) throws RemoteException;
public int getMaxItems() throws RemoteException;
public int getNextItem() throws RemoteException;
}
============================= ServletTestHAJBossEjbStateful
==========================================
package it.ibm.com.it42021.test.web;
import it.ibm.com.it42021.test.ejb.TestHAEjbStatefulHomeRemote;
import it.ibm.com.it42021.test.ejb.TestHAEjbStatefulRemote;
import it.ibm.com.it42021.test.ejb.TestHAEjbStatelessHomeRemote;
import java.io.IOException;
import java.rmi.RemoteException;
import java.util.Properties;
import javax.ejb.CreateException;
import javax.ejb.RemoveException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* @author ...
*/
public class ServletTestHAJBossEjbStateful extends HttpServlet {
private static final String _paramNameProviderUrl = "providerUrl";
private static final String _paramNameResultJsp = "resultJsp";
private static final String _defaultJBossHAJNDIServer = "localhost:1100";
private static final String _defaultJBossNCtxFactory =
"org.jnp.interfaces.NamingContextFactory";
private static final String _ejbJndiName = "ejb/TestHAEjbStateful";
private static final String _requesterName = "requesterName";
private static final String _beanName = "beanName";
private static final String _loops = "loops";
private static final String _answerBean = "answerBean";
private static String _resultJsp = "result.jsp";
private InitialContext ctx = null;
private TestHAEjbStatefulHomeRemote home = null;
private TestHAEjbStatefulRemote bean = null;
public ServletTestHAJBossEjbStateful() {
super();
}
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
execute(request, response);
}
protected void doPost(HttpServletRequest request, HttpServletResponse
response) throws ServletException, IOException {
execute(request, response);
}
public void destroy() {
super.destroy();
if (ctx != null) {
try {
ctx.close();
} catch (NamingException e) {
}
}
}
public void init(ServletConfig config) throws ServletException {
super.init(config);
String providerUrl = null;
String param = null;
param = config.getInitParameter(_paramNameProviderUrl);
if (param != null) {
providerUrl = param;
} else {
// default HA-JNDI for JBoss
providerUrl = _defaultJBossHAJNDIServer;
}
param = config.getInitParameter(_paramNameResultJsp);
if (param != null) {
_resultJsp = param;
}
Properties jndiProps = new Properties();
jndiProps.put(Context.PROVIDER_URL, providerUrl);
jndiProps.put(Context.INITIAL_CONTEXT_FACTORY,
_defaultJBossNCtxFactory);
System.out.println("Using: " + Context.PROVIDER_URL+" = "+providerUrl);
System.out.println("Using: " + Context.INITIAL_CONTEXT_FACTORY+" =
"+_defaultJBossNCtxFactory);
System.out.println("Using: result jsp = "+_resultJsp);
try {
ctx = new InitialContext(jndiProps);
// get home here to use balancing
home = (TestHAEjbStatefulHomeRemote) ctx.lookup(_ejbJndiName);
} catch (NamingException e) {
throw new ServletException(e);
}
}
protected void execute(HttpServletRequest request, HttpServletResponse
response) throws ServletException, IOException {
String result = null;
String name = request.getParameter(_requesterName);
String beanName = request.getParameter(_beanName);
String strLoops = request.getParameter(_loops);
System.out.println("name: "+name+" beanName: "+beanName+" strLoops:
"+strLoops);
int loops = 1;
try {
loops = Integer.parseInt(strLoops);
} catch (NumberFormatException e) {
}
if (name == null) {
name = "anonimo";
}
if (beanName == null) {
beanName = "bean anonimo";
}
StringBuffer sb = new StringBuffer();
sb.append("<table border=\"1\">");
bean = null;
try {
for (int i = 0; i < loops; i++) {
bean = home.create(beanName);
result = testEjb(name);
sb.append(""+(i+1)+"");
sb.append(result);
sb.append("");
try {
bean.remove();
} catch (RemoveException e2) {
e2.printStackTrace();
}
bean = null;
}
} catch (RemoteException e1) {
sb.append(""+e1.getMessage()+"");
} catch (CreateException e1) {
sb.append(""+e1.getMessage()+"");
} finally {
if ( bean != null ) {
try {
bean.remove();
} catch (RemoteException e2) {
e2.printStackTrace();
} catch (RemoveException e2) {
e2.printStackTrace();
}
}
}
sb.append("");
request.setAttribute(_answerBean, sb.toString());
request.getRequestDispatcher(_resultJsp).forward(request, response);
}
private String testEjb(String name) {
String result = null;
try {
result = bean.whoAreYou(name);
int max = bean.getMaxItems();
result += " max items ["+max+"]";
for (int i = 0; i < max; i++) {
result += " <"+bean.getNextItem()+">";
}
} catch (RemoteException e) {
result = e.getMessage();
}
return result;
}
}
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3829187#3829187
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3829187
-------------------------------------------------------
This SF.Net email is sponsored by: IBM Linux Tutorials
Free Linux tutorial presented by Daniel Robbins, President and CEO of
GenToo technologies. Learn everything from fundamentals to system
administration.http://ads.osdn.com/?ad_id=1470&alloc_id=3638&op=click
_______________________________________________
JBoss-user mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-user
