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 }