synchronized void registerToNotifications() throws JMSException {
  if (m_closed) {
    if (_logger.isLoggable(Level.FINE)) {
      _logger.log(Level.FINE,toString2() + "GSMessageConsumerImpl.registerToNotifications(): Called on a closed consumer.");
    }
    return;
  }
  if (_logger.isLoggable(Level.FINE)) {
    _logger.log(Level.FINE,toString2() + "GSMessageConsumerImpl.registerToNotifications(): registering for notifications");
  }
  try {
    eventSession=DataEventSessionFactory.create(m_space,eventSessionConfig);
    eventSession.addListener(m_jmsMessageTemplate,onMessageEventListener,NotifyActionType.NOTIFY_WRITE);
  }
 catch (  IOException e) {
    if (_logger.isLoggable(Level.FINE)) {
      _logger.log(Level.FINE,toString2() + "GSMessageConsumerImpl.startAsynchronous(): IOException while creating event session" + e);
    }
    JMSException e1=new JMSException("Failed to create event session.");
    e1.setLinkedException(e);
    throw e1;
  }
}

synchronized void registerToNotifications ( ) throws JMSException { if ( m_closed ) { if ( _logger . isLoggable ( Level . FINE ) ) { _logger . log ( Level . FINE , toString2 ( ) + "GSMessageConsumerImpl.registerToNotifications(): Called on a closed consumer." ) ; } return ; } if ( _logger . isLoggable ( Level . FINE ) ) { _logger . log ( Level . FINE , toString2 ( ) + "GSMessageConsumerImpl.registerToNotifications(): registering for notifications" ) ; } try { eventSession = DataEventSessionFactory . create ( m_space , eventSessionConfig ) ; eventSession . addListener ( m_jmsMessageTemplate , onMessageEventListener , NotifyActionType . NOTIFY_WRITE ) ; } catch ( IOException e ) { if ( _logger . isLoggable ( Level . FINE ) ) { _logger . log ( Level . FINE , toString2 ( ) + "GSMessageConsumerImpl.startAsynchronous(): IOException while creating event session" + e ) ; } JMSException e1 = new JMSException ( "Failed to create event session." ) ; e1 . setLinkedException ( e ) ; throw e1 ; } }
creates the notifydelegator to get notifications for messages .
