Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix for: https://issues.apache.org/activemq/browse/AMQ-2942 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1000617 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2010-09-23 20:47:03 +00:00
parent 996b7a53a3
commit 0ff144f7f4
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
activemq-optional/src/main/java/org/apache/activemq/transport/https/HttpsTransportFactory.java
View File

@ -19,10 +19,16 @@ package org.apache.activemq.transport.https;
import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Map;
import java.util.HashMap;
import org.apache.activemq.transport.Transport;
import org.apache.activemq.transport.TransportServer;
import org.apache.activemq.transport.http.HttpTransportFactory;
import org.apache.activemq.util.IntrospectionSupport;
import org.apache.activemq.util.IOExceptionSupport;
import org.apache.activemq.util.URISupport;
import org.apache.activemq.wireformat.WireFormat;
/**
@ -33,11 +39,20 @@ import org.apache.activemq.wireformat.WireFormat;
public class HttpsTransportFactory extends HttpTransportFactory {
public TransportServer doBind(String brokerId, URI location) throws IOException {
return new HttpsTransportServer(location, this);
return doBind(location);
}
public TransportServer doBind(URI location) throws IOException {
return new HttpsTransportServer(location, this);
try {
Map<String, String> options = new HashMap<String, String>(URISupport.parseParameters(location));
HttpsTransportServer result = new HttpsTransportServer(location, this);
Map<String, Object> transportOptions = IntrospectionSupport.extractProperties(options, "transport.");
result.setTransportOption(transportOptions);
return result;
} catch (URISyntaxException e) {
throw IOExceptionSupport.create(e);
}
}
protected Transport createTransport(URI location, WireFormat wf) throws MalformedURLException {