code: public void pushMessage(IMessage message) throws IOException {
          if (log.isDebugEnabled()) {
              log.debug("pushMessage: {} to {} consumers", message, consumers.size());
          }
          for (IConsumer consumer : consumers) {
              try {
                  ((IPushableConsumer) consumer).pushMessage(this, message);
              } catch (Throwable t) {
                  if (t instanceof IOException) {
                      throw (IOException) t;
                  }
                  log.error("Exception pushing message to consumer", t);
              }
  
          }
      }
docs: Pushes a message out to all the PushableConsumers.
  
  @param message
  the message to be pushed to consumers
  @throws IOException
  In case IOException of some sort is occurred