本文整理汇总了Java中org.eclipse.jetty.websocket.api.UpgradeRequest类的典型用法代码示例。如果您正苦于以下问题：Java UpgradeRequest类的具体用法？Java UpgradeRequest怎么用？Java UpgradeRequest使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
UpgradeRequest类属于org.eclipse.jetty.websocket.api包，在下文中一共展示了UpgradeRequest类的13个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getPrincipalFromNativeSession
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Test
public void getPrincipalFromNativeSession() {
TestPrincipal user = new TestPrincipal("joe");
UpgradeRequest request = Mockito.mock(UpgradeRequest.class);
given(request.getUserPrincipal()).willReturn(user);
UpgradeResponse response = Mockito.mock(UpgradeResponse.class);
given(response.getAcceptedSubProtocol()).willReturn(null);
Session nativeSession = Mockito.mock(Session.class);
given(nativeSession.getUpgradeRequest()).willReturn(request);
given(nativeSession.getUpgradeResponse()).willReturn(response);
JettyWebSocketSession session = new JettyWebSocketSession(attributes);
session.initializeNativeSession(nativeSession);
reset(nativeSession);
assertSame(user, session.getPrincipal());
verifyNoMoreInteractions(nativeSession);
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:24，代码来源:JettyWebSocketSessionTests.java
示例2: getPrincipalNotAvailable
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Test
public void getPrincipalNotAvailable() {
UpgradeRequest request = Mockito.mock(UpgradeRequest.class);
given(request.getUserPrincipal()).willReturn(null);
UpgradeResponse response = Mockito.mock(UpgradeResponse.class);
given(response.getAcceptedSubProtocol()).willReturn(null);
Session nativeSession = Mockito.mock(Session.class);
given(nativeSession.getUpgradeRequest()).willReturn(request);
given(nativeSession.getUpgradeResponse()).willReturn(response);
JettyWebSocketSession session = new JettyWebSocketSession(attributes);
session.initializeNativeSession(nativeSession);
reset(nativeSession);
assertNull(session.getPrincipal());
verifyNoMoreInteractions(nativeSession);
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:22，代码来源:JettyWebSocketSessionTests.java
示例3: getAcceptedProtocol
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Test
public void getAcceptedProtocol() {
String protocol = "foo";
UpgradeRequest request = Mockito.mock(UpgradeRequest.class);
given(request.getUserPrincipal()).willReturn(null);
UpgradeResponse response = Mockito.mock(UpgradeResponse.class);
given(response.getAcceptedSubProtocol()).willReturn(protocol);
Session nativeSession = Mockito.mock(Session.class);
given(nativeSession.getUpgradeRequest()).willReturn(request);
given(nativeSession.getUpgradeResponse()).willReturn(response);
JettyWebSocketSession session = new JettyWebSocketSession(attributes);
session.initializeNativeSession(nativeSession);
reset(nativeSession);
assertSame(protocol, session.getAcceptedProtocol());
verifyNoMoreInteractions(nativeSession);
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:24，代码来源:JettyWebSocketSessionTests.java
示例4: createWebSocket
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Override
public Object createWebSocket(UpgradeRequest request, UpgradeResponse response) {
// Validate and use "guacamole" subprotocol
for (String subprotocol : request.getSubProtocols()) {
if ("guacamole".equals(subprotocol)) {
response.setAcceptedSubProtocol(subprotocol);
return new RestrictedGuacamoleWebSocketTunnelListener(tunnelRequestService);
}
}
// Invalid protocol
return null;
}
开发者ID:apache，项目名称:guacamole-client，代码行数:18，代码来源:RestrictedGuacamoleWebSocketCreator.java
示例5: invoke
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
public ValidateUpgradeRequest invoke() {
UpgradeRequest request = session.getUpgradeRequest();
URI uri = request.getRequestURI();
path = uri.getPath();
Map<String, List<String>> params = request.getParameterMap();
List<String> watch = params.get("watch");
LOG.debug("path: {}", path);
if (watch == null || watch.size() != 1) {
session.close(0, " must specify watch parameter when connecting via websocket");
myResult = true;
return this;
}
if (!watch.get(0).equalsIgnoreCase("true")) {
session.close(0, " must specify watch parameter equal to 'true' when connecting via websocket");
myResult = true;
return this;
}
myResult = false;
return this;
}
开发者ID:fabric8io，项目名称:jube，代码行数:21，代码来源:WatchWebSocket.java
示例6: setup
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Before
public void setup() {
this.session = mock(Session.class);
given(this.session.getUpgradeRequest()).willReturn(Mockito.mock(UpgradeRequest.class));
given(this.session.getUpgradeResponse()).willReturn(Mockito.mock(UpgradeResponse.class));
this.webSocketHandler = mock(WebSocketHandler.class);
this.webSocketSession = new JettyWebSocketSession(null, null);
this.adapter = new JettyWebSocketHandlerAdapter(this.webSocketHandler, this.webSocketSession);
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:11，代码来源:JettyWebSocketHandlerAdapterTests.java
示例7: configure
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Override
public void configure(WebSocketServletFactory factory) {
// Most implementations of this method simply invoke factory.register(DispatchSocket.class);
// however, that requires DispatchSocket to have a no-arg constructor. That does not work for
// us because we would like all WebSockets created by this factory to have a reference to this
// parent class. This is why we override the default WebSocketCreator for the factory.
WebSocketCreator wrapperCreator = new WebSocketCreator() {
@Override
public Object createWebSocket(UpgradeRequest req, UpgradeResponse resp) {
return new MyWebSocket();
}
};
factory.setCreator(wrapperCreator);
}
开发者ID:saleehk，项目名称:buck-cutom，代码行数:15，代码来源:StreamingWebSocketServlet.java
示例8: parseStartLine
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
private long parseStartLine(UpgradeRequest request) {
Optional<NameValuePair> startLine = URLEncodedUtils.parse(request.getRequestURI(), "UTF-8").
stream().
filter(new Predicate<NameValuePair>() {
@Override
public boolean test(NameValuePair pair) {
return "startLine".equals(pair.getName());
}
}).findFirst();
return startLine.isPresent() ? Long.valueOf(startLine.get().getValue()) : 0L;
}
开发者ID:gocd，项目名称:gocd，代码行数:13，代码来源:ConsoleLogSocket.java
示例9: createWebSocket
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Override
public Object createWebSocket(UpgradeRequest req, UpgradeResponse resp) {
System.out.println(".. "+req.getRequestURI().getPath());
String path = req.getRequestURI().getPath(),
name = path.substring(path.lastIndexOf('/')+1);
try {
Class<?> clazz = Class.forName("jforex.jetty."+name.substring(0, 1).toUpperCase() + name.substring(1)+"Strategy");
Object strat = null;
for (Entry<Long, IStrategy> e : WebServer.pids.entrySet()){
if (clazz.equals(e.getValue().getClass())){
strat = e.getValue();
}
}
// if not started, start it now
if (strat ==null){
Constructor<?> ctor = clazz.getConstructor();
strat = ctor.newInstance();
long pid = ClientFactory.getDefaultInstance().startStrategy((IStrategy) strat);
WebServer.pids.put(pid, (IStrategy) strat);
}
return strat;
} catch (ClassNotFoundException | SecurityException | IllegalArgumentException | NoSuchMethodException | InstantiationException | IllegalAccessException | InvocationTargetException e1) {
e1.printStackTrace();
}
return null;
}
开发者ID:caub，项目名称:JForexJetty，代码行数:32，代码来源:WsServlet.java
示例10: getHttpRequest
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
private HttpServletRequest getHttpRequest(UpgradeRequest request) {
try {
return (HttpServletRequest) requestField.get(request);
} catch (Exception e) {
throw new IllegalStateException("Could not get HTTP request from field", e);
}
}
开发者ID:wigforss，项目名称:Ka-Websocket，代码行数:8，代码来源:Jetty9WebsocketCreator.java
示例11: configure
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Override
public void configure(WebSocketServletFactory factory) {
factory.getPolicy().setIdleTimeout(10000);
factory.setCreator(new WebSocketCreator() {
@Override
public Object createWebSocket(UpgradeRequest req, UpgradeResponse resp) {
return new DrogonLoggerSocket( getWebLoggerModule( ) );
}
});
}
开发者ID:joemonti，项目名称:drogon-master，代码行数:11，代码来源:DrogonLoggerServlet.java
示例12: getUpgradeRequest
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
@Override
public UpgradeRequest getUpgradeRequest() {
return null;
}
开发者ID:facebook，项目名称:buck，代码行数:5，代码来源:MockSession.java
示例13: WebSocketTunnelRequest
import org.eclipse.jetty.websocket.api.UpgradeRequest; //导入依赖的package包/类
/**
* Creates a TunnelRequest implementation which delegates parameter and
* session retrieval to the given UpgradeRequest.
*
* @param request The UpgradeRequest to wrap.
*/
public WebSocketTunnelRequest(UpgradeRequest request) {
this.handshakeParameters = request.getParameterMap();
}
开发者ID:apache，项目名称:guacamole-client，代码行数:10，代码来源:WebSocketTunnelRequest.java
注：本文中的org.eclipse.jetty.websocket.api.UpgradeRequest类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论