1
2
3
4
5
6
7
8
9
10
11
12
13
14
15 package org.fourthline.cling.test.transport;
16
17 import org.fourthline.cling.UpnpServiceConfiguration;
18 import org.fourthline.cling.transport.impl.AsyncServletStreamServerConfigurationImpl;
19 import org.fourthline.cling.transport.impl.AsyncServletStreamServerImpl;
20 import org.fourthline.cling.transport.impl.jetty.JettyServletContainer;
21 import org.fourthline.cling.transport.impl.jetty.StreamClientConfigurationImpl;
22 import org.fourthline.cling.transport.impl.jetty.StreamClientImpl;
23 import org.fourthline.cling.transport.spi.StreamClient;
24 import org.fourthline.cling.transport.spi.StreamServer;
25
26 import javax.servlet.http.HttpServletRequest;
27
28
29
30
31 public class JettyServerJettyClientTest extends StreamServerClientTest {
32
33 @Override
34 public StreamServer createStreamServer(int port) {
35 AsyncServletStreamServerConfigurationImpl configuration =
36 new AsyncServletStreamServerConfigurationImpl(
37 JettyServletContainer.INSTANCE,
38 port
39 );
40
41 return new AsyncServletStreamServerImpl(
42 configuration
43 ) {
44 @Override
45 protected boolean isConnectionOpen(HttpServletRequest request) {
46 return JettyServletContainer.isConnectionOpen(request);
47 }
48 };
49 }
50
51 @Override
52 public StreamClient createStreamClient(UpnpServiceConfiguration configuration) {
53 return new StreamClientImpl(
54 new StreamClientConfigurationImpl(
55 configuration.getSyncProtocolExecutorService(),
56 3
57 )
58 );
59 }
60 }