mirror of https://github.com/apache/activemq.git
restructure for AjaxServlet
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392829 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gregory John Wilkins
parent
2373eb2d22
commit
82704c0725
|
|
@ -0,0 +1,160 @@
|
|||
|
||||
|
||||
// AMQ Ajax handler
|
||||
// This class provides the main API for using the Ajax features of AMQ. It
|
||||
// allows JMS messages to be sent and received from javascript when used
|
||||
// with the org.apache.activemq.web.MessageListenerServlet
|
||||
//
|
||||
var amq =
|
||||
{
|
||||
// The URI of the MessageListenerServlet
|
||||
uri: '/amq',
|
||||
|
||||
// Polling. Set to true (default) if waiting poll for messages is needed
|
||||
poll: true,
|
||||
|
||||
_first: true,
|
||||
_pollEvent: function(first) {},
|
||||
_handlers: new Array(),
|
||||
|
||||
_messages:0,
|
||||
_messageQueue: '',
|
||||
_queueMessages: false,
|
||||
|
||||
_messageHandler: function(request)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (request.status == 200)
|
||||
{
|
||||
var response = request.responseXML.getElementsByTagName("ajax-response");
|
||||
if (response != null && response.length == 1)
|
||||
{
|
||||
for ( var i = 0 ; i < response[0].childNodes.length ; i++ )
|
||||
{
|
||||
var responseElement = response[0].childNodes[i];
|
||||
|
||||
// only process nodes of type element.....
|
||||
if ( responseElement.nodeType != 1 )
|
||||
continue;
|
||||
|
||||
var id = responseElement.getAttribute('id');
|
||||
|
||||
|
||||
var handler = amq._handlers[id];
|
||||
if (handler!=null)
|
||||
{
|
||||
for (var j = 0; j < responseElement.childNodes.length; j++)
|
||||
{
|
||||
var child = responseElement.childNodes[j]
|
||||
if (child.nodeType == 1)
|
||||
{
|
||||
handler(child);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
catch(e)
|
||||
{
|
||||
alert(e);
|
||||
}
|
||||
},
|
||||
|
||||
_pollHandler: function(request)
|
||||
{
|
||||
amq._queueMessages=true;
|
||||
try
|
||||
{
|
||||
amq._messageHandler(request);
|
||||
amq._pollEvent(amq._first);
|
||||
amq._first=false;
|
||||
}
|
||||
catch(e)
|
||||
{
|
||||
alert(e);
|
||||
}
|
||||
|
||||
amq._queueMessages=false;
|
||||
|
||||
if (amq._messages==0)
|
||||
{
|
||||
if (amq.poll)
|
||||
new Ajax.Request(amq.uri, { method: 'get', onSuccess: amq._pollHandler });
|
||||
}
|
||||
else
|
||||
{
|
||||
var body = amq._messageQueue+'&poll='+amq.poll;
|
||||
amq._messageQueue='';
|
||||
amq._messages=0;
|
||||
new Ajax.Request(amq.uri, { method: 'post', onSuccess: amq._pollHandler, postBody: body });
|
||||
}
|
||||
},
|
||||
|
||||
// Add a function that gets called on every poll response, after all received
|
||||
// messages have been handled. The poll handler is past a boolean that indicates
|
||||
// if this is the first poll for the page.
|
||||
addPollHandler : function(func)
|
||||
{
|
||||
var old = amq._pollEvent;
|
||||
amq._pollEvent = function(first)
|
||||
{
|
||||
old(first);
|
||||
func(first);
|
||||
}
|
||||
},
|
||||
|
||||
// Send a JMS message to a destination (eg topic://MY.TOPIC). Message should be xml or encoded
|
||||
// xml content.
|
||||
sendMessage : function(destination,message)
|
||||
{
|
||||
amq._sendMessage(destination,message,'send');
|
||||
},
|
||||
|
||||
// Listen on a channel or topic. handler must be a function taking a message arguement
|
||||
addListener : function(id,destination,handler)
|
||||
{
|
||||
amq._handlers[id]=handler;
|
||||
amq._sendMessage(destination,id,'listen');
|
||||
},
|
||||
|
||||
// remove Listener from channel or topic.
|
||||
removeListener : function(id,destination)
|
||||
{
|
||||
amq._handlers[id]=null;
|
||||
amq._sendMessage(destination,id,'unlisten');
|
||||
},
|
||||
|
||||
_sendMessage : function(destination,message,type)
|
||||
{
|
||||
if (amq._queueMessages)
|
||||
{
|
||||
amq._messageQueue+=(amq._messages==0?'destination=':'&destination=')+destination+'&message='+message+'&type='+type;
|
||||
amq._messages++;
|
||||
}
|
||||
else
|
||||
{
|
||||
new Ajax.Request(amq.uri, { method: 'post', postBody: 'destination='+destination+'&message='+message+'&type='+type});
|
||||
}
|
||||
},
|
||||
|
||||
_startPolling : function()
|
||||
{
|
||||
if (amq.poll)
|
||||
new Ajax.Request(amq.uri, { method: 'get', parameters: 'timeout=0', onSuccess: amq._pollHandler });
|
||||
}
|
||||
};
|
||||
|
||||
Behaviour.addLoadEvent(amq._startPolling);
|
||||
|
||||
function getKeyCode(ev)
|
||||
{
|
||||
var keyc;
|
||||
if (window.event)
|
||||
keyc=window.event.keyCode;
|
||||
else
|
||||
keyc=ev.keyCode;
|
||||
return keyc;
|
||||
}
|
||||
|
|
@ -0,0 +1,254 @@
|
|||
/*
|
||||
Behaviour v1.1 by Ben Nolan, June 2005. Based largely on the work
|
||||
of Simon Willison (see comments by Simon below).
|
||||
|
||||
Description:
|
||||
|
||||
Uses css selectors to apply javascript behaviours to enable
|
||||
unobtrusive javascript in html documents.
|
||||
|
||||
Usage:
|
||||
|
||||
var myrules = {
|
||||
'b.someclass' : function(element){
|
||||
element.onclick = function(){
|
||||
alert(this.innerHTML);
|
||||
}
|
||||
},
|
||||
'#someid u' : function(element){
|
||||
element.onmouseover = function(){
|
||||
this.innerHTML = "BLAH!";
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
Behaviour.register(myrules);
|
||||
|
||||
// Call Behaviour.apply() to re-apply the rules (if you
|
||||
// update the dom, etc).
|
||||
|
||||
License:
|
||||
|
||||
This file is entirely BSD licensed.
|
||||
|
||||
More information:
|
||||
|
||||
http://ripcord.co.nz/behaviour/
|
||||
|
||||
*/
|
||||
|
||||
var Behaviour = {
|
||||
list : new Array,
|
||||
|
||||
register : function(sheet){
|
||||
Behaviour.list.push(sheet);
|
||||
},
|
||||
|
||||
start : function(){
|
||||
Behaviour.addLoadEvent(function(){
|
||||
Behaviour.apply();
|
||||
});
|
||||
},
|
||||
|
||||
apply : function(){
|
||||
for (h=0;sheet=Behaviour.list[h];h++){
|
||||
for (selector in sheet){
|
||||
list = document.getElementsBySelector(selector);
|
||||
|
||||
if (!list){
|
||||
continue;
|
||||
}
|
||||
|
||||
for (i=0;element=list[i];i++){
|
||||
sheet[selector](element);
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
|
||||
addLoadEvent : function(func){
|
||||
var oldonload = window.onload;
|
||||
|
||||
if (typeof window.onload != 'function') {
|
||||
window.onload = func;
|
||||
} else {
|
||||
window.onload = function() {
|
||||
oldonload();
|
||||
func();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Behaviour.start();
|
||||
|
||||
/*
|
||||
The following code is Copyright (C) Simon Willison 2004.
|
||||
|
||||
document.getElementsBySelector(selector)
|
||||
- returns an array of element objects from the current document
|
||||
matching the CSS selector. Selectors can contain element names,
|
||||
class names and ids and can be nested. For example:
|
||||
|
||||
elements = document.getElementsBySelect('div#main p a.external')
|
||||
|
||||
Will return an array of all 'a' elements with 'external' in their
|
||||
class attribute that are contained inside 'p' elements that are
|
||||
contained inside the 'div' element which has id="main"
|
||||
|
||||
New in version 0.4: Support for CSS2 and CSS3 attribute selectors:
|
||||
See http://www.w3.org/TR/css3-selectors/#attribute-selectors
|
||||
|
||||
Version 0.4 - Simon Willison, March 25th 2003
|
||||
-- Works in Phoenix 0.5, Mozilla 1.3, Opera 7, Internet Explorer 6, Internet Explorer 5 on Windows
|
||||
-- Opera 7 fails
|
||||
*/
|
||||
|
||||
function getAllChildren(e) {
|
||||
// Returns all children of element. Workaround required for IE5/Windows. Ugh.
|
||||
return e.all ? e.all : e.getElementsByTagName('*');
|
||||
}
|
||||
|
||||
document.getElementsBySelector = function(selector) {
|
||||
// Attempt to fail gracefully in lesser browsers
|
||||
if (!document.getElementsByTagName) {
|
||||
return new Array();
|
||||
}
|
||||
// Split selector in to tokens
|
||||
var tokens = selector.split(' ');
|
||||
var currentContext = new Array(document);
|
||||
for (var i = 0; i < tokens.length; i++) {
|
||||
token = tokens[i].replace(/^\s+/,'').replace(/\s+$/,'');;
|
||||
if (token.indexOf('#') > -1) {
|
||||
// Token is an ID selector
|
||||
var bits = token.split('#');
|
||||
var tagName = bits[0];
|
||||
var id = bits[1];
|
||||
var element = document.getElementById(id);
|
||||
if (tagName && element.nodeName.toLowerCase() != tagName) {
|
||||
// tag with that ID not found, return false
|
||||
return new Array();
|
||||
}
|
||||
// Set currentContext to contain just this element
|
||||
currentContext = new Array(element);
|
||||
continue; // Skip to next token
|
||||
}
|
||||
if (token.indexOf('.') > -1) {
|
||||
// Token contains a class selector
|
||||
var bits = token.split('.');
|
||||
var tagName = bits[0];
|
||||
var className = bits[1];
|
||||
if (!tagName) {
|
||||
tagName = '*';
|
||||
}
|
||||
// Get elements matching tag, filter them for class selector
|
||||
var found = new Array;
|
||||
var foundCount = 0;
|
||||
for (var h = 0; h < currentContext.length; h++) {
|
||||
var elements;
|
||||
if (tagName == '*') {
|
||||
elements = getAllChildren(currentContext[h]);
|
||||
} else {
|
||||
elements = currentContext[h].getElementsByTagName(tagName);
|
||||
}
|
||||
for (var j = 0; j < elements.length; j++) {
|
||||
found[foundCount++] = elements[j];
|
||||
}
|
||||
}
|
||||
currentContext = new Array;
|
||||
var currentContextIndex = 0;
|
||||
for (var k = 0; k < found.length; k++) {
|
||||
if (found[k].className && found[k].className.match(new RegExp('\\b'+className+'\\b'))) {
|
||||
currentContext[currentContextIndex++] = found[k];
|
||||
}
|
||||
}
|
||||
continue; // Skip to next token
|
||||
}
|
||||
// Code to deal with attribute selectors
|
||||
if (token.match(/^(\w*)\[(\w+)([=~\|\^\$\*]?)=?"?([^\]"]*)"?\]$/)) {
|
||||
var tagName = RegExp.$1;
|
||||
var attrName = RegExp.$2;
|
||||
var attrOperator = RegExp.$3;
|
||||
var attrValue = RegExp.$4;
|
||||
if (!tagName) {
|
||||
tagName = '*';
|
||||
}
|
||||
// Grab all of the tagName elements within current context
|
||||
var found = new Array;
|
||||
var foundCount = 0;
|
||||
for (var h = 0; h < currentContext.length; h++) {
|
||||
var elements;
|
||||
if (tagName == '*') {
|
||||
elements = getAllChildren(currentContext[h]);
|
||||
} else {
|
||||
elements = currentContext[h].getElementsByTagName(tagName);
|
||||
}
|
||||
for (var j = 0; j < elements.length; j++) {
|
||||
found[foundCount++] = elements[j];
|
||||
}
|
||||
}
|
||||
currentContext = new Array;
|
||||
var currentContextIndex = 0;
|
||||
var checkFunction; // This function will be used to filter the elements
|
||||
switch (attrOperator) {
|
||||
case '=': // Equality
|
||||
checkFunction = function(e) { return (e.getAttribute(attrName) == attrValue); };
|
||||
break;
|
||||
case '~': // Match one of space seperated words
|
||||
checkFunction = function(e) { return (e.getAttribute(attrName).match(new RegExp('\\b'+attrValue+'\\b'))); };
|
||||
break;
|
||||
case '|': // Match start with value followed by optional hyphen
|
||||
checkFunction = function(e) { return (e.getAttribute(attrName).match(new RegExp('^'+attrValue+'-?'))); };
|
||||
break;
|
||||
case '^': // Match starts with value
|
||||
checkFunction = function(e) { return (e.getAttribute(attrName).indexOf(attrValue) == 0); };
|
||||
break;
|
||||
case '$': // Match ends with value - fails with "Warning" in Opera 7
|
||||
checkFunction = function(e) { return (e.getAttribute(attrName).lastIndexOf(attrValue) == e.getAttribute(attrName).length - attrValue.length); };
|
||||
break;
|
||||
case '*': // Match ends with value
|
||||
checkFunction = function(e) { return (e.getAttribute(attrName).indexOf(attrValue) > -1); };
|
||||
break;
|
||||
default :
|
||||
// Just test for existence of attribute
|
||||
checkFunction = function(e) { return e.getAttribute(attrName); };
|
||||
}
|
||||
currentContext = new Array;
|
||||
var currentContextIndex = 0;
|
||||
for (var k = 0; k < found.length; k++) {
|
||||
if (checkFunction(found[k])) {
|
||||
currentContext[currentContextIndex++] = found[k];
|
||||
}
|
||||
}
|
||||
// alert('Attribute Selector: '+tagName+' '+attrName+' '+attrOperator+' '+attrValue);
|
||||
continue; // Skip to next token
|
||||
}
|
||||
|
||||
if (!currentContext[0]){
|
||||
return;
|
||||
}
|
||||
|
||||
// If we get here, token is JUST an element (not a class or ID selector)
|
||||
tagName = token;
|
||||
var found = new Array;
|
||||
var foundCount = 0;
|
||||
for (var h = 0; h < currentContext.length; h++) {
|
||||
var elements = currentContext[h].getElementsByTagName(tagName);
|
||||
for (var j = 0; j < elements.length; j++) {
|
||||
found[foundCount++] = elements[j];
|
||||
}
|
||||
}
|
||||
currentContext = found;
|
||||
}
|
||||
return currentContext;
|
||||
}
|
||||
|
||||
/* That revolting regular expression explained
|
||||
/^(\w+)\[(\w+)([=~\|\^\$\*]?)=?"?([^\]"]*)"?\]$/
|
||||
\---/ \---/\-------------/ \-------/
|
||||
| | | |
|
||||
| | | The value
|
||||
| | ~,|,^,$,* or =
|
||||
| Attribute
|
||||
Tag
|
||||
*/
|
||||
|
|
@ -0,0 +1,184 @@
|
|||
|
||||
// Technique borrowed from scriptaculous to do includes.
|
||||
|
||||
var DefaultJS = {
|
||||
Version: 'AMQ default JS',
|
||||
script: function(libraryName) {
|
||||
document.write('<script type="text/javascript" src="'+libraryName+'"></script>');
|
||||
},
|
||||
load: function() {
|
||||
var scriptTags = document.getElementsByTagName("script");
|
||||
for(var i=0;i<scriptTags.length;i++) {
|
||||
if(scriptTags[i].src && scriptTags[i].src.match(/default\.js$/)) {
|
||||
var path = scriptTags[i].src.replace(/default\.js$/,'');
|
||||
this.script(path + 'prototype.js');
|
||||
this.script(path + 'behaviour.js');
|
||||
this.script(path + '_amq.js');
|
||||
// this.script(path + 'scriptaculous.js');
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
DefaultJS.load();
|
||||
|
||||
|
||||
// AMQ Ajax handler
|
||||
// This class provides the main API for using the Ajax features of AMQ. It
|
||||
// allows JMS messages to be sent and received from javascript when used
|
||||
// with the org.apache.activemq.web.MessageListenerServlet
|
||||
//
|
||||
var amq =
|
||||
{
|
||||
// The URI of the MessageListenerServlet
|
||||
uri: '/amq',
|
||||
|
||||
// Polling. Set to true (default) if waiting poll for messages is needed
|
||||
poll: true,
|
||||
|
||||
_first: true,
|
||||
_pollEvent: function(first) {},
|
||||
_handlers: new Array(),
|
||||
|
||||
_messages:0,
|
||||
_messageQueue: '',
|
||||
_queueMessages: false,
|
||||
|
||||
_messageHandler: function(request)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (request.status == 200)
|
||||
{
|
||||
var response = request.responseXML.getElementsByTagName("ajax-response");
|
||||
if (response != null && response.length == 1)
|
||||
{
|
||||
for ( var i = 0 ; i < response[0].childNodes.length ; i++ )
|
||||
{
|
||||
var responseElement = response[0].childNodes[i];
|
||||
|
||||
// only process nodes of type element.....
|
||||
if ( responseElement.nodeType != 1 )
|
||||
continue;
|
||||
|
||||
var id = responseElement.getAttribute('id');
|
||||
|
||||
|
||||
var handler = amq._handlers[id];
|
||||
if (handler!=null)
|
||||
{
|
||||
for (var j = 0; j < responseElement.childNodes.length; j++)
|
||||
{
|
||||
var child = responseElement.childNodes[j]
|
||||
if (child.nodeType == 1)
|
||||
{
|
||||
handler(child);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
catch(e)
|
||||
{
|
||||
alert(e);
|
||||
}
|
||||
},
|
||||
|
||||
_pollHandler: function(request)
|
||||
{
|
||||
amq._queueMessages=true;
|
||||
try
|
||||
{
|
||||
amq._messageHandler(request);
|
||||
amq._pollEvent(amq._first);
|
||||
amq._first=false;
|
||||
}
|
||||
catch(e)
|
||||
{
|
||||
alert(e);
|
||||
}
|
||||
|
||||
amq._queueMessages=false;
|
||||
|
||||
if (amq._messages==0)
|
||||
{
|
||||
if (amq.poll)
|
||||
new Ajax.Request(amq.uri, { method: 'get', onSuccess: amq._pollHandler });
|
||||
}
|
||||
else
|
||||
{
|
||||
var body = amq._messageQueue+'&poll='+amq.poll;
|
||||
amq._messageQueue='';
|
||||
amq._messages=0;
|
||||
new Ajax.Request(amq.uri, { method: 'post', onSuccess: amq._pollHandler, postBody: body });
|
||||
}
|
||||
},
|
||||
|
||||
// Add a function that gets called on every poll response, after all received
|
||||
// messages have been handled. The poll handler is past a boolean that indicates
|
||||
// if this is the first poll for the page.
|
||||
addPollHandler : function(func)
|
||||
{
|
||||
var old = amq._pollEvent;
|
||||
amq._pollEvent = function(first)
|
||||
{
|
||||
old(first);
|
||||
func(first);
|
||||
}
|
||||
},
|
||||
|
||||
// Send a JMS message to a destination (eg topic://MY.TOPIC). Message should be xml or encoded
|
||||
// xml content.
|
||||
sendMessage : function(destination,message)
|
||||
{
|
||||
amq._sendMessage(destination,message,'send');
|
||||
},
|
||||
|
||||
// Listen on a channel or topic. handler must be a function taking a message arguement
|
||||
addListener : function(id,destination,handler)
|
||||
{
|
||||
amq._handlers[id]=handler;
|
||||
amq._sendMessage(destination,id,'listen');
|
||||
},
|
||||
|
||||
// remove Listener from channel or topic.
|
||||
removeListener : function(id,destination)
|
||||
{
|
||||
amq._handlers[id]=null;
|
||||
amq._sendMessage(destination,id,'unlisten');
|
||||
},
|
||||
|
||||
_sendMessage : function(destination,message,type)
|
||||
{
|
||||
if (amq._queueMessages)
|
||||
{
|
||||
amq._messageQueue+=(amq._messages==0?'destination=':'&destination=')+destination+'&message='+message+'&type='+type;
|
||||
amq._messages++;
|
||||
}
|
||||
else
|
||||
{
|
||||
new Ajax.Request(amq.uri, { method: 'post', postBody: 'destination='+destination+'&message='+message+'&type='+type});
|
||||
}
|
||||
},
|
||||
|
||||
_startPolling : function()
|
||||
{
|
||||
if (amq.poll)
|
||||
new Ajax.Request(amq.uri, { method: 'get', parameters: 'timeout=0', onSuccess: amq._pollHandler });
|
||||
}
|
||||
};
|
||||
|
||||
Behaviour.addLoadEvent(amq._startPolling);
|
||||
|
||||
function getKeyCode(ev)
|
||||
{
|
||||
var keyc;
|
||||
if (window.event)
|
||||
keyc=window.event.keyCode;
|
||||
else
|
||||
keyc=ev.keyCode;
|
||||
return keyc;
|
||||
}
|
||||
File diff suppressed because it is too large
Load Diff
Loading…
Reference in New Issue