Examples of PipeService

    }    
    
    OutputPipe createPropagatedOutputPipe() {


        String instanceName = ReplicationUtil.getInstanceName();
        PipeService pipeService = this.netPeerGroup.getPipeService();
        PipeAdvertisement pipeAdv = JxtaUtil.getPropagatedPipeAdvertisement();
        if (_pipelogger.isLoggable(Level.FINEST)) {
            _pipelogger.finest("prop pipe adv: " + pipeAdv);
        }        
        OutputPipe op = null;
        try {
            //op = pipeService.createOutputPipe(pipeAdv, Collections.singleton(JxtaUtil.getPeerID(instanceName)), 10000); 
            op = pipeService.createOutputPipe(pipeAdv, 100);
        } catch (IOException ex) {
            //log this
        }
        return op;
    }

Examples of net.jxta.pipe.PipeService

        return op;
    }
    
    private InputPipeWrapper createPropagatedInputPipeWrapper() {
        
        PipeService pipeService = this.netPeerGroup.getPipeService();
        PipeAdvertisement pipeAdv = JxtaUtil.getPropagatedPipeAdvertisement();
        InputPipe ip = null;
        InputPipeWrapper ipWrapper = new InputPipeWrapper();
        try {
            ip = pipeService.createInputPipe(pipeAdv, ipWrapper);
            ipWrapper.setPipe(ip);
        } catch (IOException ex) {
            // FIXME evaluate log level
            if (_pipelogger.isLoggable(Level.FINE)) {
                _pipelogger.log(Level.FINE, "caught exception in createPropagatedInputPipeWrapper", ex);

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.