Coverage Report - org.apache.camel.component.mina.MinaComponent
 
Classes in this File Line Coverage Branch Coverage Complexity
MinaComponent
66% 
100% 
0
 
 1  
 /**
 2  
  * Licensed to the Apache Software Foundation (ASF) under one or more
 3  
  * contributor license agreements.  See the NOTICE file distributed with
 4  
  * this work for additional information regarding copyright ownership.
 5  
  * The ASF licenses this file to You under the Apache License, Version 2.0
 6  
  * (the "License"); you may not use this file except in compliance with
 7  
  * the License.  You may obtain a copy of the License at
 8  
  *
 9  
  *      http://www.apache.org/licenses/LICENSE-2.0
 10  
  *
 11  
  * Unless required by applicable law or agreed to in writing, software
 12  
  * distributed under the License is distributed on an "AS IS" BASIS,
 13  
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 14  
  * See the License for the specific language governing permissions and
 15  
  * limitations under the License.
 16  
  */
 17  
 package org.apache.camel.component.mina;
 18  
 
 19  
 import java.io.IOException;
 20  
 import java.net.InetSocketAddress;
 21  
 import java.net.SocketAddress;
 22  
 import java.net.URI;
 23  
 import java.util.Map;
 24  
 
 25  
 import org.apache.camel.CamelContext;
 26  
 import org.apache.camel.Endpoint;
 27  
 import org.apache.camel.impl.DefaultComponent;
 28  
 import org.apache.mina.common.IoAcceptor;
 29  
 import org.apache.mina.common.IoConnector;
 30  
 import org.apache.mina.filter.codec.ProtocolCodecFilter;
 31  
 import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
 32  
 import org.apache.mina.transport.socket.nio.DatagramAcceptor;
 33  
 import org.apache.mina.transport.socket.nio.DatagramConnector;
 34  
 import org.apache.mina.transport.socket.nio.DatagramConnectorConfig;
 35  
 import org.apache.mina.transport.socket.nio.SocketAcceptor;
 36  
 import org.apache.mina.transport.socket.nio.SocketConnector;
 37  
 import org.apache.mina.transport.socket.nio.SocketConnectorConfig;
 38  
 import org.apache.mina.transport.vmpipe.VmPipeAcceptor;
 39  
 import org.apache.mina.transport.vmpipe.VmPipeAddress;
 40  
 import org.apache.mina.transport.vmpipe.VmPipeConnector;
 41  
 
 42  
 /**
 43  
  * @version $Revision: 563665 $
 44  
  */
 45  
 public class MinaComponent extends DefaultComponent<MinaExchange> {
 46  2
     public MinaComponent() {
 47  2
     }
 48  
 
 49  
     public MinaComponent(CamelContext context) {
 50  0
         super(context);
 51  0
     }
 52  
 
 53  
     @Override
 54  
     protected Endpoint<MinaExchange> createEndpoint(String uri, String remaining, Map parameters) throws Exception {
 55  2
         URI u = new URI(remaining);
 56  
 
 57  2
         String protocol = u.getScheme();
 58  2
         if (protocol.equals("tcp")) {
 59  1
             return createSocketEndpoint(uri, u);
 60  1
         } else if (protocol.equals("udp") || protocol.equals("mcast") || protocol.equals("multicast")) {
 61  0
             return createDatagramEndpoint(uri, u);
 62  1
         } else if (protocol.equals("vm")) {
 63  1
             return createVmEndpoint(uri, u);
 64  
         } else {
 65  0
             throw new IOException("Unrecognised MINA protocol: " + protocol + " for uri: " + uri);
 66  
         }
 67  
     }
 68  
 
 69  
     protected MinaEndpoint createVmEndpoint(String uri, URI connectUri) {
 70  1
         IoAcceptor acceptor = new VmPipeAcceptor();
 71  1
         SocketAddress address = new VmPipeAddress(connectUri.getPort());
 72  1
         IoConnector connector = new VmPipeConnector();
 73  1
         return new MinaEndpoint(uri, this, address, acceptor, connector, null);
 74  
     }
 75  
 
 76  
     protected MinaEndpoint createSocketEndpoint(String uri, URI connectUri) {
 77  1
         IoAcceptor acceptor = new SocketAcceptor();
 78  1
         SocketAddress address = new InetSocketAddress(connectUri.getHost(), connectUri.getPort());
 79  1
         IoConnector connector = new SocketConnector();
 80  
 
 81  
         // TODO customize the config via URI
 82  1
         SocketConnectorConfig config = new SocketConnectorConfig();
 83  1
         config.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
 84  
 
 85  1
         return new MinaEndpoint(uri, this, address, acceptor, connector, config);
 86  
     }
 87  
 
 88  
     protected MinaEndpoint createDatagramEndpoint(String uri, URI connectUri) {
 89  0
         IoAcceptor acceptor = new DatagramAcceptor();
 90  0
         SocketAddress address = new InetSocketAddress(connectUri.getHost(), connectUri.getPort());
 91  0
         IoConnector connector = new DatagramConnector();
 92  
 
 93  
         // TODO customize the config via URI
 94  0
         DatagramConnectorConfig config = new DatagramConnectorConfig();
 95  0
         config.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
 96  
 
 97  0
         return new MinaEndpoint(uri, this, address, acceptor, connector, config);
 98  
     }
 99  
 }