001    /**
002     * Licensed to the Apache Software Foundation (ASF) under one or more
003     * contributor license agreements.  See the NOTICE file distributed with
004     * this work for additional information regarding copyright ownership.
005     * The ASF licenses this file to You under the Apache License, Version 2.0
006     * (the "License"); you may not use this file except in compliance with
007     * the License.  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    package org.apache.camel.component.mina;
018    
019    import java.io.IOException;
020    import java.net.InetSocketAddress;
021    import java.net.SocketAddress;
022    import java.net.URI;
023    import java.util.Map;
024    
025    import org.apache.camel.CamelContext;
026    import org.apache.camel.Endpoint;
027    import org.apache.camel.impl.DefaultComponent;
028    import org.apache.mina.common.IoAcceptor;
029    import org.apache.mina.common.IoConnector;
030    import org.apache.mina.filter.codec.ProtocolCodecFilter;
031    import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
032    import org.apache.mina.transport.socket.nio.DatagramAcceptor;
033    import org.apache.mina.transport.socket.nio.DatagramConnector;
034    import org.apache.mina.transport.socket.nio.DatagramConnectorConfig;
035    import org.apache.mina.transport.socket.nio.SocketAcceptor;
036    import org.apache.mina.transport.socket.nio.SocketConnector;
037    import org.apache.mina.transport.socket.nio.SocketConnectorConfig;
038    import org.apache.mina.transport.vmpipe.VmPipeAcceptor;
039    import org.apache.mina.transport.vmpipe.VmPipeAddress;
040    import org.apache.mina.transport.vmpipe.VmPipeConnector;
041    
042    /**
043     * @version $Revision: 563665 $
044     */
045    public class MinaComponent extends DefaultComponent<MinaExchange> {
046        public MinaComponent() {
047        }
048    
049        public MinaComponent(CamelContext context) {
050            super(context);
051        }
052    
053        @Override
054        protected Endpoint<MinaExchange> createEndpoint(String uri, String remaining, Map parameters) throws Exception {
055            URI u = new URI(remaining);
056    
057            String protocol = u.getScheme();
058            if (protocol.equals("tcp")) {
059                return createSocketEndpoint(uri, u);
060            } else if (protocol.equals("udp") || protocol.equals("mcast") || protocol.equals("multicast")) {
061                return createDatagramEndpoint(uri, u);
062            } else if (protocol.equals("vm")) {
063                return createVmEndpoint(uri, u);
064            } else {
065                throw new IOException("Unrecognised MINA protocol: " + protocol + " for uri: " + uri);
066            }
067        }
068    
069        protected MinaEndpoint createVmEndpoint(String uri, URI connectUri) {
070            IoAcceptor acceptor = new VmPipeAcceptor();
071            SocketAddress address = new VmPipeAddress(connectUri.getPort());
072            IoConnector connector = new VmPipeConnector();
073            return new MinaEndpoint(uri, this, address, acceptor, connector, null);
074        }
075    
076        protected MinaEndpoint createSocketEndpoint(String uri, URI connectUri) {
077            IoAcceptor acceptor = new SocketAcceptor();
078            SocketAddress address = new InetSocketAddress(connectUri.getHost(), connectUri.getPort());
079            IoConnector connector = new SocketConnector();
080    
081            // TODO customize the config via URI
082            SocketConnectorConfig config = new SocketConnectorConfig();
083            config.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
084    
085            return new MinaEndpoint(uri, this, address, acceptor, connector, config);
086        }
087    
088        protected MinaEndpoint createDatagramEndpoint(String uri, URI connectUri) {
089            IoAcceptor acceptor = new DatagramAcceptor();
090            SocketAddress address = new InetSocketAddress(connectUri.getHost(), connectUri.getPort());
091            IoConnector connector = new DatagramConnector();
092    
093            // TODO customize the config via URI
094            DatagramConnectorConfig config = new DatagramConnectorConfig();
095            config.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
096    
097            return new MinaEndpoint(uri, this, address, acceptor, connector, config);
098        }
099    }