code: @Override
      public void notifyException(Throwable exception)
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "notifyException", new Object[] { this, exception });
  
          // If an asynch consumer is registered we need to let them know something went wrong
          if (_asynchConsumerRegistered)
              _asynchConsumer.notifyExceptionListeners(exception, _consumerSession);
  
          this.lock();
          try
          {
              if (_waiting)
              {
                  // We need to get the exception back to the synchronous consumer
                  _notifiedException = exception;
                  _waiter.signal();
              }
          } finally
          {
              this.unlock();
          }
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "notifyException");
      }
docs: /*
  (non-Javadoc)
  
  @see com.ibm.ws.sib.processor.impl.ConsumerPoint#notifyException(com.ibm.ws.sib.processor.SIMPException)