Re: Advisory Support and Network of Brokers

2007-10-10 Thread Rob Davies
Demand based propagation of messages across networks does require advisories to work. You could try explicitly setting up the destinations you want to be propagated around the network - if you don't want to use advisories (though they are good!) cheers, Rob http://rajdavies.blogspot.com/

xml configuration help needed

2007-10-10 Thread Nicky Sandhu
This commented out snippet in http://activemq.apache.org/xml-configuration.html example fails when the memoryUsage part is uncommented. Neither can I make this http://activemq.apache.org/maven/activemq-core/xsddoc/schema-summary.html work Any ideas on how to set the usageManager limit to say 30

Re: gracefully restarting a c++/openwire session

2007-10-10 Thread Timothy Bish
You must destroy the connection and create a new connection / session etc. We don't have a fail over transport but you are welcome to write one and donate it :) Fred Crable wrote: Is there a best practice for gracefully restarting an openwire/c++ consumer or producer session. I'm hesitant t

message selectors

2007-10-10 Thread Terrk K
I cannot find enough documentation on message selectors but have many questions. Message selectors are more like fliters right? If so, what is the underlying selection policy of the broker? Age, priority, moon phases? I want batch select messages belonging to some logical group, i.e. some id whe

Advisory Support and Network of Brokers

2007-10-10 Thread manishbel
Hi All, When i turn off the Advisory Support the Network of Brokers doesn't work. Is it mandatory to have it on for it to work? i thought it was more for the Monitoring purposes. I am using multicast for discovery. Thanks Manish -- View this message in context: http://www.nabble.com/Advisory-

transacted sessions in multi-threaded client

2007-10-10 Thread Terrk K
In a point-to-point queue I want to use transacted sessions to ensure messages are processed completely before being removed from the queue. The client is to be multi threaded to process messages in parallel. I decided each thread would need it's own Session object (for transacting) so that when

gracefully restarting a c++/openwire session

2007-10-10 Thread Fred Crable
Is there a best practice for gracefully restarting an openwire/c++ consumer or producer session. I'm hesitant to destroy and rebuild the connection, session, and all of the consumers when I get an connection exception in my exception listener. I can't use failover:tcp: in an openwire broker uri.

Re: Yes, and it's an urgent problem [was Re: lock on Oracle activemq_lock table]

2007-10-10 Thread kmoore4now
Hi Mario, Thanks! The problem does not occur only when ActiveMQ shuts down abnormally. It also seems to occur when a db connection is lost due to network abnormalities, while Active MQ is running. Unfortunately, we do need to run in master / slave mode, so turning off db locking as you suggest

reconnection to unavailable broker causing thread/memory leak

2007-10-10 Thread Fred Crable
I just setup my 1st broker network so I'm far from an expert. However, while I was testing I took down one broker and went to a meeting. When I got back and starting testing again I saw that there were out of memory errors. Looking at Jconsole after I restarted it looks like the number of threa

Re: Unexpected remote command

2007-10-10 Thread Rob Davies
This is fixed in the svn main trunk cheers, Rob http://rajdavies.blogspot.com/ On Oct 9, 2007, at 2:47 PM, ttmdev wrote: We are using the 'duplex' functionality for the same reason. I am getting the same results whether I use this syntax, as in the distro test case duplex

Re: Yes, and it's an urgent problem [was Re: lock on Oracle activemq_lock table]

2007-10-10 Thread Mario Siegenthaler
I think that's a reasonable scenario, Oracle will actually have trouble detecting them fast enough. I don't know if there's a setting in Oracle that would speed up the checks. MySQL and MS SQL Server detect the disconnect almost instantaneous. However this should not happen on a clean shutdown. Whi

Re: Yes, and it's an urgent problem [was Re: lock on Oracle activemq_lock table]

2007-10-10 Thread kmoore4now
Perhaps stating the obvious... this seems to happen when there is some network instability and the connection to the database is lost. Because the connection is lost, ActiveMQ is unable to release the lock. The lock then stays on the table until Oracle is good and ready to delete it, which can be

Re: Yes, and it's an urgent problem [was Re: lock on Oracle activemq_lock table]

2007-10-10 Thread Mario Siegenthaler
I don't know about how Oracle exactly handles that, but all of the DBs I've seen so far remove the locks as soon as the connection holding them is disconnected or closed or the transaction is rollbacked. Since the 'old' broker isn't running anymore the connection is disconnected. And the locker ro

Re: 6 broker node network results in many duplicate messages or "durable consumer in use" errors

2007-10-10 Thread ddossot
JIRA issue: https://issues.apache.org/activemq/browse/AMQ-1455 Anyone knows if it is possible to restart a bridge from JMX? ddossot wrote: > > Here is the exception that makes the bridge die: > > 11:04:46,254 DEBUG [org.apache.activemq.network.DemandForwardingBridge] > The local Exception was

Urgent: App server (websphere) unable to restart if queue not empty

2007-10-10 Thread naql
This next issue is very serious for us and urgently needs a resolution. I'm sure that it's the same issue I see described here at this link: http://ecommunity.groupintelligence.com/websphere/forums/archive/index.php/t-1027.html http://ecommunity.groupintelligence.com/websphere/forums/archive/in

Yes, and it's an urgent problem [was Re: lock on Oracle activemq_lock table]

