@Override
    public void loadNodes(PubSubService service)
    {
        log.debug( "Loading nodes for service: {}", service.getUniqueIdentifier() );

        // Make sure that all changes to nodes have been written to the database
        // before the nodes are retrieved.
        flushPendingNodes( service.getUniqueIdentifier() );

        delegate.loadNodes( service );
    }
Cache for recently accessed published items.
xmppserver/src/main/java/org/jivesoftware/openfire/pubsub/CachingPubsubPersistenceProvider.java