1c89c92217
enabled the command agent so you can communicate with the broker agent via JMS or XMPP or Stomp
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475316 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 17:34:46 +00:00
bc7d758fa0
Added some simple stompcat and catstomp scripts
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475302 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 16:36:18 +00:00
9260e941f9
use a temporary queue so replies can be sent to the client when they send to admin topics like ActiveMQ.Agent
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475289 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 16:08:46 +00:00
ba476b36f0
Setting some svn eol-styles and improving source distro assembly
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475265 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 15:43:24 +00:00
540ebc6651
added a simple interactive console via SimpleConsole together with making the commands usable from the CommandAgent in activemq-core
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475211 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 12:10:41 +00:00
940850910d
added a simple command agent that can be used to send messages to a destination (ActiveMQ.Agent) to interact with the broker via the activemq-console commands (list, query, browse etc)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475210 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 12:02:34 +00:00
f3105202ef
Tweaked out the source distro assembly
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475068 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 00:00:28 +00:00
5bde1e3003
setting svn:eol-style
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475018 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 22:09:09 +00:00
fe1cde80ae
removing extranous META-INF
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475009 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:47:27 +00:00
9e45486806
Adding notice files
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475004 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:44:45 +00:00
934e70cb66
Adding notice files
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475002 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:44:06 +00:00
4416123a00
Adding notice files
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475000 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:43:00 +00:00
0028479281
Adding notice files
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474998 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:40:14 +00:00
06a365f12c
Setting svn:eol-style
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474985 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:16:11 +00:00
9e6eb830b3
Set the eol-style
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474977 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:02:18 +00:00
cdf6bee977
Added a source distro assembly
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474976 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 20:59:57 +00:00
36265ea802
Updated java service wrappers so that they properly use the ACTIVEMQ_BASE and ACTIVEMQ_HOME enviroment variables.
...
also print out the ACTIVEMQ_BASE on startup and if classloading error occurs, have the main method dump a listing of what is in the classloaders.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474926 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 19:20:38 +00:00
48a1ad8eec
move the wrapper.jar to the bin dir and set the eol-style
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474894 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 17:54:28 +00:00
f001db49a9
move the wrapper.jar to the bin dir
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474893 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 17:50:53 +00:00
b243182cf9
move the wrapper.jar to the bin dir
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474892 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 17:50:34 +00:00
ae5cf8ef9e
https://issues.apache.org/activemq/browse/AMQ-1016
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474872 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 17:11:37 +00:00
c0bc3e00c1
http://issues.apache.org/activemq/browse/AMQ-1045 we now evict failed connections from a connection pool.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474799 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 14:12:03 +00:00
caa30ffdc0
Added synconization to the methods that setup connection state so that when an async error is detected, it properly does a full cleanup. Previously subscriptions were not properly cleaned up since they were being setup at the same time as they were being cleaned up.
...
Also start 1 async exception thread ever since an async exception leads to connection tear down. Subsequent failures do not need additional async threads started.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474769 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 12:44:16 +00:00
0e9369f5dd
AMQ-644 - create Java Service Wrapper for ActiveMQ
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474706 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 08:52:13 +00:00
7a3de7693b
log the the exception if an exception caught in rotating the consumers
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474674 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 06:27:34 +00:00
2d64943d45
Minor fix on build failure due to missing start tag "<dependency>" on one of the dependencies.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474632 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 02:43:04 +00:00
636e37b376
Don't include activecluster as dependency since it not :)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474523 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 21:18:54 +00:00
6895d009d8
Split the internal messages in a Queue destination in two - messages accessed by the
...
PendingMessageCursor and work in progress or pagedInMessages - which are instances
of QueueMessageReference - hence keeping the semantics for Message Groups etc. and keeping
the majority of the 'fiddly bits' intact.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474475 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 20:06:49 +00:00
55f4aad761
check that Queue messages aren't acknowledged before applying a filter
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474469 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:54:40 +00:00
9fcfa5c6d2
remove RangeLimitedMap - will be replaced with B+ Tree
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474468 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:52:47 +00:00
6b5840f8c1
remove RangeLimitedMap - will be replaced with B+ Tree
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474467 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:51:38 +00:00
b376ce24ef
propagate exceptions up to the caller
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474466 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:50:31 +00:00
43d2ef0469
log an error for ConnectionErrors that are not transport or
...
Broker in shutdown related
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474465 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:49:33 +00:00
8396de884b
Merge in change 474371 from 4.1 branch
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474373 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 15:40:21 +00:00
2510b088ad
fixed for http://issues.apache.org/activemq/browse/AMQ-1042
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473647 13f79535-47bb-0310-9956-ffa450edef68
2006-11-11 06:09:59 +00:00
b75b1ee059
fix for https://issues.apache.org/activemq/browse/AMQ-1039
...
updated activemq-version property to 4.2-incubator-SNAPSHOT
updated activecluster-version property to 4.x-SNAPSHOT
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473325 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 12:47:17 +00:00
beaca8a043
Fix some failing test cases in windows.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473224 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 07:29:23 +00:00
a8f4f6978c
Added optimization to determine the highest priority consumer during addition of subscription.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473223 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 07:28:27 +00:00
8951023556
https://issues.apache.org/activemq/browse/AMQ-1024
...
- Fix case where a non-exclusive consumer registered first will receive a message, before an exclusive consumer.
- Added junit test case to demonstrate the issue.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473219 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 07:16:25 +00:00
d71bc421f8
We should let a client change the client id on a connection even if it was set on the connection factory.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473167 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 02:04:40 +00:00
0918fba384
https://issues.apache.org/activemq/browse/AMQ-1036
...
- Fix some browsing problems in the web console.
- Added a purge queue action.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473056 13f79535-47bb-0310-9956-ffa450edef68
2006-11-09 20:12:29 +00:00
8be1b5eb5a
Reving up version
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472518 13f79535-47bb-0310-9956-ffa450edef68
2006-11-08 15:27:38 +00:00
6be185d2ce
Changes to POM to try fix AMQ-1017
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472483 13f79535-47bb-0310-9956-ffa450edef68
2006-11-08 13:05:14 +00:00
4b5bc5eb2d
added synchronization around marshal/unmarshal
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472421 13f79535-47bb-0310-9956-ffa450edef68
2006-11-08 08:23:08 +00:00
da5139c24b
All message dispatching should occur from the session's executor. Also, we should dispatch any messages in the consumers queue before dispatching messages in the session's queues.
...
http://issues.apache.org/activemq/browse/AMQ-1031
http://issues.apache.org/activemq/browse/AMQ-1032
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472345 13f79535-47bb-0310-9956-ffa450edef68
2006-11-08 00:14:56 +00:00
c636b3798f
Added test case to test resizing of internal buffer of DataByteArrayOutputStream.
...
Fix bug during resizing of internal buffer of DataByteArrayOutputStream.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472258 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 21:00:46 +00:00
0c93dfde72
Added message ordering assertions and also a test case that uses consumer.receive() instead of a messsage listener
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472237 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 20:30:37 +00:00
11501cb38e
removed java 5 annotations :)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472209 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 19:12:48 +00:00
39b0376001
added a test case to reproduce a bad ack bug
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472207 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 19:10:01 +00:00
3daf923b51
Added some fields for future use to the BrokerInfo and ProducerInfo classes.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472165 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 16:56:12 +00:00
James Strachan
Hiram R. Chirino
Joseph Dennis O. Gapuz
Robert Davies
Frederick G. Oconer
Jonas B. Lim
Adrian T. Co