2007-10-10 Thread naql
kmoore4now wrote: > > I'm using the journaled JDBC approach to message persistence, with Oracle. > It seems to work well most of the time. However, I'm finding that even > after a normal shutdown a lock occasionally appears to be held on the > activemq_lock table. This prevents ActiveMQ from sta

Re: java.lang.NoSuchMethodError: org.apache.activemq.command.ConnectionInfo.isClientMaster()Z

2007-10-10 Thread jaspa
Thanks for the explanation - I made the following change to the POM which resolved the problem, but I have to admit it was more luck that judgement! :- org.logicblaze.lingo lingo 1.3 incubator-active

Re: Async error occurred: java.lang.IllegalStateException: Cannot add a consumer to a session that had not been registered:

2007-10-10 Thread Alex_ynr
Cool, that's great! Do you know of a workaround in the meantime? rajdavies wrote: > > I'm in the middle of fixing this > On Oct 10, 2007, at 2:02 PM, Alex_ynr wrote: > >> >> We slightly discussed this issue in another thread (about a >> different issue) >> so in order to not hijack it, I c

Re: java.lang.NoSuchMethodError: org.apache.activemq.command.ConnectionInfo.isClientMaster()Z

2007-10-10 Thread SynapticFire
Lingo has a dependency on ActiveMQ 4.0. As far as I can tell activemq 4.0 does not have ConnectionInfo.isClientMaster(). Somehow through maven dependency resolution, the earlier ActiveMQ is higher in the chain than the declared version, thus it finds the older ConnectionInfo class with no isClie

Re: Async error occurred: java.lang.IllegalStateException: Cannot add a consumer to a session that had not been registered:

2007-10-10 Thread Rob Davies
I'm in the middle of fixing this On Oct 10, 2007, at 2:02 PM, Alex_ynr wrote: We slightly discussed this issue in another thread (about a different issue) so in order to not hijack it, I created a new one. This error comes up when trying to set up a duplex networkConnector between 2 Acti

performance with 1 MByte messages

2007-10-10 Thread keneida
In my installation i will have maximum of 350 clients which connect to the queue and send about 1 MB messages. In worst case scenario all of them will do it almost at the same time. I creaetd small program with 350 threads which connects to the amq with a 4 second delay between the threads. The w

Reliably starting and stopping of a producer/consumer

2007-10-10 Thread Aaron Digulla
Hello, I'm trying to write code for a webapp which allows me to start and stop the webapp no matter whether an ActiveMQ JMS server is running or not with ActiveMQ 4.1.1. This means: - Create the connection in a worker thread, so the webapp doesn't hang during startup - Interrupt the connection c

Async error occurred: java.lang.IllegalStateException: Cannot add a consumer to a session that had not been registered:

2007-10-10 Thread Alex_ynr
We slightly discussed this issue in another thread (about a different issue) so in order to not hijack it, I created a new one. This error comes up when trying to set up a duplex networkConnector between 2 ActiveMQ brokers. In this specific case, I am running Fuse 3.3. Clean install on both mac

Re: Couldn't get jdbcPersistenceAdapter working

2007-10-10 Thread Alex_ynr
Eh... The "Specified key was too long; max key length is 1000 bytes" error came up in my logs on creating the tables and I've seen it many times because I work with utf-8 databases a lot so it jumped at me :P I'm using Fuse 3.3 btw ... Alex Yuen-Chi Lian wrote: > > Hi Alex, > > Fantastic! I

Quick question on ActiveMQConnectionFactory and ActiveMQXAConnectionFactory

2007-10-10 Thread Yuen Chi Lian
Hi guys, I have looked into the API documentation at: http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQXAConnectionFactory.html However, I couldn't find any information or confirmation regarding when and how should the ActiveMQXAConnectionFactory should be used.

Re: Couldn't get jdbcPersistenceAdapter working

2007-10-10 Thread Yuen Chi Lian
Hi Alex, Fantastic! I managed to get it working now. Do you mind to share how did you manage to find that out? Anyway: mysql> status -- ... Server characterset:utf8 Db characterset:utf8 ... mysql> drop database activemq; Query OK, 2 rows affected (0.06 sec) mysql> creat

Re: Couldn't get jdbcPersistenceAdapter working

2007-10-10 Thread Alex_ynr
I just hit the same thing as well Specified key was too long; max key length is 1000 bytes is the error not allowing the creation of ACTIVEMQ_ACKS You are probably using utf8/some other multibyte encoding as the collation in your database Switch it to latin1 or ASCII... The varchar fields t

Can i provide my own DB Table for message persistence?

2007-10-10 Thread Arif Mohd
Hi, Iam using JDBC for message persistence. Can i configure activeMQ in such a way that it uses my own supplied DDL statement for creating a table for message persistence? My message will be an Object message so i want a custom table with column names ID,name,val where ID should be for

Graphing perfomance test results (4.1)

2007-10-10 Thread Patrick Wright
Hi I was ran the performance test (activemq-4.1.1/activemq-perftest) described in http://activemq.apache.org/activemq-performance-module-users-manual.html, and was wondering if anyone had ever hooked up the output result XML to some graphing library, to get a visual overview of the results. Tha

Re: Duplicate message delivered to consumers on queue with AMQ persistence

2007-10-10 Thread David Sitsky
Hi Rob, I'm afraid I didn't get any time today, and my project has moved on to not using JMS persistence for messaging. We are using custom checkpointing instead, which is a bit more lightweight than full JMS persistence. I'd still like to see this issue fixed, so I'll try to find some time