I have a non-persistent Topic with a single producer (Java-JMS) and
multiple non-durable consumers (written in C# NMS)
Looking at the Topic in jconsole I notice the following:
1. The QueueSize on the Topic is the same as the EnqueueCount and
keeps increasing with each new message.
2.
Mea Maxima Culpa!
As penance I will post an example of how to accomplish this using
Advisory Topics.
Gaurav
Gaurav Hariani wrote:
We have a scenario where we would like to be notified when a consumer
on a Topic disconnects.
Is there a way to do this? Maybe using the Advisory Topics
We have a scenario where we would like to be notified when a consumer on
a Topic disconnects.
Is there a way to do this? Maybe using the Advisory Topics?
Thanks,
Gaurav
er told it to put it...
Can I turn that off too??
Thanks again!
Werner
Gaurav Hariani wrote:
My needs are similar to yours and I don't see any derby/journal activity.
I'm using ActiveMQ 4.1.1 with the following basic activemq.xml config
My needs are similar to yours and I don't see any derby/journal activity.
I'm using ActiveMQ 4.1.1 with the following basic activemq.xml config.
Gaurav
---
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
xmlns="http://activemq.org/config/1.0";>
We have a similar need and after trying a number of approaches we
settled on the following approach:
The producer creates a file in a directory where it can be served by a
webserver e.g. ~gaurav/public_html/large_messages/xyzABC123.zip
Then the producer sends the URL of this file as a text mess
I don't know anything about MDB's etc but my guess is you are not
acknowledging messages.
vineetc wrote:
Hello All,
I am trying to build a MDB based recv. application that will process
messages delivered by AMQ RA.
ENVIRONMENT
Windows XP
JDK 1.6.0_01
ActiveMQ 4.1.1 and the the RA provided by
I would approach this using persistent messages.
Your webapp creates a persistent message adds the time (as a property
maybe) at which the message should be sent as email and puts it on a queue.
Another application can regularly poll the queue for messages that are
ready to be emailed.
That
If you are retrieving primitive types - you could check using
boolean itemExists(String name)
http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/command/ActiveMQMapMessage.html#itemExists(java.lang.String)
also from the spec api: http://java.sun.com/j2ee/1.4/docs/api/
yes
Hiram Chirino wrote:
Odd. look like a bug. You using 4.1.1?
On 6/6/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote:
Since James and Hiram are back on the list ... I thought I'd repost
this-
We are facing a problem of orphan connections to ActiveMQ. A simple .NET
client that o
Since James and Hiram are back on the list ... I thought I'd repost this-
We are facing a problem of orphan connections to ActiveMQ. A simple .NET
client that only creates a connection/session and then closes and exits,
still shows up in jconsole.
It is possible to stop it manually in jconsole
The following code creates a connection to an OpenWire transport
connector, waits for 1 second and then closes the session/connection.
Looking at JConsole ... ActiveMQ reports the connection as open. Too
many open connections and ActiveMQ stops processing messages.
However if the connection is
I have a simple producer in .NET that makes a connection, creates a
producer, sends a message, calls close on the producer, session and
connection.
The AcknowledgementMode is AcknowledgementMode.AutoAcknowledge
The producer is non persistent.
After the program exits, the openwire connection can
It seems you are trying to run two instances of ActiveMQ from the same
installation.
And they are both trying to write to the same journal ... change the
configuration to use a different journal location for the second broker.
Vinod_mit wrote:
Hi
I have just installed activemq, I have to star
Correction - I meant:
BrokerA also needs a network connector defined pointing to the TCP
TransportConnector defined in BrokerB
Gaurav Hariani wrote:
BrokerA also needs a transport connector defined pointing to the TCP
TransportConnector defined in BrokerB
agrabil wrote:
Sorry, forgot to
BrokerA also needs a transport connector defined pointing to the TCP
TransportConnector defined in BrokerB
agrabil wrote:
Sorry, forgot to mention that I'm using ActiveMQ 4.1
Greg
agrabil wrote:
I am testing what I believe to be a very simple network of brokers
scenario that I can't s
From what I understand -
Transport Connector: An end point which clients (or other brokers) can
connect to. This is what you use as the connection URI in clients.
Network Connector: A remote end point at another broker, which this
broker will connect to.
You can certainly replace 'localhost'
This may be a dumb question ... where in jconsole do I look for the
usageManager stats?
James Strachan wrote:
On 4/2/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote:
Is there a way of confirming that this is the cause?
The JMX stats should show the usageManager being full.
Is there a way of confirming that this is the cause?
Something like maybe enable debug logging on the broker or something
like that?
James Strachan wrote:
As I said, its probably this
http://activemq.apache.org/my-producer-blocks.html
On 4/2/07, Gaurav Hariani <[EMAIL PROTECTED]>
t I'll try getting one the next time it happens
But what could be the potential reasons for this?
James Strachan wrote:
On 3/30/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote:
Would this show up in the memory usage on the broker?
Not really; it would in JMX though.
wrote:
Hi,
Speed of response is critical for my application. Also it must work with
BES and BIS connected users. So it doesn't appear either of what you
suggest will work. Any other suggestions?
Gaurav Hariani-2 wrote:
It should be possible to write a simple STOMP client for the
It should be possible to write a simple STOMP client for the blackberry
... as they support sockets.
(This feature may be restricted to Blackberry devices connected to a
corporate network using the MDS)
Another alternative which is probably slower but easier to write is a
JMS client running on
...
http://activemq.apache.org/my-producer-blocks.html
On 3/27/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote:
I have a single producer (Java) that sends small messages to about 20
consumers (written in C#).
After a few hours of running it blocks for many hours on the send.
What could be causin
I have a single producer (Java) that sends small messages to about 20
consumers (written in C#).
After a few hours of running it blocks for many hours on the send.
What could be causing this?
"main" prio=6 tid=0x00286000 nid=0xe3c in Object.wait() [0x0090f000..0x0090fe58]
java.lang.Thread.Sta
Is there someplace that explains these statistics?
James Strachan wrote:
On 3/26/07, ss2 <[EMAIL PROTECTED]> wrote:
Is there a way to get queue statistics such as how long a message
sits in the
queue before being processed, when was the last time the queue
received a
message? when was the l
I see that irrespective of the number of clients connected to a broker
or the number of messages being sent (or the size of messages)
the JMX Console reports that the broker is using 20Mb of Non-Heap Memory
... is this a limit by design ... can I increase this limit to improve
throughput?
Chan
I have a network of 2 standalone brokers - BrokerA and BrokerB
There is one producer ProducerA (a java client) that connects to BrokerA
X number of consumers that connect to BrokerA
Y number of consumers that connect to BrokerB
The consumers are written in C#.
When more than 1 consumer connects t
Check the broker using jconsole that the queue names match and that you
aren't creating 2 different queues.
I had a similar problem using the Perl Stomp client.
I think Stomp Topics and Queues get created with a name like
TOPIC/ and QUEUE/
I may be rusty on the format etc.
Gaurav
[EMAIL PROT
the queue statistics.
Gaurav Hariani wrote:
Is there a way for a client to determine which broker it is connected to
(when using a failover URI)?
nd tcp://host2:61616
Still trying to figure out how to get failover going the clients
don't switch over to other brokers but just exit.
Nagavardhan Sogal wrote:
Different names
On 2/27/07, *Gaurav Hariani* <[EMAIL PROTECTED]
<mailto:[EMAIL PROTECTED]>> wrote:
Hi N
Is there a way for a client to determine which broker it is connected to
(when using a failover URI)?
Is there a simple way to handle this at the client currently?
Maybe something like a listener on the Session/Connection that gets
notified in case of a transport failure?
Also is there any means of querying a broker for load information (e.g.
how many clients are connected to a broker)
to allow
I still get the same exception on the clients.
naga007 wrote:
>
>
> use failover:(tcp://host1:61616,tcp://host2:61616) uri format for the
> client.s
>
>
> Gaurav Hariani wrote:
>>
>> I'm trying to setup a cluster of Brokers (standalone) which clie
sible to use similar clients using the .NET API?
Thanks,
Gaurav Hariani
--
View this message in context:
http://www.nabble.com/Network-Cluster-of-Brokers---Please-help-tf3293180s2354.html#a9159928
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
34 matches
Mail list logo
