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 */ 017package org.apache.activemq.transport.failover; 018 019import java.io.IOException; 020import java.net.URI; 021import java.net.URISyntaxException; 022import java.util.HashMap; 023import java.util.Map; 024import org.apache.activemq.transport.MutexTransport; 025import org.apache.activemq.transport.ResponseCorrelator; 026import org.apache.activemq.transport.Transport; 027import org.apache.activemq.transport.TransportFactory; 028import org.apache.activemq.transport.TransportServer; 029import org.apache.activemq.util.IntrospectionSupport; 030import org.apache.activemq.util.URISupport; 031import org.apache.activemq.util.URISupport.CompositeData; 032 033public class FailoverTransportFactory extends TransportFactory { 034 035 @Override 036 public Transport doConnect(URI location) throws IOException { 037 try { 038 Transport transport = createTransport(URISupport.parseComposite(location)); 039 transport = new MutexTransport(transport); 040 transport = new ResponseCorrelator(transport); 041 return transport; 042 } catch (URISyntaxException e) { 043 throw new IOException("Invalid location: " + location); 044 } 045 } 046 047 @Override 048 public Transport doCompositeConnect(URI location) throws IOException { 049 try { 050 return createTransport(URISupport.parseComposite(location)); 051 } catch (URISyntaxException e) { 052 throw new IOException("Invalid location: " + location); 053 } 054 } 055 056 /** 057 * @param location 058 * @return 059 * @throws IOException 060 */ 061 public Transport createTransport(CompositeData compositData) throws IOException { 062 Map<String, String> options = compositData.getParameters(); 063 FailoverTransport transport = createTransport(options); 064 if (!options.isEmpty()) { 065 throw new IllegalArgumentException("Invalid connect parameters: " + options); 066 } 067 transport.add(false,compositData.getComponents()); 068 return transport; 069 } 070 071 public FailoverTransport createTransport(Map<String, String> parameters) throws IOException { 072 FailoverTransport transport = new FailoverTransport(); 073 Map<String, Object> nestedExtraQueryOptions = IntrospectionSupport.extractProperties(parameters, "nested."); 074 IntrospectionSupport.setProperties(transport, parameters); 075 try { 076 transport.setNestedExtraQueryOptions(URISupport.createQueryString(nestedExtraQueryOptions)); 077 } catch (URISyntaxException e) { 078 } 079 return transport; 080 } 081 082 @Override 083 public TransportServer doBind(URI location) throws IOException { 084 throw new IOException("Invalid server URI: " + location); 085 } 086 087}