From f4de9a66ae9de165f27dd2aa5803b536e88db6d8 Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Fri, 7 Sep 2012 06:14:08 +0000 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-4028 - missed adding files in the previous commit git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1381896 13f79535-47bb-0310-9956-ffa450edef68 --- .../transport/wss/WSSTransportTest.java | 46 ++++ activemq-optional/src/test/webapp/stomp.js | 212 ++++++++++++++++++ 2 files changed, 258 insertions(+) create mode 100644 activemq-optional/src/test/java/org/apache/activemq/transport/wss/WSSTransportTest.java create mode 100644 activemq-optional/src/test/webapp/stomp.js diff --git a/activemq-optional/src/test/java/org/apache/activemq/transport/wss/WSSTransportTest.java b/activemq-optional/src/test/java/org/apache/activemq/transport/wss/WSSTransportTest.java new file mode 100644 index 0000000000..13fab43cb9 --- /dev/null +++ b/activemq-optional/src/test/java/org/apache/activemq/transport/wss/WSSTransportTest.java @@ -0,0 +1,46 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.activemq.transport.wss; + +import org.apache.activemq.transport.ws.WSTransportTest; +import org.eclipse.jetty.server.Connector; +import org.eclipse.jetty.server.ssl.SslSocketConnector; +import org.eclipse.jetty.util.ssl.SslContextFactory; + +public class WSSTransportTest extends WSTransportTest { + @Override + protected Connector createJettyConnector() { + SslSocketConnector sslConnector = new SslSocketConnector(); + SslContextFactory contextFactory = sslConnector.getSslContextFactory(); + contextFactory.setKeyStorePath("src/test/resources/server.keystore"); + contextFactory.setKeyStorePassword("password"); + contextFactory.setTrustStore("src/test/resources/client.keystore"); + contextFactory.setTrustStorePassword("password"); + sslConnector.setPort(8080); + return sslConnector; + } + + @Override + protected String getWSConnectorURI() { + return "wss://localhost:61623"; + } + + @Override + protected String getTestURI() { + return "https://localhost:8080/websocket.html#wss://localhost:61623"; + } +} diff --git a/activemq-optional/src/test/webapp/stomp.js b/activemq-optional/src/test/webapp/stomp.js new file mode 100644 index 0000000000..1caa64c1a2 --- /dev/null +++ b/activemq-optional/src/test/webapp/stomp.js @@ -0,0 +1,212 @@ +/** + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the 'License'); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an 'AS IS' BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +(function() { + var Client, Stomp, WebSocketStompMock; + var __hasProp = Object.prototype.hasOwnProperty, __bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; }; + Stomp = { + frame: function(command, headers, body) { + if (headers == null) { + headers = []; + } + if (body == null) { + body = ''; + } + return { + command: command, + headers: headers, + body: body, + id: headers.id, + receipt: headers.receipt, + transaction: headers.transaction, + destination: headers.destination, + subscription: headers.subscription, + error: null, + toString: function() { + var lines, name, value; + lines = [command]; + for (name in headers) { + if (!__hasProp.call(headers, name)) continue; + value = headers[name]; + lines.push("" + name + ":" + value); + } + lines.push('\n' + body); + return lines.join('\n'); + } + }; + }, + unmarshal: function(data) { + var body, chr, command, divider, headerLines, headers, i, idx, line, trim, _ref, _ref2, _ref3; + divider = data.search(/\n\n/); + headerLines = data.substring(0, divider).split('\n'); + command = headerLines.shift(); + headers = {}; + body = ''; + trim = function(str) { + return str.replace(/^\s+/g, '').replace(/\s+$/g, ''); + }; + line = idx = null; + for (i = 0, _ref = headerLines.length; 0 <= _ref ? i < _ref : i > _ref; 0 <= _ref ? i++ : i--) { + line = headerLines[i]; + idx = line.indexOf(':'); + headers[trim(line.substring(0, idx))] = trim(line.substring(idx + 1)); + } + chr = null; + for (i = _ref2 = divider + 2, _ref3 = data.length; _ref2 <= _ref3 ? i < _ref3 : i > _ref3; _ref2 <= _ref3 ? i++ : i--) { + chr = data.charAt(i); + if (chr === '\0') { + break; + } + body += chr; + } + return Stomp.frame(command, headers, body); + }, + marshal: function(command, headers, body) { + return Stomp.frame(command, headers, body).toString() + '\0'; + }, + client: function(url) { + return new Client(url); + } + }; + Client = (function() { + function Client(url) { + this.url = url; + this.counter = 0; + this.connected = false; + this.subscriptions = {}; + } + Client.prototype._transmit = function(command, headers, body) { + var out; + out = Stomp.marshal(command, headers, body); + if (typeof this.debug === "function") { + this.debug(">>> " + out); + } + return this.ws.send(out); + }; + Client.prototype.connect = function(login_, passcode_, connectCallback, errorCallback) { + var klass; + if (typeof this.debug === "function") { + this.debug("Opening Web Socket..." + this.url); + } + klass = WebSocketStompMock || WebSocket; + this.ws = new klass(this.url); + this.ws.onmessage = __bind(function(evt) { + var frame, onreceive; + if (typeof this.debug === "function") { + this.debug('<<< ' + evt.data); + } + frame = Stomp.unmarshal(evt.data); + if (frame.command === "CONNECTED" && connectCallback) { + this.connected = true; + return connectCallback(frame); + } else if (frame.command === "MESSAGE") { + onreceive = this.subscriptions[frame.headers.subscription]; + return typeof onreceive === "function" ? onreceive(frame) : void 0; + } + }, this); + this.ws.onclose = __bind(function() { + var msg; + msg = "Whoops! Lost connection to " + this.url; + if (typeof this.debug === "function") { + this.debug(msg); + } + return typeof errorCallback === "function" ? errorCallback(msg) : void 0; + }, this); + this.ws.onopen = __bind(function() { + if (typeof this.debug === "function") { + this.debug('Web Socket Opened...'); + } + return this._transmit("CONNECT", { + login: login_, + passcode: passcode_ + }); + }, this); + return this.connectCallback = connectCallback; + }; + Client.prototype.disconnect = function(disconnectCallback) { + this._transmit("DISCONNECT"); + this.ws.close(); + this.connected = false; + return typeof disconnectCallback === "function" ? disconnectCallback() : void 0; + }; + Client.prototype.send = function(destination, headers, body) { + if (headers == null) { + headers = {}; + } + if (body == null) { + body = ''; + } + headers.destination = destination; + return this._transmit("SEND", headers, body); + }; + Client.prototype.subscribe = function(destination, callback, headers) { + var id; + if (headers == null) { + headers = {}; + } + id = "sub-" + this.counter++; + headers.destination = destination; + headers.id = id; + this.subscriptions[id] = callback; + this._transmit("SUBSCRIBE", headers); + return id; + }; + Client.prototype.unsubscribe = function(id, headers) { + if (headers == null) { + headers = {}; + } + headers.id = id; + delete this.subscriptions[id]; + return this._transmit("UNSUBSCRIBE", headers); + }; + Client.prototype.begin = function(transaction, headers) { + if (headers == null) { + headers = {}; + } + headers.transaction = transaction; + return this._transmit("BEGIN", headers); + }; + Client.prototype.commit = function(transaction, headers) { + if (headers == null) { + headers = {}; + } + headers.transaction = transaction; + return this._transmit("COMMIT", headers); + }; + Client.prototype.abort = function(transaction, headers) { + if (headers == null) { + headers = {}; + } + headers.transaction = transaction; + return this._transmit("ABORT", headers); + }; + Client.prototype.ack = function(message_id, headers) { + if (headers == null) { + headers = {}; + } + headers["message-id"] = message_id; + return this._transmit("ACK", headers); + }; + return Client; + })(); + if (typeof window !== "undefined" && window !== null) { + window.Stomp = Stomp; + } else { + exports.Stomp = Stomp; + WebSocketStompMock = require('./test/server.mock.js').StompServerMock; + } +}).call(this); \ No newline at end of file