continue;                        }                    }                } catch (Exception e) {                    continue; // Broken content; silently discard                }                System.out.println("Received Request from HungryPeer "                               + name                               + " for "                               + size                               + " Fries.");                // The auction request is valid. We can                // create the output pipe to send the response bid to                // the HungryPeer requester                try {                    System.out.println(                        "Attempting to create Output Pipe to HungryPeer " +                        name);                    // Create an output pipe connection to the HungryPeer                    pipeOut = pipes.createOutputPipe(hungryPipe,                                                     rtimeout);                    // Check if we have a pipe                    if (pipeOut == null) {                        // Cannot conect the pipe                        System.out.println("Could not find HungryPeer pipe");                        continue;                    }                } catch (Exception e) {                    // Pipe creation exception                    System.out.println("HungryPeer may not be listening anymore");                    continue;                }                // We have a pipe connection to the HungryPeer.                // Now create the Bid Response document                try {                    // Construct the Response document                    bid = StructuredDocumentFactory.newStructuredDocument(                                     mimeType,                                     "RestoNet:Bid");                    // Set the Bid values (Brand, price, special)                    // in the response document                    el = bid.createElement("Brand", brand);                    bid.appendChild(el);                    el = bid.createElement("Price", friesPrice(size));                    bid.appendChild(el);                    el = bid.createElement("Specials", specials);                    bid.appendChild(el);                    // Create a new pipe message                    msg = pipes.createMessage();                    // Push the Bid offer in the message                    msg.addElement(msg.newMessageElement(                                   "Bid",mimeType, bid.getStream()));                    // Send the message                    pipeOut.send(msg);                    // Close the output pipe connection                    pipeOut.close();                } catch (Exception ex) {                    System.out.println(                        "Error sending bid offer to HungryPeer " + name);                    continue;                }                System.out.println("Sent Bid Offer to HungryPeer (" + name +                       ") Fries price = "  + friesPrice(size) +                       ", special = " + specials);            } catch (Exception e) {               System.out.println("Abort RestoPeer interrupted");               return;            }        }    }    // Determine the price of the French fries depending on the size    private String friesPrice(String size) {        if (size.equals("small"))              return "$1.50";        if (size.equals("medium"))              return "2.50";        if (size.equals("large"))              return "3.00";        return "error";    }    // This routine creates a Module Spec advertisement to be    // associated with a RestoPeer    private void createRestoPeerService() {        try {            // First create the Module class advertisement associated            // with the service.            // The Module class advertisement is used            // to advertise the existence of the service.            // In order to access the service, a            // peer will have to discover the associated module spec            // advertisement.            ModuleClassAdvertisement mcadv = (ModuleClassAdvertisement)                AdvertisementFactory.newAdvertisement(                ModuleClassAdvertisement.getAdvertisementType());            mcadv.setName("JXTAMOD:RestoNet:Service:" + brand);            mcadv.setDescription("RestoPeer service");            ModuleClassID mcID = IDFactory.newModuleClassID();            mcadv.setModuleClassID(mcID);            // Publish the Module Class advertisement            // it in my local cache and to my peergroup.            disco.publish(mcadv, DiscoveryService.ADV);            disco.remotePublish(mcadv, DiscoveryService.ADV);            // Create the Module Spec advertisement associated            // with the service.            // The Module Spec advertisement will contain            // all the information necessary for a client to contact            // the service; for instance it will contain a pipe            // advertisement to be used to contact the service            ModuleSpecAdvertisement mdadv = (ModuleSpecAdvertisement)                AdvertisementFactory.newAdvertisement(                ModuleSpecAdvertisement.getAdvertisementType());            // Set up some of the information field about the            // service. In this example, we set the name,            // provider and version and a pipe advertisement. The            // module creates an input pipes to listen on this pipe            // endpoint.            mdadv.setName("JXTASPEC:RestoNet:Service:" + brand);            mdadv.setVersion("Version 1.0");            mdadv.setCreator("sun.com");            mdadv.setModuleSpecID(IDFactory.newModuleSpecID(mcID));            mdadv.setSpecURI("http://www.jxta.org/tutorial/RestoPeer.jar");            // Set a pipe advertisement for the Service. The pipe is            // used as the mean to communicate with the service. The            // HungryPeer client MUST use this pipe to talk the            // service.            // The pipe advertisement is stored in the service advertisement            // params; the client retrieves it from the params.            mdadv.setPipeAdvertisement(myAdv);            // Display the advertisement as a plain text dcoument.            StructuredTextDocument doc = (StructuredTextDocument)                mdadv.getDocument(new MimeMediaType("text/plain"));            StringWriter out = new StringWriter();            doc.sendToWriter(out);            System.out.println(out.toString());            out.close();            // Publish the service advertisement            disco.publish(mdadv, DiscoveryService.ADV);            disco.remotePublish(mdadv, DiscoveryService.ADV);        } catch (Exception ex) {            System.out.println("Error publishing RestoPeer Advertisement");        }    }    // Create the resto pipe associated with this RestoPeer.    // Discover first if a pipe advertisement exists, if    // not create and publish it.    private boolean createRestoPipe() {        int count = 3;           // Discovery retry count        Enumeration ae = null;   // Discovery response enumeration        try {            System.out.println("Attempting to Discover the Restaurant RestoPipe");            // get the discovery and pipe services for the RestoNet Peergroup            disco = restoNet.getDiscoveryService();            pipes = restoNet.getPipeService();            // check if I have already published myself            // one should always check if the advertisement            // is there            while (count-->0) {                try {                    // check first locally if we have the advertisement cached                    ae = disco.getLocalAdvertisements(DiscoveryService.ADV                                             , "name"                                             , "RestoNet:RestoPipe:"                                             + brand);                    // if we find our pipe advertisement we are done                    // no need to create one                    if (ae != null && ae.hasMoreElements()) {                        break;                    }                    // we did not find the advertisement locally, let's                    // send a remote request                    disco.getRemoteAdvertisements(null,			 DiscoveryService.ADV, "name",			 "RestoNet:RestoPipe:" + brand, 1, null);                    // nothing really to do here, so                    // wait a little to give a chance for the request                    // to come back                    try {                        Thread.sleep(timeout);                    } catch (Exception e){                    }                } catch (IOException e){                    // found nothing!  move on                }            }            // we searched for our pipe advertisement we could not find            // one so let's go an create one            if (ae == null || !ae.hasMoreElements()) {                System.out.println(                    "Could not find the Restaurant Pipe Advertisement");                // Create a pipe advertisement for our RestoPeer                myAdv = (PipeAdvertisement)                    AdvertisementFactory.newAdvertisement(                    PipeAdvertisement.getAdvertisementType() );                // assign a unique ID to the pipe                myAdv.setPipeID(IDFactory.newPipeID(                    restoNet.getPeerGroupID()));                // the sympolic name of the pipe is build from                // the brand name of RestoPeer. So each RestoPeer                // as a unique name.                myAdv.setName("RestoNet:RestoPipe:" + brand);                // set the type of the pipe                myAdv.setType(PipeService.UnicastType);                // we have the advertisement, we can publish                // our pipe advertisement into our local cache                // and to the RestoNet PeerGroup                disco.publish(myAdv, DiscoveryService.ADV);                disco.remotePublish(myAdv, DiscoveryService.ADV);                System.out.println("Created the Restaurant Pipe Advertisement");            } else {                // we got it so we do not need to create one                myAdv = (PipeAdvertisement) ae.nextElement();                System.out.println("Found Restaurant Pipe Advertisement");            }            // create my input pipe to listen for hungry peers            // requests            pipeIn = pipes.createInputPipe(myAdv);        } catch (Exception e) {            System.out.println("Could not initialize the Restaurant pipe");            return false;        }        return true;    }}