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

https://issues.apache.org/jira/browse/AMQ-6521 

Adding support for Jetty 9.3 by re-adding in the logic to dynamically
load the correct GzipHandler depending on the version
This commit is contained in:
Christopher L. Shannon (cshannon) 2016-11-29 11:20:27 -05:00
parent 4e766d92c5
commit 80f46a8056
1 changed files with 24 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
activemq-http/src/main/java/org/apache/activemq/transport/http/HttpTransportServer.java
View File

@ -32,7 +32,6 @@ import org.eclipse.jetty.server.Handler;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.servlet.ServletHolder;
import org.eclipse.jetty.servlets.gzip.GzipHandler;
public class HttpTransportServer extends WebTransportServerSupport {
@ -123,11 +122,34 @@ public class HttpTransportServer extends WebTransportServerSupport {
private int getConnectorLocalPort() throws Exception {
return (Integer)connector.getClass().getMethod("getLocalPort").invoke(connector);
}
private void addGzipHandler(ServletContextHandler contextHandler) throws Exception {
Handler handler = new GzipHandler();
Handler handler = null;
try {
handler = (Handler) forName("org.eclipse.jetty.server.handler.GzipHandler").newInstance();
} catch (Throwable t) {
handler = (Handler) forName("org.eclipse.jetty.servlets.gzip.GzipHandler").newInstance();
}
contextHandler.setHandler(handler);
}
private Class<?> forName(String name) throws ClassNotFoundException {
Class<?> clazz = null;
ClassLoader loader = Thread.currentThread().getContextClassLoader();
if (loader != null) {
try {
clazz = loader.loadClass(name);
} catch (ClassNotFoundException e) {
// ignore
}
}
if (clazz == null) {
clazz = HttpTransportServer.class.getClassLoader().loadClass(name);
}
return clazz;
}
@Override
protected void doStop(ServiceStopper stopper) throws Exception {
Server temp = server;