import javax.ejb.stateless.*; 
/*a simple stateless session bean implementing       the incrementvalue() method of the * calculateejb interface.*/ 
@stateless(name="calculateejb") 
public class calculateejbbean 
implements calculateejb 
{ 
int value = 0; 
public string incrementvalue() 
{ 
value++; 
return "value incremented by 1"; 
} 
} 

import javax.persistence.*; 
import java.util.arraylist; 
import java.util.collection; 
@entity 
@table(name = "employees") 
public class employee implements java.io.serializable 
{ 
　private int empid; 
　private string ename; 
　private double sal; 
　@id 
　@column(name="empno", primarykey=true) 
　public int getempid() 
{ return empid;} 
　public void setempid(int empid) 
{ this.empid = empid; } 
　public string getename() 
{ return ename; } 
　public void setename(string ename) 
{ this.ename = ename; } 
　public double getsal() 
{ return sal; } 
　public void setsal(double sal) 
{ this.sal = sal; } 
　public string tostring() 
{stringbuffer buf = new stringbuffer(); 
buf.append("class:") 
.append(this.getclass().getname()).append(" ::")          .append(" empid:").append(getempid()).append(" ename:")        .append(getename()).append("sal:").append(getsal()); 
return buf.tostring();} 
} 

import javax.ejb.messagedriven; 
import javax.ejb.activationconfigproperty; 
import javax.ejb.inject; 
import javax.jms.*; 
import java.util.*; 
import javax.ejb.timedobject; 
import javax.ejb.timer; 
import javax.ejb.timerservice; 
@messagedriven( 
activationconfig = { 
@activationconfigproperty(propertyname="connectionfactoryjndiname", 
　propertyvalue="jms/topicconnectionfactory"), 
@activationconfigproperty(propertyname=      "destinationname", propertyvalue="jms/mytopic"), 
@activationconfigproperty(propertyname=      "destinationtype", propertyvalue="javax.jms.topic"), 
@activationconfigproperty(propertyname=      "messageselector", propertyvalue="recipient = 'mdb27%") } ) 
/** a simple message-driven bean that listens to the configured jms queue or       topic and gets notified via an * invocation of it's onmessage() method        when a message has been posted to the queue or topic.the bean 
* prints the contents of the message. */ 
public class messagelogger implements messagelistener, timedobject 
{ 
　@inject javax.ejb.messagedrivencontext mc; 
　public void onmessage(message message) 
　{ system.out.println("onmessage() - " + message); 
　try 
　{ 
　string subject = message.getstringproperty("subject"); 
　string inmessage = message.getstringproperty("message"); 
　system.out.println("message received\n\tdate:" + new java.util.date()                  + "\n\tsubject:" + subject + "\n\tmessage:" + inmessage + "\n"); 
　system.out.println("creating timer a single event timer"); 
　timerservice ts = mc.gettimerservice(); 
　timer timer = ts.createtimer(30000, subject); 
　system.out.println("timer created by mdb at:"                  + new date(system.currenttimemillis()) +" with info:"+subject); } 
　catch (throwable ex) 
　{ ex.printstacktrace(); } 
} 
　public void ejbtimeout(timer timer) 
　{ system.out.println("ejb 3.0:timer with mdb"); 
　system.out.println("ejbtimeout() called at:"            + new date(system.currenttimemillis())); 
　return; } 
} 

import javax.naming.context; 
import javax.naming.initialcontext; 
/* a simple bean client which calls methods on a stateless session bean.*/ 
public class calculateejbclient 
{ 
public static void main(string [] args) 
{ 
　context context = new initialcontext(); 
　calculateejb myejb =(calculateejb)context.lookup        ("java:comp/env/ejb/calculateejb"); 
myejb.incrementvalue(); } 
}