public void scheduleMaintenance(String descr, Date dateOf) {
   TimerService timerService = ejbContext.getTimerService( );
   timerService.createTimer(dateOf, description);
}

public void clearSchedule( ) {
   TimerService timerService = ejbContext.getTimerService( );
   java.util.Iterator timers = timerService.getTimers( ).iterator( );
   while (timers.hasNext( )) {
      System.out.println("Cancelling maintenance on ship: " + getName( ));
      javax.ejb.Timer timer = (javax.ejb.Timer) timers.next( );
      timer.cancel( );
   }
}

public void ejbTimeout(javax.ejb.Timer timer)   {
   String description = (String) timer.getInfo( );

   try {
      InitialContext jndiContext = new InitialContext( );
      TopicConnectionFactory factory =(TopicConnectionFactory)
              jndiContext.lookup("java:comp/env/jms/TopicFactory");

      Topic topic = (Topic)
         jndiContext.lookup("java:comp/env/jms/MaintenanceTopic");

      TopicConnection connect = factory.createTopicConnection( );
      TopicSession session = connect.createTopicSession(true, 0);
      TopicPublisher publisher = session.createPublisher(topic);

      TextMessage textMsg = session.createTextMessage( );
      textMsg.setText(getName( ) + " " + description);
      publisher.publish(textMsg);
      session.close( );
      connect.close( );
   } catch (Exception e){
      throw new EJBException(e);
   }
}

A stateless session bean has been added to the ship package so that the Ship EJB methods can be called remotely. The scheduleMaintenance and clearSchedule methods look up a Ship EJB and call those methods on that particular entity bean.

public void scheduleMaintenance(int shipId, int secs, String desc) {
   try {
      ShipHomeLocal shiphome =(ShipHomeLocal)
          jndiContext.lookup("java:comp/env/ejb/ShipHomeLocal");

      ShipLocal ship = 
         shiphome.findByPrimaryKey(new Integer(shipId));
      Date dateOfTest = new Date(System.currentTimeMillis( ) 
                                 + (secondsToSchedule * 1000));
      ship.scheduleMaintenance(description, dateOfTest);
   } catch (NamingException e){
      throw new EJBException(e);
   } catch (javax.ejb.FinderException e){
      throw new EJBException(e);
   }
}

public void clearSchedule(int shipId) {
   try {
      ShipHomeLocal shiphome =(ShipHomeLocal)
          jndiContext.lookup("java:comp/env/ejb/ShipHomeLocal");

      ShipLocal ship = 
         shiphome.findByPrimaryKey(new Integer(shipId));
      Date dateOfTest = new Date(System.currentTimeMillis( ) 
                                 + (secondsToSchedule * 1000));
      ship.clearSchedule( );
   } catch (NamingException e){
      throw new EJBException(e);
   } catch (javax.ejb.FinderException e){
      throw new EJBException(e);
   }
}