Issue #3129 - refactor of javax websocket package names

Signed-off-by: Lachlan Roberts <lachlan@webtide.com>
This commit is contained in:
Lachlan Roberts 2018-11-29 17:28:48 +01:00
parent aeb200e583
commit e8ba030904
380 changed files with 836 additions and 838 deletions

View File

@ -25,7 +25,7 @@ import javax.websocket.server.ServerEndpoint;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.websocket.jsr356.server.JavaxWebSocketServerContainerInitializer;
import org.eclipse.jetty.websocket.javax.server.JavaxWebSocketServerContainerInitializer;
/**
* Example of setting up a javax.websocket server with Jetty embedded

View File

@ -95,7 +95,7 @@
<Item>org.eclipse.jetty.plus.webapp.EnvConfiguration</Item>
<Item>org.eclipse.jetty.webapp.JmxConfiguration</Item>
<Item>org.eclipse.jetty.websocket.server.JettyWebSocketConfiguration</Item>
<Item>org.eclipse.jetty.websocket.jsr356.JavaxWebSocketExtensionConfig</Item>
<Item>JavaxWebSocketExtensionConfig</Item>
<Item>org.eclipse.jetty.osgi.annotations.AnnotationConfiguration</Item>
<Item>org.eclipse.jetty.osgi.boot.OSGiWebInfConfiguration</Item>
<Item>org.eclipse.jetty.osgi.boot.OSGiMetaInfConfiguration</Item>

View File

@ -82,7 +82,7 @@
<Item>org.eclipse.jetty.plus.webapp.EnvConfiguration</Item>
<Item>org.eclipse.jetty.webapp.JmxConfiguration</Item>
<Item>org.eclipse.jetty.websocket.server.JettyWebSocketConfiguration</Item>
<Item>org.eclipse.jetty.websocket.jsr356.JavaxWebSocketExtensionConfig</Item>
<Item>org.eclipse.jetty.websocket.javax.common.JavaxWebSocketExtensionConfig</Item>
<Item>org.eclipse.jetty.osgi.annotations.AnnotationConfiguration</Item>
<Item>org.eclipse.jetty.osgi.boot.OSGiWebInfConfiguration</Item>
<Item>org.eclipse.jetty.osgi.boot.OSGiMetaInfConfiguration</Item>

View File

@ -86,7 +86,7 @@
<Item>org.eclipse.jetty.plus.webapp.EnvConfiguration</Item>
<Item>org.eclipse.jetty.webapp.JmxConfiguration</Item>
<Item>org.eclipse.jetty.websocket.server.JettyWebSocketConfiguration</Item>
<Item>org.eclipse.jetty.websocket.jsr356.JavaxWebSocketExtensionConfig</Item>
<Item>org.eclipse.jetty.websocket.javax.common.JavaxWebSocketExtensionConfig</Item>
<Item>org.eclipse.jetty.osgi.annotations.AnnotationConfiguration</Item>
<Item>org.eclipse.jetty.osgi.boot.OSGiWebInfConfiguration</Item>
<Item>org.eclipse.jetty.osgi.boot.OSGiMetaInfConfiguration</Item>

View File

@ -18,11 +18,11 @@
import javax.websocket.ContainerProvider;
import org.eclipse.jetty.websocket.jsr356.client.JavaxWebSocketClientContainerProvider;
import org.eclipse.jetty.websocket.javax.client.JavaxWebSocketClientContainerProvider;
module org.eclipse.jetty.websocket.javax.client
{
exports org.eclipse.jetty.websocket.jsr356.client;
exports org.eclipse.jetty.websocket.javax.client;
requires javax.websocket.api;
requires org.eclipse.jetty.util;

View File

@ -16,9 +16,9 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import org.eclipse.jetty.websocket.jsr356.InvalidWebSocketException;
import org.eclipse.jetty.websocket.javax.common.InvalidWebSocketException;
import javax.websocket.ClientEndpoint;
import javax.websocket.ClientEndpointConfig;

View File

@ -16,14 +16,14 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import org.eclipse.jetty.client.HttpResponse;
import org.eclipse.jetty.websocket.core.FrameHandler;
import org.eclipse.jetty.websocket.core.client.WebSocketCoreClient;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketFrameHandler;
import org.eclipse.jetty.websocket.jsr356.UpgradeRequest;
import org.eclipse.jetty.websocket.jsr356.UpgradeResponse;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketFrameHandler;
import org.eclipse.jetty.websocket.javax.common.UpgradeRequest;
import org.eclipse.jetty.websocket.javax.common.UpgradeResponse;
import javax.websocket.Session;
import java.net.URI;

View File

@ -16,9 +16,9 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import org.eclipse.jetty.websocket.jsr356.UpgradeRequest;
import org.eclipse.jetty.websocket.javax.common.UpgradeRequest;
import java.net.URI;
import java.security.Principal;

View File

@ -16,12 +16,12 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import org.eclipse.jetty.client.HttpResponse;
import org.eclipse.jetty.http.HttpHeader;
import org.eclipse.jetty.websocket.core.ExtensionConfig;
import org.eclipse.jetty.websocket.jsr356.UpgradeResponse;
import org.eclipse.jetty.websocket.javax.common.UpgradeResponse;
import java.util.Collections;
import java.util.List;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import javax.websocket.ClientEndpointConfig;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import javax.websocket.ClientEndpointConfig;
import javax.websocket.HandshakeResponse;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import org.eclipse.jetty.client.HttpClient;
import org.eclipse.jetty.io.ByteBufferPool;
@ -24,11 +24,11 @@ import org.eclipse.jetty.util.DecoratedObjectFactory;
import org.eclipse.jetty.util.annotation.ManagedObject;
import org.eclipse.jetty.websocket.core.WebSocketExtensionRegistry;
import org.eclipse.jetty.websocket.core.client.WebSocketCoreClient;
import org.eclipse.jetty.websocket.jsr356.ConfiguredEndpoint;
import org.eclipse.jetty.websocket.jsr356.InvalidWebSocketException;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketContainer;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketExtensionConfig;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketFrameHandlerFactory;
import org.eclipse.jetty.websocket.javax.common.ConfiguredEndpoint;
import org.eclipse.jetty.websocket.javax.common.InvalidWebSocketException;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketContainer;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketExtensionConfig;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketFrameHandlerFactory;
import javax.websocket.ClientEndpoint;
import javax.websocket.ClientEndpointConfig;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import org.eclipse.jetty.util.component.LifeCycle;
import org.eclipse.jetty.util.thread.ShutdownThread;

View File

@ -16,12 +16,12 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketContainer;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketFrameHandlerFactory;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketFrameHandlerMetadata;
import org.eclipse.jetty.websocket.jsr356.util.InvokerUtils;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketContainer;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketFrameHandlerFactory;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketFrameHandlerMetadata;
import org.eclipse.jetty.websocket.javax.common.util.InvokerUtils;
import javax.websocket.ClientEndpoint;
import javax.websocket.Endpoint;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.client;
package org.eclipse.jetty.websocket.javax.client;
import org.eclipse.jetty.client.HttpRequest;
import org.eclipse.jetty.client.HttpResponse;

View File

@ -1 +1 @@
org.eclipse.jetty.websocket.jsr356.client.JavaxWebSocketClientContainerProvider
org.eclipse.jetty.websocket.javax.client.JavaxWebSocketClientContainerProvider

View File

@ -18,11 +18,11 @@
module org.eclipse.jetty.websocket.javax.common
{
exports org.eclipse.jetty.websocket.jsr356;
exports org.eclipse.jetty.websocket.jsr356.decoders;
exports org.eclipse.jetty.websocket.jsr356.encoders;
exports org.eclipse.jetty.websocket.jsr356.messages;
exports org.eclipse.jetty.websocket.jsr356.util;
exports org.eclipse.jetty.websocket.javax.common;
exports org.eclipse.jetty.websocket.javax.common.decoders;
exports org.eclipse.jetty.websocket.javax.common.encoders;
exports org.eclipse.jetty.websocket.javax.common.messages;
exports org.eclipse.jetty.websocket.javax.common.util;
requires javax.websocket.api;
requires org.eclipse.jetty.util;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import javax.websocket.Decoder;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.util.log.Log;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import javax.websocket.EndpointConfig;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
/**
* Thrown when a duplicate coder is encountered when attempting to identify a Endpoint's metadata ({@link javax.websocket.Decoder} or {@link javax.websocket.Encoder})

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
/**
* Exception during initialization of the Endpoint

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.websocket.core.WebSocketException;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.FutureCallback;
@ -25,9 +25,9 @@ import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.core.FrameHandler;
import org.eclipse.jetty.websocket.core.OpCode;
import org.eclipse.jetty.websocket.jsr356.messages.MessageOutputStream;
import org.eclipse.jetty.websocket.jsr356.messages.MessageWriter;
import org.eclipse.jetty.websocket.jsr356.util.TextUtil;
import org.eclipse.jetty.websocket.javax.common.messages.MessageOutputStream;
import org.eclipse.jetty.websocket.javax.common.messages.MessageWriter;
import org.eclipse.jetty.websocket.javax.common.util.TextUtil;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.SharedBlockingCallback;
@ -25,7 +25,7 @@ import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.core.FrameHandler;
import org.eclipse.jetty.websocket.core.OpCode;
import org.eclipse.jetty.websocket.jsr356.util.TextUtil;
import org.eclipse.jetty.websocket.javax.common.util.TextUtil;
import javax.websocket.EncodeException;
import javax.websocket.RemoteEndpoint;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.io.ByteBufferPool;
import org.eclipse.jetty.util.DecoratedObjectFactory;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.websocket.core.ExtensionConfig;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.websocket.core.ExtensionConfig;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
@ -29,15 +29,15 @@ import org.eclipse.jetty.websocket.core.OpCode;
import org.eclipse.jetty.websocket.core.ProtocolException;
import org.eclipse.jetty.websocket.core.WebSocketConstants;
import org.eclipse.jetty.websocket.core.WebSocketException;
import org.eclipse.jetty.websocket.jsr356.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedBinaryMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedBinaryStreamMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedTextMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedTextStreamMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.PartialByteArrayMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.PartialByteBufferMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.PartialStringMessageSink;
import org.eclipse.jetty.websocket.jsr356.util.InvokerUtils;
import org.eclipse.jetty.websocket.javax.common.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedBinaryMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedBinaryStreamMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedTextMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedTextStreamMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.PartialByteArrayMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.PartialByteBufferMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.PartialStringMessageSink;
import org.eclipse.jetty.websocket.javax.common.util.InvokerUtils;
import javax.websocket.CloseReason;
import javax.websocket.Decoder;
@ -57,8 +57,6 @@ import java.util.Set;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
import static org.eclipse.jetty.websocket.jsr356.JavaxWebSocketFrameHandlerMetadata.MessageMetadata;
public class JavaxWebSocketFrameHandler implements FrameHandler
{
private final Logger LOG;
@ -94,8 +92,8 @@ public class JavaxWebSocketFrameHandler implements FrameHandler
private MethodHandle openHandle;
private MethodHandle closeHandle;
private MethodHandle errorHandle;
private MessageMetadata textMetadata;
private MessageMetadata binaryMetadata;
private JavaxWebSocketFrameHandlerMetadata.MessageMetadata textMetadata;
private JavaxWebSocketFrameHandlerMetadata.MessageMetadata binaryMetadata;
// TODO: need pingHandle ?
private MethodHandle pongHandle;
/**
@ -124,8 +122,8 @@ public class JavaxWebSocketFrameHandler implements FrameHandler
Object endpointInstance,
UpgradeRequest upgradeRequest, UpgradeResponse upgradeResponse,
MethodHandle openHandle, MethodHandle closeHandle, MethodHandle errorHandle,
MessageMetadata textMetadata,
MessageMetadata binaryMetadata,
JavaxWebSocketFrameHandlerMetadata.MessageMetadata textMetadata,
JavaxWebSocketFrameHandlerMetadata.MessageMetadata binaryMetadata,
MethodHandle pongHandle,
String id,
EndpointConfig endpointConfig,
@ -245,8 +243,8 @@ public class JavaxWebSocketFrameHandler implements FrameHandler
closeHandle = InvokerUtils.bindTo(closeHandle, session);
errorHandle = InvokerUtils.bindTo(errorHandle, session);
MessageMetadata actualTextMetadata = MessageMetadata.copyOf(textMetadata);
MessageMetadata actualBinaryMetadata = MessageMetadata.copyOf(binaryMetadata);
JavaxWebSocketFrameHandlerMetadata.MessageMetadata actualTextMetadata = JavaxWebSocketFrameHandlerMetadata.MessageMetadata.copyOf(textMetadata);
JavaxWebSocketFrameHandlerMetadata.MessageMetadata actualBinaryMetadata = JavaxWebSocketFrameHandlerMetadata.MessageMetadata.copyOf(binaryMetadata);
pongHandle = InvokerUtils.bindTo(pongHandle, session);
@ -333,12 +331,12 @@ public class JavaxWebSocketFrameHandler implements FrameHandler
return messageHandlerMap;
}
public MessageMetadata getBinaryMetadata()
public JavaxWebSocketFrameHandlerMetadata.MessageMetadata getBinaryMetadata()
{
return binaryMetadata;
}
public MessageMetadata getTextMetadata()
public JavaxWebSocketFrameHandlerMetadata.MessageMetadata getTextMetadata()
{
return textMetadata;
}
@ -368,7 +366,7 @@ public class JavaxWebSocketFrameHandler implements FrameHandler
assertBasicTypeNotRegistered(OpCode.BINARY, this.binaryMetadata, handler.getClass().getName());
MessageSink messageSink = new PartialByteArrayMessageSink(session, partialMessageHandler);
this.binarySink = registerMessageHandler(OpCode.BINARY, clazz, handler, messageSink);
MessageMetadata metadata = new MessageMetadata();
JavaxWebSocketFrameHandlerMetadata.MessageMetadata metadata = new JavaxWebSocketFrameHandlerMetadata.MessageMetadata();
metadata.handle = partialMessageHandler;
metadata.sinkClass = PartialByteArrayMessageSink.class;
this.binaryMetadata = metadata;
@ -378,7 +376,7 @@ public class JavaxWebSocketFrameHandler implements FrameHandler
assertBasicTypeNotRegistered(OpCode.BINARY, this.binaryMetadata, handler.getClass().getName());
MessageSink messageSink = new PartialByteBufferMessageSink(session, partialMessageHandler);
this.binarySink = registerMessageHandler(OpCode.BINARY, clazz, handler, messageSink);
MessageMetadata metadata = new MessageMetadata();
JavaxWebSocketFrameHandlerMetadata.MessageMetadata metadata = new JavaxWebSocketFrameHandlerMetadata.MessageMetadata();
metadata.handle = partialMessageHandler;
metadata.sinkClass = PartialByteBufferMessageSink.class;
this.binaryMetadata = metadata;
@ -388,7 +386,7 @@ public class JavaxWebSocketFrameHandler implements FrameHandler
assertBasicTypeNotRegistered(OpCode.TEXT, this.textMetadata, handler.getClass().getName());
MessageSink messageSink = new PartialStringMessageSink(session, partialMessageHandler);
this.textSink = registerMessageHandler(OpCode.TEXT, clazz, handler, messageSink);
MessageMetadata metadata = new MessageMetadata();
JavaxWebSocketFrameHandlerMetadata.MessageMetadata metadata = new JavaxWebSocketFrameHandlerMetadata.MessageMetadata();
metadata.handle = partialMessageHandler;
metadata.sinkClass = PartialStringMessageSink.class;
this.textMetadata = metadata;
@ -435,7 +433,7 @@ public class JavaxWebSocketFrameHandler implements FrameHandler
throw new IllegalStateException("Unable to find Decoder for type: " + clazz);
}
MessageMetadata metadata = new MessageMetadata();
JavaxWebSocketFrameHandlerMetadata.MessageMetadata metadata = new JavaxWebSocketFrameHandlerMetadata.MessageMetadata();
metadata.handle = wholeMsgMethodHandle;
metadata.registeredDecoder = registeredDecoder;

View File

@ -16,26 +16,26 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.http.pathmap.UriTemplatePathSpec;
import org.eclipse.jetty.websocket.jsr356.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.jsr356.messages.ByteArrayMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.ByteBufferMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedBinaryMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedBinaryStreamMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedTextMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.DecodedTextStreamMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.InputStreamMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.PartialByteArrayMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.PartialByteBufferMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.PartialStringMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.ReaderMessageSink;
import org.eclipse.jetty.websocket.jsr356.messages.StringMessageSink;
import org.eclipse.jetty.websocket.jsr356.util.InvalidSignatureException;
import org.eclipse.jetty.websocket.jsr356.util.InvokerUtils;
import org.eclipse.jetty.websocket.jsr356.util.ReflectUtils;
import org.eclipse.jetty.websocket.javax.common.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.javax.common.messages.ByteArrayMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.ByteBufferMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedBinaryMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedBinaryStreamMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedTextMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.DecodedTextStreamMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.InputStreamMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.PartialByteArrayMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.PartialByteBufferMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.PartialStringMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.ReaderMessageSink;
import org.eclipse.jetty.websocket.javax.common.messages.StringMessageSink;
import org.eclipse.jetty.websocket.javax.common.util.InvalidSignatureException;
import org.eclipse.jetty.websocket.javax.common.util.InvokerUtils;
import org.eclipse.jetty.websocket.javax.common.util.ReflectUtils;
import javax.websocket.CloseReason;
import javax.websocket.Decoder;
@ -63,8 +63,7 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
import static java.nio.charset.StandardCharsets.UTF_8;
import static org.eclipse.jetty.websocket.jsr356.JavaxWebSocketFrameHandlerMetadata.MessageMetadata;
import static org.eclipse.jetty.websocket.jsr356.util.InvokerUtils.Arg;
import static org.eclipse.jetty.websocket.javax.common.JavaxWebSocketFrameHandlerMetadata.MessageMetadata;
public abstract class JavaxWebSocketFrameHandlerFactory
{
@ -396,8 +395,8 @@ public abstract class JavaxWebSocketFrameHandlerFactory
if (onmethod != null)
{
assertSignatureValid(endpointClass, onmethod, OnOpen.class);
final Arg SESSION = new Arg(Session.class);
final Arg ENDPOINT_CONFIG = new Arg(EndpointConfig.class);
final InvokerUtils.Arg SESSION = new InvokerUtils.Arg(Session.class);
final InvokerUtils.Arg ENDPOINT_CONFIG = new InvokerUtils.Arg(EndpointConfig.class);
MethodHandle methodHandle = InvokerUtils
.mutatedInvoker(endpointClass, onmethod, paramIdentifier, metadata.getNamedTemplateVariables(), SESSION, ENDPOINT_CONFIG);
metadata.setOpenHandler(methodHandle, onmethod);
@ -408,8 +407,8 @@ public abstract class JavaxWebSocketFrameHandlerFactory
if (onmethod != null)
{
assertSignatureValid(endpointClass, onmethod, OnClose.class);
final Arg SESSION = new Arg(Session.class);
final Arg CLOSE_REASON = new Arg(CloseReason.class);
final InvokerUtils.Arg SESSION = new InvokerUtils.Arg(Session.class);
final InvokerUtils.Arg CLOSE_REASON = new InvokerUtils.Arg(CloseReason.class);
MethodHandle methodHandle = InvokerUtils
.mutatedInvoker(endpointClass, onmethod, paramIdentifier, metadata.getNamedTemplateVariables(), SESSION, CLOSE_REASON);
metadata.setCloseHandler(methodHandle, onmethod);
@ -419,8 +418,8 @@ public abstract class JavaxWebSocketFrameHandlerFactory
if (onmethod != null)
{
assertSignatureValid(endpointClass, onmethod, OnError.class);
final Arg SESSION = new Arg(Session.class);
final Arg CAUSE = new Arg(Throwable.class).required();
final InvokerUtils.Arg SESSION = new InvokerUtils.Arg(Session.class);
final InvokerUtils.Arg CAUSE = new InvokerUtils.Arg(Throwable.class).required();
MethodHandle methodHandle = InvokerUtils
.mutatedInvoker(endpointClass, onmethod, paramIdentifier, metadata.getNamedTemplateVariables(), SESSION, CAUSE);
metadata.setErrorHandler(methodHandle, onmethod);
@ -431,52 +430,52 @@ public abstract class JavaxWebSocketFrameHandlerFactory
if (onMessages != null && onMessages.length > 0)
{
// The different kind of @OnMessage method parameter signatures expected
Arg textCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(String.class).required()
InvokerUtils.Arg textCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(String.class).required()
};
Arg textPartialCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(String.class).required(),
new Arg(boolean.class).required()
InvokerUtils.Arg textPartialCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(String.class).required(),
new InvokerUtils.Arg(boolean.class).required()
};
Arg binaryBufferCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(ByteBuffer.class).required()
InvokerUtils.Arg binaryBufferCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(ByteBuffer.class).required()
};
Arg binaryPartialBufferCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(ByteBuffer.class).required(),
new Arg(boolean.class).required()
InvokerUtils.Arg binaryPartialBufferCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(ByteBuffer.class).required(),
new InvokerUtils.Arg(boolean.class).required()
};
Arg binaryArrayCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(byte[].class).required()
InvokerUtils.Arg binaryArrayCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(byte[].class).required()
};
Arg binaryPartialArrayCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(byte[].class).required(),
new Arg(boolean.class).required()
InvokerUtils.Arg binaryPartialArrayCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(byte[].class).required(),
new InvokerUtils.Arg(boolean.class).required()
};
Arg inputStreamCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(InputStream.class).required()
InvokerUtils.Arg inputStreamCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(InputStream.class).required()
};
Arg readerCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(Reader.class).required()
InvokerUtils.Arg readerCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(Reader.class).required()
};
Arg pongCallingArgs[] = new Arg[] {
new Arg(Session.class),
new Arg(PongMessage.class).required()
InvokerUtils.Arg pongCallingArgs[] = new InvokerUtils.Arg[] {
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(PongMessage.class).required()
};
List<DecodedArgs> decodedTextCallingArgs = new ArrayList<>();
@ -490,8 +489,8 @@ public abstract class JavaxWebSocketFrameHandlerFactory
{
decodedTextCallingArgs.add(
new DecodedArgs(decoder,
new Arg(Session.class),
new Arg(decoder.objectType).required()
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(decoder.objectType).required()
));
}
@ -499,8 +498,8 @@ public abstract class JavaxWebSocketFrameHandlerFactory
{
decodedTextStreamCallingArgs.add(
new DecodedArgs(decoder,
new Arg(Session.class),
new Arg(decoder.objectType).required()
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(decoder.objectType).required()
));
}
@ -508,8 +507,8 @@ public abstract class JavaxWebSocketFrameHandlerFactory
{
decodedBinaryCallingArgs.add(
new DecodedArgs(decoder,
new Arg(Session.class),
new Arg(decoder.objectType).required()
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(decoder.objectType).required()
));
}
@ -517,8 +516,8 @@ public abstract class JavaxWebSocketFrameHandlerFactory
{
decodedBinaryStreamCallingArgs.add(
new DecodedArgs(decoder,
new Arg(Session.class),
new Arg(decoder.objectType).required()
new InvokerUtils.Arg(Session.class),
new InvokerUtils.Arg(decoder.objectType).required()
));
}
}
@ -767,9 +766,9 @@ public abstract class JavaxWebSocketFrameHandlerFactory
private static class DecodedArgs
{
public final AvailableDecoders.RegisteredDecoder registeredDecoder;
public final Arg[] args;
public final InvokerUtils.Arg[] args;
public DecodedArgs(AvailableDecoders.RegisteredDecoder registeredDecoder, Arg... args)
public DecodedArgs(AvailableDecoders.RegisteredDecoder registeredDecoder, InvokerUtils.Arg... args)
{
this.registeredDecoder = registeredDecoder;
this.args = args;

View File

@ -16,11 +16,11 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.http.pathmap.UriTemplatePathSpec;
import org.eclipse.jetty.websocket.jsr356.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.jsr356.encoders.AvailableEncoders;
import org.eclipse.jetty.websocket.javax.common.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.javax.common.encoders.AvailableEncoders;
import javax.websocket.Decoder;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.BufferUtil;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
@ -28,8 +28,8 @@ import org.eclipse.jetty.websocket.core.FrameHandler;
import org.eclipse.jetty.websocket.core.OpCode;
import org.eclipse.jetty.websocket.core.OutgoingFrames;
import org.eclipse.jetty.websocket.core.WebSocketException;
import org.eclipse.jetty.websocket.jsr356.messages.MessageOutputStream;
import org.eclipse.jetty.websocket.jsr356.messages.MessageWriter;
import org.eclipse.jetty.websocket.javax.common.messages.MessageOutputStream;
import org.eclipse.jetty.websocket.javax.common.messages.MessageWriter;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.SharedBlockingCallback;
import org.eclipse.jetty.util.component.AbstractLifeCycle;
@ -24,9 +24,9 @@ import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.core.ExtensionConfig;
import org.eclipse.jetty.websocket.core.FrameHandler;
import org.eclipse.jetty.websocket.jsr356.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.jsr356.encoders.AvailableEncoders;
import org.eclipse.jetty.websocket.jsr356.util.ReflectUtils;
import org.eclipse.jetty.websocket.javax.common.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.javax.common.encoders.AvailableEncoders;
import org.eclipse.jetty.websocket.javax.common.util.ReflectUtils;
import javax.websocket.CloseReason;
import javax.websocket.EndpointConfig;
@ -37,7 +37,6 @@ import javax.websocket.RemoteEndpoint.Basic;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;
import java.io.IOException;
import java.lang.invoke.MethodHandle;
import java.net.URI;
import java.security.Principal;
import java.time.Duration;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import java.net.URI;
import java.util.List;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.websocket.core.ExtensionConfig;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.websocket.core.Frame;

View File

@ -16,13 +16,13 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import java.util.Map;
/**
* Optional interface for custom {@link javax.websocket.EndpointConfig} implementations
* in Jetty to expose Path Param values used during the {@link org.eclipse.jetty.websocket.jsr356.JavaxWebSocketFrameHandler}
* in Jetty to expose Path Param values used during the {@link JavaxWebSocketFrameHandler}
* resolution of methods.
* <p>
* Mostly a feature of the JSR356 Server implementation and its {@code &#064;javax.websocket.server.PathParam} annotation.

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import javax.websocket.MessageHandler;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.util.Callback;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import java.net.URI;
import java.security.Principal;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import java.net.URI;
import java.security.Principal;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.websocket.core.ExtensionConfig;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import org.eclipse.jetty.websocket.core.ExtensionConfig;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.Decoder;
import javax.websocket.EndpointConfig;

View File

@ -16,12 +16,12 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import org.eclipse.jetty.websocket.jsr356.InitException;
import org.eclipse.jetty.websocket.jsr356.InvalidWebSocketException;
import org.eclipse.jetty.websocket.jsr356.util.InvalidSignatureException;
import org.eclipse.jetty.websocket.jsr356.util.ReflectUtils;
import org.eclipse.jetty.websocket.javax.common.InitException;
import org.eclipse.jetty.websocket.javax.common.InvalidWebSocketException;
import org.eclipse.jetty.websocket.javax.common.util.InvalidSignatureException;
import org.eclipse.jetty.websocket.javax.common.util.ReflectUtils;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import org.eclipse.jetty.util.BufferUtil;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import org.eclipse.jetty.util.BufferUtil;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.decoders;
package org.eclipse.jetty.websocket.javax.common.decoders;
import javax.websocket.DecodeException;
import javax.websocket.Decoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.Encoder;
import javax.websocket.EndpointConfig;

View File

@ -16,12 +16,12 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import org.eclipse.jetty.websocket.jsr356.InitException;
import org.eclipse.jetty.websocket.jsr356.InvalidWebSocketException;
import org.eclipse.jetty.websocket.jsr356.util.InvalidSignatureException;
import org.eclipse.jetty.websocket.jsr356.util.ReflectUtils;
import org.eclipse.jetty.websocket.javax.common.InitException;
import org.eclipse.jetty.websocket.javax.common.InvalidWebSocketException;
import org.eclipse.jetty.websocket.javax.common.util.InvalidSignatureException;
import org.eclipse.jetty.websocket.javax.common.util.ReflectUtils;
import javax.websocket.Encoder;
import javax.websocket.EndpointConfig;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.Encoder;
import java.util.concurrent.ExecutionException;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.encoders;
package org.eclipse.jetty.websocket.javax.common.encoders;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;

View File

@ -16,10 +16,10 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import java.lang.invoke.MethodHandle;
import java.util.Objects;

View File

@ -16,14 +16,14 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.core.MessageTooLargeException;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.util.InvalidSignatureException;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.util.InvalidSignatureException;
import java.io.ByteArrayOutputStream;
import java.lang.invoke.MethodHandle;

View File

@ -16,13 +16,13 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.core.MessageTooLargeException;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import java.io.ByteArrayOutputStream;
import java.lang.invoke.MethodHandle;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;

View File

@ -16,11 +16,11 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.websocket.core.CloseException;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import javax.websocket.CloseReason;
import javax.websocket.DecodeException;

View File

@ -16,11 +16,11 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.websocket.core.CloseException;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import javax.websocket.CloseReason;
import javax.websocket.DecodeException;

View File

@ -16,14 +16,14 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import javax.websocket.Decoder;
import java.lang.invoke.MethodHandle;

View File

@ -16,11 +16,11 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.websocket.core.CloseException;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import javax.websocket.CloseReason;
import javax.websocket.DecodeException;

View File

@ -16,11 +16,11 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.websocket.core.CloseException;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import javax.websocket.CloseReason;
import javax.websocket.DecodeException;

View File

@ -16,12 +16,12 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import java.lang.invoke.MethodHandle;
import java.util.Objects;

View File

@ -16,11 +16,11 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import java.io.InputStream;
import java.lang.invoke.MethodHandle;

View File

@ -16,14 +16,14 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import java.io.IOException;
import java.io.InputStream;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.io.ByteBufferPool;
import org.eclipse.jetty.util.BufferUtil;

View File

@ -16,11 +16,11 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.MessageSink;
import org.eclipse.jetty.websocket.javax.common.MessageSink;
import java.io.InputStreamReader;
import java.nio.charset.StandardCharsets;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;

View File

@ -16,13 +16,13 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.jsr356.util.InvalidSignatureException;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.util.InvalidSignatureException;
import java.lang.invoke.MethodHandle;
import java.lang.invoke.MethodType;

View File

@ -16,12 +16,12 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import java.lang.invoke.MethodHandle;
import java.nio.ByteBuffer;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
@ -24,7 +24,7 @@ import org.eclipse.jetty.util.Utf8StringBuilder;
import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import java.lang.invoke.MethodHandle;
import java.nio.ByteBuffer;

View File

@ -16,10 +16,10 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import java.io.Reader;
import java.lang.invoke.MethodHandle;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.messages;
package org.eclipse.jetty.websocket.javax.common.messages;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
@ -25,7 +25,7 @@ import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.core.Frame;
import org.eclipse.jetty.websocket.core.MessageTooLargeException;
import org.eclipse.jetty.websocket.jsr356.JavaxWebSocketSession;
import org.eclipse.jetty.websocket.javax.common.JavaxWebSocketSession;
import java.lang.invoke.MethodHandle;
import java.nio.ByteBuffer;

View File

@ -16,9 +16,9 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.util;
package org.eclipse.jetty.websocket.javax.common.util;
import org.eclipse.jetty.websocket.jsr356.InvalidWebSocketException;
import org.eclipse.jetty.websocket.javax.common.InvalidWebSocketException;
import java.lang.annotation.Annotation;
import java.lang.reflect.Method;

View File

@ -16,9 +16,9 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.util;
package org.eclipse.jetty.websocket.javax.common.util;
import org.eclipse.jetty.websocket.jsr356.InvalidWebSocketException;
import org.eclipse.jetty.websocket.javax.common.InvalidWebSocketException;
import java.lang.annotation.Annotation;
import java.lang.invoke.MethodType;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.util;
package org.eclipse.jetty.websocket.javax.common.util;
import java.lang.invoke.MethodHandle;
import java.lang.invoke.MethodHandles;

View File

@ -16,9 +16,9 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.util;
package org.eclipse.jetty.websocket.javax.common.util;
import org.eclipse.jetty.websocket.jsr356.InvalidWebSocketException;
import org.eclipse.jetty.websocket.javax.common.InvalidWebSocketException;
import java.lang.annotation.Annotation;
import java.lang.invoke.MethodType;

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356.util;
package org.eclipse.jetty.websocket.javax.common.util;
/**
* Collection of utility methods for Text content

View File

@ -16,7 +16,7 @@
// ========================================================================
//
package org.eclipse.jetty.websocket.jsr356;
package org.eclipse.jetty.websocket.javax.common;
import java.util.HashMap;
import java.util.Map;
@ -25,8 +25,8 @@ import java.util.concurrent.CompletableFuture;
import javax.websocket.EndpointConfig;
import org.eclipse.jetty.websocket.core.FrameHandler;
import org.eclipse.jetty.websocket.jsr356.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.jsr356.encoders.AvailableEncoders;
import org.eclipse.jetty.websocket.javax.common.decoders.AvailableDecoders;
import org.eclipse.jetty.websocket.javax.common.encoders.AvailableEncoders;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;

Some files were not shown because too many files have changed in this diff Show More