Skip to content

Commit 4264587

Browse files
authored
Fix jetty upgrade issue (#1762)
1 parent e575675 commit 4264587

File tree

2 files changed

+10
-10
lines changed

2 files changed

+10
-10
lines changed

amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,9 +31,9 @@
3131
import org.apache.pulsar.broker.protocol.ProtocolHandler;
3232
import org.apache.pulsar.broker.service.BrokerService;
3333
import org.apache.pulsar.policies.data.loadbalancer.AdvertisedListener;
34+
import org.eclipse.jetty.ee8.servlet.ServletContextHandler;
35+
import org.eclipse.jetty.ee8.servlet.ServletHolder;
3436
import org.eclipse.jetty.server.Server;
35-
import org.eclipse.jetty.servlet.ServletContextHandler;
36-
import org.eclipse.jetty.servlet.ServletHolder;
3737
import org.glassfish.jersey.servlet.ServletContainer;
3838

3939
/**

tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/qpid/jms_1_1/extensions/sasl/AuthenticationTest.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@
4343
import javax.jms.Session;
4444
import javax.jms.TemporaryQueue;
4545
import javax.naming.NamingException;
46+
import javax.servlet.ServletException;
4647
import javax.servlet.http.HttpServletRequest;
4748
import javax.servlet.http.HttpServletResponse;
4849
import org.apache.qpid.server.model.Port;
@@ -59,12 +60,11 @@
5960
import org.apache.qpid.test.utils.tls.PrivateKeyEntry;
6061
import org.apache.qpid.test.utils.tls.TlsResource;
6162
import org.apache.qpid.test.utils.tls.TlsResourceBuilder;
62-
import org.eclipse.jetty.server.Request;
63+
import org.eclipse.jetty.ee8.nested.AbstractHandler;
64+
import org.eclipse.jetty.ee8.nested.ContextHandler;
65+
import org.eclipse.jetty.ee8.nested.HandlerCollection;
6366
import org.eclipse.jetty.server.Server;
6467
import org.eclipse.jetty.server.ServerConnector;
65-
import org.eclipse.jetty.server.handler.AbstractHandler;
66-
import org.eclipse.jetty.server.handler.ContextHandler;
67-
import org.eclipse.jetty.server.handler.HandlerCollection;
6868
import org.hamcrest.Matchers;
6969
import org.junit.AfterClass;
7070
import org.junit.BeforeClass;
@@ -146,7 +146,7 @@ public static void setUp() throws Exception
146146
createContext(_crlFile);
147147
createContext(_emptyCrlFile);
148148
createContext(_intermediateCrlFile);
149-
CRL_SERVER.setHandler(HANDLERS);
149+
CRL_SERVER.setHandler(HANDLERS.getServer());
150150
CRL_SERVER.start();
151151
crlHttpPort = connector.getLocalPort();
152152

@@ -842,9 +842,9 @@ private static class CrlServerHandler extends AbstractHandler
842842
}
843843

844844
@Override
845-
public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
846-
throws IOException
847-
{
845+
public void handle(String s, org.eclipse.jetty.ee8.nested.Request request,
846+
HttpServletRequest httpServletRequest,
847+
HttpServletResponse response) throws IOException, ServletException {
848848
final byte[] crlBytes = Files.readAllBytes(crlPath);
849849
response.setStatus(HttpServletResponse.SC_OK);
850850
try (final OutputStream responseBody = response.getOutputStream())

0 commit comments

Comments
 (0)