Hhm, given this error
java.io.IOException: Failed to retrieve RMIServer stub:
javax.naming.NameNotFoundException: jmxrmi
the tool seems unable to connect to the broker using JMX url given.
Can you double check the JMX port (typically 1099) is in use by the broker?
Is this the correct JMX
First of all, for your full-round-trip case (no production of message n+1
until triggered by result returned for message n), you need to know the
network latency. So do traceroute or equivalent both ways. US-AUS and
AUS-US.
This gives you a hard limit on how many round-trips you can do per unit
I should point out - just in case - that in your diagram, the
NetworkConnector property suppressDuplicateQueueSubscriptions value is
trues rather than true for Sydney Broker A.
-
Michael Hayes B.Sc. (NUI), M.Sc. (DCU), SCSA SCNA
--
View this message in context:
Hi,
I have the following topology:
Producer Broker 1 -- Consumer 1 Broker 2 - Consumer
2.
^ |
|_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _|
Is it possible to send the message that I
I would like to know the various ways by which we can acknowledge individual
messages received by the consumer.
the one which people generally use is, we set the ActiveMQSession as
INDIVIDUAL_ACKNOWLEDGE, then we can send individual acknowledgment using
message.acknowledge() method.
But i was
On Mar 29, 2012, at 11:18 AM, newtonsri wrote:
Hi,
I have the following topology:
Producer Broker 1 -- Consumer 1 Broker 2 - Consumer
2.
^ |
|_ _ _ _ _ _ _ _ _ _ _ _ _
Hi,
But i was wondering whether it is possible to send a the JMSCorrelationID of
the message to some queue in the broker as a acknowledgment to the broker??
No, that's no possible.
If you want to have control over the acks you should either use CLIENT_ACK mode
or JMS transactions.
Torsten
Can you show where the RMI registry is running? Typically on port 1099 for
the first instance.
-
Michael Hayes B.Sc. (NUI), M.Sc. (DCU), SCSA SCNA
--
View this message in context:
the destination garbage collection only kicks in if there are no
consumers and no messages. so the producer is keeping this temp
destination alive...
one option is to purge the queue, so that the message count goes to 0.
But I think we need to understand why the temp queue is created and
not
Thanks for the reply and the suggesstions..
My requirement is a message comes from consumer1 to broker 2.
This message from consumer 1 must be transmitted both to consumer 2 as well
as Broker 1. I just want to know if this is possible.
--
View this message in context:
Hello everyone ,
I want to use activeMQ in jboss global transaction.
In fact, I will have a project with an oracle datasource and ActiveMQ.
What I want to do is combining in the same trasaction database update and
messages sending.
To do that , I followed the instructions here :
There are many ways to do it, but steps are
1. Create a datasource
2. Set it on JDBCPersistenceAdapter object.
3. Set PersistenceAdapter object on the broker instance...
Below code for illustration only...
protected PersistenceAdapter createJDBCPersistenceAdapter(DataSource ds,
boolean
I took a peek into Makefile.win and find it references vs2005-build directory
while the package contains vs2008-build. I will go ahead and rename the
directory and see if that works.
--
View this message in context:
On Thu, 2012-03-29 at 07:53 -0700, stephenju wrote:
I am trying to build ActiveMQ-CPP with with VC++ 2010 Express and Windows SDK
7.1. VC++ Express has all the tools in normal VS sans the IDE. But I am not
sure where to start. I've built APR and friends. How do I set up so they can
be found
Running:
# netstat -apn | grep 1099
I get the following output:
tcp0 0 0.0.0.0:10990.0.0.0:* LISTEN
5789/rmiregistry
And running:
pgrep -fl java
I get:
/usr/local/java/bin/java -Xms256M -Xmx256M
Thanks. I figured it out now. Here are the steps in case someone needs it. I
am building it with only VC++ 2010 Express and Windows SDK 7.1 installed.
The steps are for building ActiveMQ-CPP 3.4.1:
1. Build APR and friends. This is another hassle. The issue is the latest
apr-util (1.4.6) doesn't
I have been seeing a problem where messages from a spoke instance of AMQ does
not always continue to send messages to a central hub instance using its
network connector after a network outage. The network connector has
apparently reconnected, but the hub/network connector is no longer listed as
a
My failover stuff wasn't working either and I found it was because I didn't
specify the URI correctly. Initially I entered it the way you did.
failover://(tcp://localhost:63001)
I changed it to
failover:(tcp://localhost:63001)
and it worked. So, perhaps removing the extra '//' will help?
From what I understand, the NameNotFoundException happens when you've
successfully connected to the server and port, but 'jmxrmi' is not found
there. So, would this be an issue with my activeMQ or with rmiregistry?
--
View this message in context:
Hi,
I have installed ActiveMQ on MacOS (Lion), and I want to use it with
ActiveMessaging in Rails 3. When I start ActiveMQ with the following
command:
./bin/activemq start
from ACTIVEMQ_HOME (which is /usr/local/Cellar/activemq/5.5.1/libexec),
I get the following messages:
neek wrote
All this led me back to
http://www.lancehendrix.com/techdocs/incubation/Talking%20Stomp%20to%20ActiveMQ.txt,
which is verbose and hard to read but does contain working code. It seems
the exact format of the PHP array you have to send is very particular.
You might be
Thanks for the reply. I tried taking the // out so I'm now using:
networkConnector
uri=static:(failover:(tcp://localhost:63001)?updateURIsSupported=false)
name=network-connector
networkTTL=5
conduitSubscriptions=true
try
./bin/activemq console
so you can see any errors in the shell console
On 29 March 2012 22:05, bibudh bib...@gmail.com wrote:
Hi,
I have installed ActiveMQ on MacOS (Lion), and I want to use it with
ActiveMessaging in Rails 3. When I start ActiveMQ with the following
command:
A bit more info after a bit of investigation... It appears that Network
Connector is created, but not active. When it works, I see this in the log:
[org.apache.activemq.transport.failover.FailoverTransport] : Connection
established
[org.apache.activemq.transport.failover.FailoverTransport] :
This appears to be similar situation to what is described in AMQ-3277. I
have added a maxReconnectAttempts=1 to my network connection URL and have
yet to see a reconnection failure.
networkConnector
Hey Torsten,
what do you mean by control over acknowledge??
The reason I m asking questions related to acknowledgment from consumer, is
that i want to only acknowledge messages after they have been processed by
some processing engine. I can only send the messages to the engine using a
Adapter??
26 matches
Mail list logo