code: public void initialize(final JsMessagingEngine engine) {
  
          final String methodName = "initialize";
          if (TRACE.isEntryEnabled()) {
              SibTr.entry(this, TRACE, methodName, engine);
          }
  
          final Set listeners;
  
          _messagingEngine = engine;
  
          synchronized (MESSAGING_ENGINES) {
  
              // Do we already have a set of initialized MEs on this bus?
              Set messagingEngines = (Set) MESSAGING_ENGINES.get(engine
                      .getBusName());
  
              // If not, create a new set and add it to the map
              if (messagingEngines == null) {
  
                  messagingEngines = new HashSet();
                  MESSAGING_ENGINES.put(engine.getBusName(), messagingEngines);
  
              }
  
              // Add the initializing ME to the set
              messagingEngines.add(engine);
  
              // Get listeners to notify
              listeners = getListeners(_messagingEngine.getBusName());
  
          }
  
          // Notify listeners
          for (final Iterator iterator = listeners.iterator(); iterator.hasNext();) {
  
              final SibRaMessagingEngineListener listener = (SibRaMessagingEngineListener) iterator
                      .next();
              listener.messagingEngineInitializing(_messagingEngine);
  
          }
  
          if (TRACE.isEntryEnabled()) {
              SibTr.exit(this, TRACE, methodName);
          }
  
      }
docs: /*
  (non-Javadoc)
  
  @see com.ibm.ws.sib.admin.JsEngineComponent#initialize(com.ibm.ws.sib.admin.JsMessagingEngine)