public TrapEmitter(String trapFactoryClassName,
    Counter trapCount,
    Clock uptime,
    String managersResName,
    String notificationMapResName) 
{
      this.trapFactoryClassName = trapFactoryClassName;
      this.trapCount = trapCount;
      this.uptime = uptime;
      this.managersResName = managersResName;
      this.notificationMapResName = notificationMapResName;
}

Builds a TrapEmitter object for sending SNMP V1 or V2 traps.

 public  void send(Notification n) throws Exception 
{
      // Beeing paranoid
      synchronized(this.trapFactory) {
         if(this.trapFactory == null) {
            log.error("Received notifications before trap factory set. Discarding.");
            return;     
         }
      }
      // Cache the translated notification
      SnmpPduTrap v1TrapPdu = null; 
      SnmpPduPacket v2TrapPdu = null; 
      // Send trap. Synchronise on the subscription collection while 
      // iterating 
      synchronized(this.managers) {
         // Iterate over sessions and emit the trap on each one
         Iterator i = this.managers.iterator();
         while (i.hasNext()) {
            ManagerRecord s = (ManagerRecord)i.next();       
            try {
               switch (s.getVersion()) {
                  case SnmpAgentService.SNMPV1:
                     if (v1TrapPdu == null)
                        v1TrapPdu = this.trapFactory.generateV1Trap(n);
                     // fix the agent ip in the trap depending on which local address is bound
                     v1TrapPdu.setAgentAddress(new SnmpIPAddress(s.getLocalAddress()));
                     // Advance the trap counter
                     this.trapCount.advance();
                     // Send
                     s.getSession().send(v1TrapPdu);
                     break;
                  case SnmpAgentService.SNMPV2:
                     if (v2TrapPdu == null)
                        v2TrapPdu = this.trapFactory.generateV2Trap(n);
                     // Advance the trap counter
                     this.trapCount.advance();
                     // Send
                     s.getSession().send(v2TrapPdu);
                     break;
                  default:    
                     log.error("Skipping session: Unknown SNMP version found");    
               }            
            } 
            catch(MappingFailedException e) {
              log.error("Translating notification - " + e.getMessage());
            }    
            catch(Exception e) {
              log.error("SNMP send error for " + 
                        s.getAddress().toString() + ":" +
                        s.getPort() + ": < " + e +
                        " >");                    
            }
         }    
      }
}

Intercepts the notification and after translating it to a trap sends it along.

 public  void start() throws Exception 
{
      // Load persisted manager subscriptions
      load();
      // Instantiate the trap factory
      this.trapFactory = (TrapFactory) Class.forName(this.trapFactoryClassName,
                                                     true,
                                                     this.getClass().getClassLoader()).newInstance();
      // Initialise
      this.trapFactory.set(this.notificationMapResName,
                           this.uptime,
                           this.trapCount);
      // Start the trap factory
      this.trapFactory.start();
}

Complete emitter initialisation *

 public  void stop() throws Exception 
{
      synchronized(this.managers) {
         // Recycle open sessions to managers
         Iterator i = this.managers.iterator();
         while (i.hasNext()) {
            ManagerRecord s = (ManagerRecord)i.next();
            s.closeSession();    
         }
         // Drop all held manager records
         this.managers.clear();
      }
}

Perform shutdown *