JXTA com CMS

Programação Java
#1

Estou desenvolvendo um compartilhador de arquivo e estou com problemas quanto a busca, não consigo fazer com que o sistema encontre um arquivo publicado. como posso resolver isto?



import java.io.File;

import net.jxta.peergroup.NetPeerGroupFactory;
import net.jxta.peergroup.PeerGroup;
import net.jxta.share.CMS;
import net.jxta.share.ContentAdvertisement;
import net.jxta.share.ContentManager;
import net.jxta.share.client.CachedListContentRequest;


public class ClasseExemplo{
	
	private CMS cms = null;
	private PeerGroup peerGroup = null;
	private int numeroPublicacoes = 0;
	
	
	public ClasseExemplo(File file, String nomeBusca){
		startJXTA();
		iniciaSessaoCMS();
		publicaArquivo(file);
		verificaPublicacao();
		iniciaBusca(nomeBusca);
	}
	
	
	public void startJXTA(){
		System.out.print("Iniciando JXTA ... ");
		try {
			peerGroup = new NetPeerGroupFactory().getInterface();
		} catch (Exception e) {
			System.out.println("Falhou");
			e.printStackTrace();
			System.exit(1);
		}
		System.out.println("[OK]");
	}
	
	
	public void iniciaSessaoCMS(){
		System.out.print("Iniciando Sessão CMS ... ");
		try {
			cms = new CMS();
			cms.init(peerGroup, null, peerGroup.getPeerGroupAdvertisement());
			cms.startApp(new File("cliente"));
		} catch (Exception e) {
			System.out.println("[Falhou]");
			e.printStackTrace();
			System.exit(1);
		}
		System.out.println("[OK]");
	}
	
	
	public void publicaArquivo(File file){
		System.out.print("Publicando arquivo ... ");
		try {
			ContentManager contentManager = cms.getContentManager();
			numeroPublicacoes = contentManager.getContent().length;
			contentManager.share(file);
		} catch (Exception e) {
			System.out.println("[Falhou]");
			e.printStackTrace();
			System.exit(1);
		}
		System.out.println("[OK]");
	}
	
	public void verificaPublicacao(){
		System.out.print("Verificando a publicação do arquivo ... ");
		try {
			ContentManager contentManager = cms.getContentManager();
			if(contentManager.getContent().length &gt numeroPublicacoes){
				System.out.println("[Confirmada]");
				System.out.println("\t Existem "+contentManager.getContent().length+" publicações.");
			} else {
				System.out.println("[Não Confirmada]");
			}
		} catch (Exception e) {
			System.out.println("[Falhou]");
			e.printStackTrace();
			System.exit(1);
		}
	}
	
	public void iniciaBusca(String fileName){
		System.out.print("Iniciando Busca ... ");
		try{
			ListRequestor requestor = new ListRequestor(peerGroup,fileName);
			requestor.activateRequest();
			requestor.getResults();
			System.out.println("[OK]");
		} catch (Exception e) {
			System.out.println("[Falhou]");
			e.printStackTrace();
			System.exit(1);
		}
	}
	
	/**
	 * Metodo Principal da Classe
	 */
	public static void main(String[] args){
		File file =  new File("D:/Documentos/espanhol.txt");
		String nomeBusca = "espanhol.txt";
		
		new ClasseEcemplo(file, nomeBusca);
	}
}

class ListRequestor extends CachedListContentRequest{

	public ListRequestor(PeerGroup group, String nomeBuscar) {
		super(group, nomeBuscar);
	}
	
	
	public void notifyMoreResults(){
		try {
			ContentAdvertisement[] searchResults = getResults();
			System.out.println("Número de arquivos encontrados: "+searchResults.length);
		} catch (Exception e) {
			System.out.println("FAlha no sistema");
			e.printStackTrace();
			System.exit(1);
		}
	}
	
	public void notifyDone() {
		System.out.println("Requestor done");
	} 
	
}
#2