001    /** 
002     * 
003     * Copyright 2004 Protique Ltd
004     * 
005     * Licensed under the Apache License, Version 2.0 (the "License"); 
006     * you may not use this file except in compliance with the License. 
007     * You may obtain a copy of the License at 
008     * 
009     * http://www.apache.org/licenses/LICENSE-2.0
010     * 
011     * Unless required by applicable law or agreed to in writing, software
012     * distributed under the License is distributed on an "AS IS" BASIS, 
013     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 
014     * See the License for the specific language governing permissions and 
015     * limitations under the License. 
016     * 
017     **/
018    
019    package org.activemq.transport.remote;
020    import javax.jms.JMSException;
021    
022    import org.activemq.broker.BrokerContainer;
023    import org.activemq.io.WireFormat;
024    import org.activemq.transport.NetworkConnector;
025    import org.activemq.transport.RemoteNetworkConnector;
026    import org.activemq.transport.peer.PeerTransportChannel;
027    import org.activemq.util.IdGenerator;
028    
029    /**
030     * A <CODE>RemoteTransportChannel</CODE> creates an embedded broker that creates a remote connection to
031     * another broker. This connection type is designed for reliable connections, that can use the storage
032     * mechansims of an embedded broker to be decoupled from the remote broker - i.e. for connections that 
033     * need to be reliable, don't block but maybe using a transport across an unreliable network connection
034     * <P>
035     
036     * <P>
037     * An example of the expected format is: <CODE>remote://tcp://remotebroker:5060</CODE> 
038     * <P>
039     * 
040     * @version $Revision: 1.1.1.1 $
041     */
042    public class RemoteTransportChannel extends PeerTransportChannel {
043      
044        /**
045         * Construct a RemoteTransportChannel
046         * 
047         * @param wireFormat
048         * @param peerURIs
049         * @throws JMSException
050         */
051        protected RemoteTransportChannel(WireFormat wireFormat, String peerURIs) throws JMSException{
052            super(wireFormat,new IdGenerator().generateId());
053            setPeerURIs(peerURIs);
054            setDoDiscovery(false);
055            setRemote(true);
056        }
057        
058        /**
059         * Create a NetworkConnector
060         * @param container
061         * @return the NetworkConnector
062         */
063        protected NetworkConnector createNetworkConnector(BrokerContainer container){
064            return new RemoteNetworkConnector(container);
065        }
066    
067    }