Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

batch support 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397165 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gregory John Wilkins 2006-04-26 10:16:45 +00:00
parent c1a1dd2689
commit f25d9269af
1 changed files with 28 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
activemq-web/src/main/resources/org/apache/activemq/web/_amq.js
View File

@ -19,7 +19,7 @@ var amq =
_messages:0, _messages:0,
_messageQueue: '', _messageQueue: '',
_queueMessages: false, _queueMessages: 0,
_messageHandler: function(request) _messageHandler: function(request)
{ {
@ -63,9 +63,26 @@ var amq =
} }
}, },
startBatch: function()
{
amq._queueMessages++;
},
endBatch: function()
{
amq._queueMessages--;
if (amq._queueMessages==0 && amq._messages>0)
{
var body = amq._messageQueue;
amq._messageQueue='';
amq._messages=0;
new Ajax.Request(amq.uri, { method: 'post', postBody: body});
}
},
_pollHandler: function(request) _pollHandler: function(request)
{ {
amq._queueMessages=true; amq._queueMessages++;
try try
{ {
amq._messageHandler(request); amq._messageHandler(request);
@ -77,20 +94,19 @@ var amq =
alert(e); alert(e);
} }
amq._queueMessages=false; amq._queueMessages--;
if (amq._messages==0) if (amq._queueMessages==0 && amq._messages>0)
{
if (amq.poll)
new Ajax.Request(amq.uri, { method: 'get', onSuccess: amq._pollHandler });
}
else
{ {
var body = amq._messageQueue+'&poll='+amq.poll; var body = amq._messageQueue+'&poll='+amq.poll;
amq._messageQueue=''; amq._messageQueue='';
amq._messages=0; amq._messages=0;
new Ajax.Request(amq.uri, { method: 'post', onSuccess: amq._pollHandler, postBody: body }); new Ajax.Request(amq.uri, { method: 'post', onSuccess: amq._pollHandler, postBody: body });
} }
else if (amq.poll)
{
new Ajax.Request(amq.uri, { method: 'get', onSuccess: amq._pollHandler });
}
}, },
// Add a function that gets called on every poll response, after all received // Add a function that gets called on every poll response, after all received
@ -129,7 +145,7 @@ var amq =
_sendMessage : function(destination,message,type) _sendMessage : function(destination,message,type)
{ {
if (amq._queueMessages) if (amq._queueMessages>0)
{ {
amq._messageQueue+=(amq._messages==0?'destination=':'&destination=')+destination+'&message='+message+'&type='+type; amq._messageQueue+=(amq._messages==0?'destination=':'&destination=')+destination+'&message='+message+'&type='+type;
amq._messages++; amq._messages++;