if(corr == null) { if(transport_adapter != null) corr=new RequestCorrelator("MessageDispatcher", transport_adapter, this, deadlock_detection, local_addr, concurrent_processing); else { corr=new RequestCorrelator("MessageDispatcher", prot_adapter, this, deadlock_detection, local_addr, concurrent_processing);
if (corr == null) { if (transport_adapter != null) { corr = new RequestCorrelator("MessageDispatcher", transport_adapter, this, deadlock_detection, local_addr, concurrent_processing); } else { corr = new RequestCorrelator("MessageDispatcher", prot_adapter, this, deadlock_detection, local_addr, concurrent_processing);
    public void start() {        if(corr == null) {            if(transport_adapter != null)                corr=new RequestCorrelator("MessageDispatcher", transport_adapter,                                            this, deadlock_detection, local_addr, concurrent_processing);            else {                corr=new RequestCorrelator("MessageDispatcher", prot_adapter,                                            this, deadlock_detection, local_addr, concurrent_processing);            }            corr.start();        }        if(channel != null) {            Vector tmp_mbrs=channel.getView() != null? channel.getView().getMembers() : null;            setMembers(tmp_mbrs);        }    }