diff options
Diffstat (limited to 'jetty-websocket/javax-websocket-client-impl/src/main/java/org/eclipse/jetty/websocket/jsr356/annotations/JsrParamIdText.java')
| -rw-r--r-- | jetty-websocket/javax-websocket-client-impl/src/main/java/org/eclipse/jetty/websocket/jsr356/annotations/JsrParamIdText.java | 160 |
1 files changed, 160 insertions, 0 deletions
diff --git a/jetty-websocket/javax-websocket-client-impl/src/main/java/org/eclipse/jetty/websocket/jsr356/annotations/JsrParamIdText.java b/jetty-websocket/javax-websocket-client-impl/src/main/java/org/eclipse/jetty/websocket/jsr356/annotations/JsrParamIdText.java new file mode 100644 index 0000000000..d7eb8f9cb6 --- /dev/null +++ b/jetty-websocket/javax-websocket-client-impl/src/main/java/org/eclipse/jetty/websocket/jsr356/annotations/JsrParamIdText.java @@ -0,0 +1,160 @@ +// +// ======================================================================== +// Copyright (c) 1995-2013 Mort Bay Consulting Pty. Ltd. +// ------------------------------------------------------------------------ +// All rights reserved. This program and the accompanying materials +// are made available under the terms of the Eclipse Public License v1.0 +// and Apache License v2.0 which accompanies this distribution. +// +// The Eclipse Public License is available at +// http://www.eclipse.org/legal/epl-v10.html +// +// The Apache License v2.0 is available at +// http://www.opensource.org/licenses/apache2.0.php +// +// You may elect to redistribute this code under either of these licenses. +// ======================================================================== +// + +package org.eclipse.jetty.websocket.jsr356.annotations; + +import java.io.Reader; + +import javax.websocket.OnMessage; + +import org.eclipse.jetty.websocket.common.events.annotated.InvalidSignatureException; +import org.eclipse.jetty.websocket.jsr356.annotations.Param.Role; +import org.eclipse.jetty.websocket.jsr356.decoders.BooleanDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.ByteDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.CharacterDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.DoubleDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.FloatDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.IntegerDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.LongDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.ReaderDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.ShortDecoder; +import org.eclipse.jetty.websocket.jsr356.decoders.StringDecoder; + +/** + * Param handling for static Text @{@link OnMessage} parameters + */ +public class JsrParamIdText extends JsrParamIdOnMessage implements IJsrParamId +{ + public static final IJsrParamId INSTANCE = new JsrParamIdText(); + + private boolean isMessageRoleAssigned(JsrCallable callable) + { + if (callable instanceof OnMessageCallable) + { + OnMessageCallable onmessage = (OnMessageCallable)callable; + return onmessage.isMessageRoleAssigned(); + } + return false; + } + + @Override + public boolean process(Param param, JsrCallable callable) throws InvalidSignatureException + { + if (super.process(param,callable)) + { + // Found common roles + return true; + } + + // String for whole message + if (param.type.isAssignableFrom(String.class)) + { + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(StringDecoder.class); + return true; + } + + // Java primitive or class equivalent to receive the whole message converted to that type + if (param.type.isAssignableFrom(Boolean.class)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(BooleanDecoder.class); + return true; + } + if (param.type.isAssignableFrom(Byte.class) || (param.type == Byte.TYPE)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(ByteDecoder.class); + return true; + } + if (param.type.isAssignableFrom(Character.class) || (param.type == Character.TYPE)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(CharacterDecoder.class); + return true; + } + if (param.type.isAssignableFrom(Double.class) || (param.type == Double.TYPE)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(DoubleDecoder.class); + return true; + } + if (param.type.isAssignableFrom(Float.class) || (param.type == Float.TYPE)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(FloatDecoder.class); + return true; + } + if (param.type.isAssignableFrom(Integer.class) || (param.type == Integer.TYPE)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(IntegerDecoder.class); + return true; + } + if (param.type.isAssignableFrom(Long.class) || (param.type == Long.TYPE)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(LongDecoder.class); + return true; + } + if (param.type.isAssignableFrom(Short.class) || (param.type == Short.TYPE)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(ShortDecoder.class); + return true; + } + + // Streaming + if (param.type.isAssignableFrom(Reader.class)) + { + assertPartialMessageSupportDisabled(param,callable); + param.bind(Role.MESSAGE_TEXT_STREAM); + callable.setDecoderClass(ReaderDecoder.class); + return true; + } + + /* + * boolean primitive. + * + * can be used for either: 1) a boolean message type 2) a partial message indicator flag + */ + if (param.type == Boolean.TYPE) + { + if (isMessageRoleAssigned(callable)) + { + param.bind(Role.MESSAGE_PARTIAL_FLAG); + } + else + { + param.bind(Role.MESSAGE_TEXT); + callable.setDecoderClass(BooleanDecoder.class); + } + return true; + } + + return false; + } +} |