@Override
    public void run()
    {
		final PubSubPersistenceProvider provider = XMPPServer.getInstance().getPubSubModule().getPersistenceProvider();
		if ( provider instanceof CachingPubsubPersistenceProvider )
		{
			if ( uniqueIdentifier != null ) {
				((CachingPubsubPersistenceProvider) provider).flushPendingChanges(uniqueIdentifier, false ); // just this member
			} else {
				((CachingPubsubPersistenceProvider) provider).flushPendingChanges(false ); // just this member
			}
        }
	}
Instantiates a flush task for a system-wide flush of pending changes.
xmppserver/src/main/java/org/jivesoftware/openfire/pubsub/cluster/FlushTask.java