822df45e38
Rev up openwire version in case someone makes changes
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475773 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 15:35:24 +00:00
86faaef7c9
Fix for AMQ-1053. Added support for pluggable message transformation together with an implementation using XStream to marshall ObjectMessage instances as TextMessages. See the XStreamTransformTest to see how a producer can send ObjectMessages but then consumers can see either ObjectMessages or TextMessages depending on their requirements.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475701 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 12:08:22 +00:00
34fb326a0a
added test case for AMQ-1027
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475680 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 10:56:07 +00:00
fc6ab9c687
change Queue message store in Kaha store adaptor to use memory efficent list instead
...
of Map containers
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475416 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 20:56:21 +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
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
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
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
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
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
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
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
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
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
da7478d9d5
Eliminated AbstractConnection by inlining it into TransportConnection. The synchronization complexity between the two was making my head spin. Now that they are consolidated, we can try to simply them a little more.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472157 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 16:40:23 +00:00
cafe4cbcc4
http://issues.apache.org/activemq/browse/AMQ-1026
...
Created a ReconnectTest that showed problems with the synchronization used when a client reconnects to a server via failover before the server detects the client failure.
- InactivityMonitor : Better syncronization so that an inactivty exception is only raised once.
- Connection: Added serviceExceptionAsync() method and change all methods that are dispatching to use this instead of serviceException() to avoid possible deadlock that can occur during connection shutdown.
- MockTransport: finer grained sychonization to avoid deadlocks.
- PrefetchSubscription: it is possible it will get duplicate acks on a failover reconnect
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@471837 13f79535-47bb-0310-9956-ffa450edef68
2006-11-06 19:35:59 +00:00
36de58b371
fix for https://issues.apache.org/activemq/browse/AMQ-1023
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470695 13f79535-47bb-0310-9956-ffa450edef68
2006-11-03 07:15:37 +00:00
4821b9da70
Use Input/Output Stream intefaces instead of concrete classes
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470398 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:49:58 +00:00
8a8f41c33b
Added test to make sure ConnectionFactory is serializable - which
...
is a requirement of the JMS spec
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470395 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:47:46 +00:00
ae687a1182
moved StoreByteArray stream methods to util
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470391 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:36:21 +00:00
166a04bc58
make size of io buffers configurable
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470390 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:35:46 +00:00
fdcc973923
optimized
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470389 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:34:53 +00:00
330e73140a
moved utility methods for reading byte streams to utils package from Kaha
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470388 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:34:22 +00:00
526cb5bae8
make enabling statistics configurable
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470387 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:33:25 +00:00
12fff78943
fixed typo
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470282 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 08:57:54 +00:00
3f74b0e1c0
support for ByteSequence
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@469986 13f79535-47bb-0310-9956-ffa450edef68
2006-11-01 17:13:39 +00:00
b3e315fcc2
disabled the use of the CommandAgent by default to avoid causing the VM broker to keep around forever (since the broker itself creates a VM transport which avoids it ever being closed)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@469972 13f79535-47bb-0310-9956-ffa450edef68
2006-11-01 16:37:39 +00:00
b93cd9ec13
Ensure Administered objects are Serializable
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@469873 13f79535-47bb-0310-9956-ffa450edef68
2006-11-01 11:47:51 +00:00
49e10d36fc
added support for a simple message based command agent so that you can send management commands to the broker over JMS
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@469135 13f79535-47bb-0310-9956-ffa450edef68
2006-10-30 12:17:14 +00:00
41265f2b53
make the setProperty public since it can be handy.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@468911 13f79535-47bb-0310-9956-ffa450edef68
2006-10-29 14:30:36 +00:00
efd516866d
fixed trivial javadoc warning
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@468030 13f79535-47bb-0310-9956-ffa450edef68
2006-10-26 15:02:45 +00:00
04015a5e3d
switched to released version
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@467949 13f79535-47bb-0310-9956-ffa450edef68
2006-10-26 10:28:08 +00:00
47a97ef893
Change default multicast IP used as we had been using one in the reserved range, now it uses 239.255.2.3, which is in th
...
e range designated for site-local stuff
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@467791 13f79535-47bb-0310-9956-ffa450edef68
2006-10-25 22:15:35 +00:00
Hiram R. Chirino
James Strachan
Robert Davies
Jonas B. Lim
Adrian T. Co
Brian McCallister