code: @Override
  	public synchronized void flush()
      {
          if (!transport.isClosed())
          {
              try
              {
                  int len = notificationBuffer.size();
                  for (int i = 0 ; i < len ; i++)
                  {
                  	NotificationPacket notifPacket = notificationBuffer.get(i);
                  	notifPacket.setDonePrefetching(i == len-1);
                      transport.send(notifPacket);
                  }
              }
              catch (Exception e)
              {
                  log.error("Could not send notification packet",e);
                  transport.close();
              }
          }
          
          notificationBuffer.clear();
      }
docs: /*
  (non-Javadoc)
  @see net.timewalker.ffmq4.local.destination.notification.NotificationProxy#flush()