code: @Override
  	public synchronized void addNotification(IntegerID consumerId, AbstractMessage prefetchedMessage)
      {
  		NotificationPacket notifPacket = new NotificationPacket();
      	notifPacket.setSessionId(sessionId);
          notifPacket.setConsumerId(consumerId);
          notifPacket.setMessage(prefetchedMessage);
          
          notificationBuffer.add(notifPacket);
      }
docs: /* (non-Javadoc)
  @see net.timewalker.ffmq4.local.destination.notification.NotificationProxy#sendNotification(net.timewalker.ffmq4.utils.id.IntegerID, net.timewalker.ffmq4.common.message.AbstractMessage)