See the ACTIVEMQ_HOME/conf/log4j.properties file. In that file, you'll see
the following statement.
log4j.appender.out.file=${activemq.base}/data/activemq.log
Joe
www.ttmsolutions.com
sparky2708 wrote:
>
> I keep getting the following error message (I want everything to be logged
> to /tm
See the following JIRA and associated patch.
http://issues.apache.org/activemq/browse/AMQ-1098
There is also this thread, which concerns ActiveMQ’s use of Jetty for HTTPS
support. Note that a misconfiguration with respect to the keys and/or
certificates can lead to an infinite loop with the brok
A broker automatically retries connections to remote brokers.
Clients will also automatically retry connections to brokers, but they need
to use the 'failover' transport.
Joe
www.ttmsolutions.com
dlaidlaw wrote:
>
>
> OK, so JMS Bridges are not the recommended solution. And I will look at
Enable simple or JAAS-based authentication @ the broker.
http://activemq.apache.org/security.html
Then have your client pass in the proper username and password when creating
the JMS connection.
Its not HTTP Basic Authentication, but it should do the trick. For added
security, you can use the
You may want to look into setting up a Camel context to implement such
routing rules.
http://activemq.apache.org/enterprise-integration-patterns.html
Joe
www.ttmsolutions.com
Arnau wrote:
>
> Hi all,
>
> Yesterday I discovered ActiveMQ and I have been banging my head
> against a wall :).
Hi Eddie,
Try this
env.put(Context.PROVIDER_URL, "vm://localhost");
Joe
Get a free ActiveMQ user guide at www.ttmsolutions.com
EddieK wrote:
>
> I am migrating an application away from JBoss JMS to ActiveMQ, but I am
> not having much luck. The application, migrated away from JBoss, will
The two connection endpoints negotiate the value and settle on the lesser of
the two. Do you have the same setting at both ends?
Joe
www.ttmsolutions.com
Suchitha Koneru (sukoneru) wrote:
>
> Hello Active MQ users ,
> Our application uses active mq 4.1.1. The
>
rd the next release of Active MQ 5.2 will detect slow consumers &
> notify (according to AMQ-609). Will the command agent send a notification
> on ActiveMQ.Agent? How can I know that the command agent has sent a
> notification? Does it log any info in the log file?
>
>
>
rom Jconsole:
Live Threads: 5300 Peak:5306
Daemon threads: 5292 Total started: 6424
Memory used: 170.521 kbytes
Is that normal?
Br,
Neowill
ttmdev wrote:
>
> Not sure why you're getting the OOME even after increasing the JVM's heap
> size. But given that you&#
Not sure why you're getting the OOME even after increasing the JVM's heap
size. But given that you're potentially creating up to 20,000 topics, would
the use of message selectors be a more efficient approach?
Joe
neowill wrote:
>
> Thanks Dave!
>
> I increase the JVM heap size by change
Check out the following
http://activemq.apache.org/command-agent.html
Note that the command agent will not work within a secure AMQ environment
(i.e., you've enabled authentication). See the following JIRA for more
details and a 5.2 fix.
https://issues.apache.org/activemq/browse/AMQ-1303
Joe
Using multicast across subnets gets a bit involved. This thread may help.
http://www.nabble.com/broker-discovery-client-help-to4474136.html#a4515535
If multicast is not a requirement, I would recommend using unicast tcp
transports to connect the two brokers.
Joe
LiXiao2007 wrote:
>
> I se
This posting from Robin may help.
http://www.nabble.com/Adding-users-on-the-fly-ACTIVEMQ-to16825211s2354.html#a16984528
Joe
Graham Leggett wrote:
>
> Hi all,
>
> A quick Google search to find a straightforward explanation on how to
> authenticate activemq against an LDAP server uncovered t
You should make a note of the following JIRA
https://issues.apache.org/activemq/browse/AMQ-1529
As it currently stands, BLOBs are not deleted from the web server's
repository.
Joe
ttmdev wrote:
>
> I have opened up a JIRA for this and submitted a patch for review.
I have opened up a JIRA for this and submitted a patch for review.
https://issues.apache.org/activemq/browse/AMQ-1770
Joe
Marco Buss wrote:
>
> Hello,
>
> check if the blob is uploaded to the fileserver webapp. If the blob is
> uploaded try this:
>
> class="org.apache.activemq.pool.Pooled
Sun has a decent JMS tutorial.
http://java.sun.com/products/jms/tutorial/
Joe
floulou wrote:
>
> Hi,
> I want to do my first application using JMS binding component and
> activeMQ,so can you give me a tutorial wich helps me in this purpose.
> NB:I am using NetBeans IDE
> Thanking in advance
I have create AMQ-1761 and submitted a patch for review. The patch enhances
sendTextMessage() such that it accepts an optional username and password.
This allows you to send a text message, via jmx, while authentication
services have been enabled.
Joe
ttmdev wrote:
>
> There
The TransportConnector is used by the broker to listen for and accept
connection requests from clients and other brokers. When a connection is
initially established, the connection endpoints go through a wireformat
negotiation phase. This is explained on this page.
http://activemq.apache.org/o
You will need to implement your clients (i.e., publisher and subscriber). Via
its XML configuration file, you can have the message broker create the
clients' corresponding topic(s) when it starts up. Or you can have the
clients create the topics on the fly.
http://activemq.apache.org/how-do-i-c
There is the 'sendTextMessage' operation that the destination MBean (i.e.,
DestinationViewMBean) provides. I guess you could extend this to accept an
optional user name and password.
Joe
Jeremy Ross wrote:
>
> bump. pretty please.
>
>
> Jeremy Ross wrote:
>>
>> Hi. I'm using the authoriza
FYI - copyMessageOnSend is being used within the ActiveMQSession.send()
method.
...
if (connection.isCopyMessageOnSend()) {
msg = (ActiveMQMessage)msg.copy();
}
...
Joe
Ryan Stewart wrote:
>
> I'm trying to use an embedded ActiveMQ instance for some lightweight
> message handling. Accordi
Here's some good info.
http://activemq.apache.org/integrating-apache-activemq-with-jboss.html
Joe
Hema Natarajan wrote:
>
> Hi,
> I am looking for the steps to configure JBoss with external ActiveMQ.
> Please provide us.
>
> We tried the following and it gave the exception as follows.
Sounds like what you're after is a MQ-like 'trigger monitor'. Perhaps another
option is to develop a plugin module that provides 'trigger monitor' like
functionality.
Joe
Swampcritter wrote:
>
> I am trying out Active MQ for the first time, so bear with me. I have a
> number of questions, so
There's an example towards the bottom of this page.
http://activemq.apache.org/slow-consumer-handling.html
Joe
Get your free ActiveMQ user guide at http://www.ttmsolutions.com
Andrew M-2 wrote:
>
> How do I set the subscription recovery policy options at the bottom of
> this
> page?
>
>
A number
and I can submit a patch for review.
If you're interested, I have updated our dynamically re-loadable AMQ
security plugin to do just that.
http://www.ttmsolutions.com/amqsec.php4
Regards,
Joe
Tom Purcell wrote:
>
> Looks like jira it is. I have not tried the consumer yet.
> queueSender = queueSession.createSender(queue);
>
> And I get:
> java.lang.SecurityException: User queryuser is not authorized to create:
> queue://Wile.Jms.Queue.Query.Asset
>
> So I'm not sure how to connect to a predefined queue. Can you point me at
> an exa
> Am I missing something or looking in the wrong place?
>
> -- Michael
>
>
>
> ttmdev wrote:
>>
>> With ActiveMQ, clients and brokers are not required to reside on the same
>> machine/site. So the answer to your last questions is, yes. The point A
&g
FWIW, I have dropped your configuration into my setup (AMQ 5.1, JDK
1.5.0_06-b05, Windoze XP Pro)
and have not encountered your problem. I have used both
jaasAuthenticationPlugin and simpleAuthenticationPlugin.
Joe
Tom Purcell wrote:
>
> Hello
> I'm trying to get the ActiveMQ authorizatio
With ActiveMQ, clients and brokers are not required to reside on the same
machine/site. So the answer to your last questions is, yes. The point A and
B clients can exchange messages via the remote central broker.
Joe
Get a free ActiveMQ user guide at www.ttmsolutions.com
Swampcritter wrote:
;
> Joe: As per the following resolved issue:
> http://issues.apache.org/activemq/browse/AMQ-920
>
> the NetworkConnector *should* be bidirectional.
>
>
> ttmdev wrote:
>>
>> If you decide to put it on the local broker, make sure the remote broker
>> ha
If you decide to put it on the local broker, make sure the remote broker has
a forwarding bridge back to the local broker.
Joe
Hiram Chirino wrote:
>
> either one works.. but putting on the local broker is typically
> simpler and what is normally done.
>
> On Thu, May 22, 2008 at 4:06 PM, c
What do you have networkTTL set at?
Also, depending on how the brokers are interconnected, you may want to
consider setting dynamicOnly to true; this ensures that messages are only
routed to brokers with active consumers.
Careful using 'duplex' bridges between brokers in combination with high
n
You'll find it in the .../lib/optional/activemq-rar-4.1.1.rar file.
Joe
/U wrote:
>
>
> I do not find activemq-ra.jar in the 4.1.1 distribution.
> This is needed for using Jencks. Can someone send
> me a pointer to this artifact?
>
> Regards
>
> /Ur
>
>
--
View this message in contex
I highly recommend moving to version 5.1
Joe
Get a free ActiveMQ user guide at www.ttmsolutions.com
sgopal wrote:
>
> Hi,
> I have two applications eaching having their own embedded broker (active
> mq 5.0) .
>
> Each of the embedded brokers add a network broker pointing to the other
> one.
In my testing with 5.1, it has been the CommandAgent and Camel that cause the
security-related exceptions to be hurled on broker startup. Jetty may hurl
an exception if and when you try and use it. If you need to use the
CommandAgent in a secure environment, you can extend it to provide a
userna
Beware that the commandAgent, which is now commented out in the default
activemq.xml, will also initiate a connection.
Joe
bsnyder wrote:
>
> On Thu, May 15, 2008 at 8:49 PM, Aaron Mulder
> <[EMAIL PROTECTED]> wrote:
>> This may not be as bad as the subject sounds, but...
>>
>> I enabled secu
I think what is happening is that you haven't given everyone all access
rights to the advisory topics. I get a similar stack trace when I don't do
that. Add an ACL with the following "ActiveMQ.Advisory.>" and that should do
the trick.
If you're interested, check out this AMQ security plugin.
h
I also ran across this issue with the latest 5.1.
Messages bounce back and forth between the 2 brokers via the duplex
transport until the ttl count expires. The DemandForwardingBridge doesn't
check where the message came from before sending it back off to the remote.
Working on a patch for the c
FYI - the "Destination" link @ the top of
http://activemq.apache.org/activemq-510-release.html is broken.
Joe
James.Strachan wrote:
>
> BTW you can listen to destinations being added/removed by calling the
> setDestinationListener method on the DestinationSource
>
>
>
> 2008/5/8 shaf <[EMA
Have you given the three broker's unique names?
Joe
Get a free ActiveMQ user guide at www.ttmsolutions.com
peanutgyz wrote:
>
> i use 3 brokers, a b c.
> then i want point a to b , c to b,
> like this a --> b <-- c
>
> but , when connection between a and b is establised,
> connect c
It appears to me that org.apache.activemq.network.ForwardingBridge does not
have the appropriate constructor and setters for the localBroker and
remoteBroker 'String' params. You may want to check and see if there is a
jira out for this.
Joe
Get a free ActiveMQ user guide at www.ttmsolutions.com
What about creating clusters of consumers for each of your processing stages
to better-handle the load spikes? The messages will get load-balanced across
the consumers in a cluster.
Joe
Get a free ActiveMQ user guide at www.ttmsolutions.com
Maarten Dirkse-2 wrote:
>
> An update:
> I've now
Yup, referencing ActiveMQ objects from your code nails your application to
ActiveMQ and makes it non-portable. It defeats the purpose of using the JMS.
If you're running an external (standalone) client, Spring would be a good
way to go, but if you want to still use the JNDI, then simply create a
j
I have two 5.1 brokers connecting okay over http transports. Could it be a
firewall-related issue?
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
j0llyr0g3r wrote:
>
> Hey folks,
>
> i am having a hard time figuring out how to get http-tunneling working.
>
> According to the
1. You can purge messages via the JMX.
2. You should be able to set up a cluster of consumers where all consumers
in the cluster compete for messages on a particular queue. Over time, I
think you should get an even distribution. If there are messages in the
queue and the consumers are not yet ac
A static connector, having multiple IP addresses, will force the broker to
connect to *all* the brokers whose IP addresses are listed in the connector.
It is the client failover connector that, by default, randomly chooses one
of the listed IP addresses/brokers (i.e., is more than one is provide
Can you post your broker's XML configuration file? Also, the output of your
broker as captured in the ACTIVEMQ_HOME/data/activemq.log file; it may shed
some light on the problem.
I highly recommend upgrading to version 5.1 of ActiveMQ.
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user gu
If you've got security enabled, then I'm afraid you're going to have to
comment out the commandAgent and most probably the camelContext elements.
These components try and connect to the broker, but AFAIK there's no way to
assign them a valid user name and password via their respective elements in
Re compression; if your producer has not set useCompression to true, then the
'compressed' message property will be set to false when viewed by your
consumer. If I'm not mistaken, the default compression algorithm used is
the default “DEFLATE” (gzip) algorithm. More on this algorithm can be found
Hola Luiz,
Since all you want to do is forward messages from broker A to B, then simply
create a forwarding bridge from A to B. Each broker should only have one
transportConnector and broker A would have one networkConnector that will be
used to create the forwarding bridge to B. You really don't
Doh! Never mind my previous question ;)
Joe
ttmdev wrote:
>
> Try taking the 'failover' out of broker A's static connector. Like so,
>
> ... />
>
> With the above static connector, if broker B fails, Broker A should go
> into connect retry mode.
Try taking the 'failover' out of broker A's static connector. Like so,
With the above static connector, if broker B fails, Broker A should go into
connect retry mode.
What version of AMQ are you using?
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
rmahoney249 wrote:
>
>
The "duplex" feature has had its issues :( I think you'll find that if you
set networkTTL to 1, the topic consumer(s) on broker A will not get
duplicate messages. However, even with networkTTL set to greater than 1,
broker B should not be sending messages back to where they came from.
Re your f
In your groups.properties file, you've assigned the user "system" to the
"admins", "tempDestinationAdmins", and "users" groups. So in your
elements, change "system" to one of those groups.
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
navnetkachroo wrote:
>
> Hi,
>
> I am
I don't think he needs to acknowledge. It appears he's using an asynchronous
receiver w/in an AUTO_ACKNOWLEDGE session. In this scenario, the
acknowledgment occurs automatically when the onMessage method returns.
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
liushk wrote:
>
I don't think that the retroactive consumer feature guarantees delivery of
all messages sent while the consumer was inactive. The way this feature is
described, it is more of a best-attempt effort to deliver the messages.
http://activemq.apache.org/retroactive-consumer.html
Have you considered
trying to create “duplex”
connections/bridges to each other. So taking out the duplex=”true” attribute
from the network connector elements should do the trick.
Joe
ttmdev wrote:
>
> The following statement, taken from your standard error output, tells me
> that the broker w/the nam
The following statement, taken from your standard error output, tells me that
the broker w/the name "ds-pl3.technion.ac.il" is rejecting a connection
request from a client because the client is trying to use a client id
(NC_planetlab1.tmit.bme.hu_inboundds-pl3.technion.ac.il) that is already in
us
/bugdatabase/view_bug.do;jsessionid=ee6ec97669ab91923bde6c
>> d8c041?bug_id=6460501
>>
>> Would we still expect the ActiveMQ5.0 + Sun JDK 1.5.0_12 memory leak?
>
> Possibly - could you use the latest snapshot until we do either a 5.01
> or 5.1 release ?
>>
>>
>>
virtual destinations. What
> would be the recommended thing to do in my case?
> And BTW, the user guide is awesome!
>
> Thanks,
> Ramit
>
> ttmdev wrote:
>>
>> Your non-durable subscriber will only get those messages that were
>> published while it is act
Your non-durable subscriber will only get those messages that were published
while it is active. When you bounce the broker it does not retain the
identity of your non-durable subscriber. So when the broker comes back up,
it doesn't consider your non-durable subscriber to have been active when th
Can you provide information re the memory leak that you've come across?
rby wrote:
>
> Hi,
>
> Same here, I have an obvious memory leak with activemq 5.1-snapshot.
> I hope someone will respond at least to one of these memory related
> questions.
>
> Regards,
> Ramzi
>
>
> krv wrote:
>>
>
It appears that one of your clients is setting the client identifier
explicitly for its connection to the broker called, "wattle.broker".
However, that client id has already been taken by another client that is
already connected to the broker and thus the client id is being treated as
an invalid d
Looks like the remote endpoint at the other end of this transport connection
closed the connection. Maybe due to an inactivity timeout?
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
Fuddi wrote:
>
>
> Hi,
>
> Thanks for a good product.
>
> running ActiveMQ with broker URL
Joe
navnetkachroo wrote:
>
> Thanks for your reply.
>
> I tried giving the username & pwd... But even that did'nt work :(. I'm
> getting the same exception.
>
> uri="static://(tcp://test-msg-poc-1:61616)" userName="system"
> password="ma
Couple of things to keep in mind.
a. Any broker wishing to connect to this broker (i.e., the one you've
enabled security for) will need to provide the proper credentials via the
networkConnector element's userName and password attributes.
b. Any networkConnector elements given to this broker m
You typically get a BindException when you try and bind to a port that has
already been taken by another process or thread. So it looks like you have
more than one embedded broker, in your load balanced cluster, trying to bind
to the same port on the same machine.
Joe
Goto www.ttmsolutions.com f
If you're running ActiveMQ on a 1.5 VM, you may have noticed a very slow and
steady memory leak with the broker even when it is sitting idle.
The leak, which is in the VM and not the broker, has been addressed in the
1.6 VM. The culprit is the java.util.concurrent package, and relative to
Active
l the Redhat version we are using is consistent across all
>> systems
>>
>> and it is
>>
>> Red Hat Enterprise Linux ES release 3 (Taroon Update 9)
>> Kernel 2.4.21-50.ELsmp on an i686
>>
>> any tips on how to check which threads package its using?
Use caution when setting advisorySupport to 'false', because doing so will
preclude the broker from forwarding messages to other brokers in a network
of brokers.
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
Michal Singer wrote:
>
> Hi. I tried to disable Advisory Support using
Try disabling or increasing the inactivity timeout on the brokers'
corresponding transport connector element. For example this will disable the
inactivity monitor.
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
/U wrote:
>
> I am connecting two external brokers as follows:
>
Yup, there's a way. ActiveMQ provides a couple of basic authentication and
authorization service providers that you can use to control access to
destinations. For more info go to this URL
http://activemq.apache.org/security.html
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
pet
FYI - patchfile submitted.
https://issues.apache.org/activemq/browse/AMQ-1511
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
toxicafunk wrote:
>
> That'll be great.
>
> Thx,
> Eric
>
> ttmdev wrote:
>> I'm testing out a patch. If all goes
I'm testing out a patch. If all goes well, I'll submit it in the next day or
so...
Joe
Goto www.ttmsolutions.com for a free ActiveMQ user guide
toxicafunk wrote:
>
> This seems to be exactly the problem. I will try the shared master/slave
> configuration but is this bug fixable and if so whe
You can think of the peer connector as a superset of the VM connector. The
peer connector uses the VM connector to launch and connect to an 'embedded'
broker, but it also configures the embedded broker to establish network
connectors to other embedded brokers within the LAN subnet that have the
sa
Sounds like what you may be looking for are LDAP Authorization and
Authentication plugins? That is, retrieve user security information from one
central directory service or repository. Maybe take a look at Acegi; I think
Acegi is or was on the ActiveMQ road map.
I think ActiveMQ's plugin archite
It is not necessary to start your connection before setting it up (i.e.,
create sessions, listeners, etc.). As a matter fact, the JMS specification
recommends that you start your connection after you've completed your setup.
Here's the statement from the specification.
"It is typical to leave th
g of your email suggests that there is.
>
> Could you pl give me an example of aconfiguration of two brokers that
> authenticate each other using the simpleAuth plugin?
>
> Thanks, /U
>
> -- Original message --
> From: ttmdev <[EMAIL PROTECTED
Regarding your question - If you have enabled authentication for a particular
message broker, then other brokers that wish to connect to that broker must
provide the proper authentication credentials via their
element.
Joe
www.ttmsolutions.com
/U wrote:
>
> Env: Activemq 5.0.0, JDK1.6
>
> I
My guess is that you're using AMQ 4.1, but with the 5.x schema? If that is
the case, see this URL for the 4.1 simpleAuthenticationPlugin
http://activemq.apache.org/ref/schema/activemq-core-4.1.1.xsd.html#simpleAuthenticationPlugin
I think Rudi ran across the same problem
http://www.nabble.com/A
Yup, implementing an authentication and authorization scheme can get quite
confusing. If you're planning to adhere to the JAAS, you may want to read
through the following documentation.
http://java.sun.com/javase/6/docs/technotes/guides/security/jaas/JAASRefGuide.html
Joe
www.ttmsolutions.com
Just a hunch, but maybe its the threads package being used on this particular
system. For example, on older versions of Linux each thread you spawned was
implemented as a separate process.
Joe
QWERTY? wrote:
>
>
>
> ttmdev wrote:
>>
>> That is rather strange, bec
That is rather strange, because the activemq script starts only one instance
of the broker.
QWERTY? wrote:
>
>
>
> ttmdev wrote:
>>
>> Yup, looks like it. What version of AMQ are you using and are you using
>> the $ACTIVEMQ_HOME/bin/activemq script t
Yup, looks like it. What version of AMQ are you using and are you using the
$ACTIVEMQ_HOME/bin/activemq script to start the broker?
Joe
QWERTY? wrote:
>
>
>
> ttmdev wrote:
>>
>> The "36 ActiveMQ processes" that you mention...are these
The "36 ActiveMQ processes" that you mention...are these 36 message brokers?
Joe
www.ttmsolutions.com
QWERTY? wrote:
>
> Hi,
>
> when running activemq and I connect to it with a client I get the
> following exception or exceptions?
>
> java.io.EOFException
> at java.io.DataInputStre
at in this scenario the OpenWire protocol is
being tunneled through http.
http://activemq.apache.org/openwire-version-2-specification.html
Joe
www.ttmsolutions.com
Brian Munroe-2 wrote:
>
> On Mon, Mar 3, 2008 at 11:17 AM, ttmdev <[EMAIL PROTECTED]>
> wrote:
>
>> Th
Yes, if you're using a pure JMS client you can use the http transport w/out
having to deal with REST or AJAX. For example, if you're using the JNDI, you
can place the following brokerURL in your jndi.properties file.
connection.httpConnectionFactory.brokerURL = http://host01:61616
>From your JM
The $ACTIVEMQ_HOME/bin/activemq script starts a 'standalone' ActiveMQ message
broker that, by default, uses the $ACTIVEMQ_HOME/conf/activemq.xml
configuration file. The standalone broker will automatically reference the
jar files in $ACTIVEMQ_HOME/lib.
You also have the option of starting an 'em
The default activemq.xml configuration file comes with three optional and
enabled elements: , , and . If you
enable authentication & authorization services, these enabled elements will
cause the broker to throw security-related exceptions. This is because these
elements represent functionality th
ing. I configured
> transport as:
>
> fanout:(static:(tcp://localhost:12346,tcp://localhost:12345))
>
> and messages were consumed only from one broker, and there were a lot of
> errors in log.
>
> S.
>
>
> ttmdev wrote:
>>
>> There is the composit
There is the composite 'fanout' transport, which allows you to replicate a
command across multiple brokers. However, when I last tested fanout, it
worked well for producing, but not so well for consuming.
http://activemq.apache.org/fanout-transport-reference.html
There has also been some talk
There is a consumer option called 'noLocal' (e.g.,
TEST.Q?consumer.noLocal=true).
When set to ‘true’, it prohibits delivery of messages produced on the same
connection.
Joe
www.ttmsolutions.com
Oleg Deribas-5 wrote:
>
> Hello,
>
> I'm connecting to ActiveMQ 5.0 with the latest SVN versio
I think the exclusive consumer feature should do the trick for you. If you
introduce an exclusive consumer to an existing cluster of non-exclusive
consumers, the exclusive consumer will gain control of the corresponding
destination and the non-exclusives are locked out. When the exclusive
consumer
teFormat("-MM-dd
>> HH:mm:ss");
>> java.util.Date date = new java.util.Date();
>>
>> System.out.println(dateFormat.format(date) + " -
>> Received msg: " +
>> ((TextMessage)mess).getTe
The default setting for advisorySupport is 'true' and I don't think that the
forwarding of messages has any dependencies on advisorySupport.
Joe
www.ttmsolutions.com
wha wrote:
>
>
>
> bsnyder wrote:
>>
>>
>> Disable the all transport connectors (i.e., comment them out) and
>> remove th
I've been using ActiveMQ 5.1 on XP and so far it's been pretty steady-eddy
wrt pure master/slave. However, I don't think I've been kicking the tires as
long and hard as you guys.
There are a couple of related JIRA's:
https://issues.apache.org/activemq/browse/AMQ-1257
https://issues.apache.org
re is no reference in the
activemq and activeio trunks to "com.ibm.io.*"
Joe
www.ttmsolutions.com
bsnyder wrote:
>
> On Thu, Feb 14, 2008 at 8:55 AM, ttmdev <[EMAIL PROTECTED]>
> wrote:
>>
>> Re the reference to "AIO", does this mean support
The "[activemq_install_dir]/bin activemq" command will start a standalone
broker that, by default, uses the
"[activemq_install_dir]/conf/activemq.xml" configuration file. You're most
likely getting the bind error because the default JMX management port (1099)
has been taken by another process on
Thanks, Bruce.
Joe
bsnyder wrote:
>
> On Thu, Feb 14, 2008 at 8:55 AM, ttmdev <[EMAIL PROTECTED]>
> wrote:
>>
>> Re the reference to "AIO", does this mean support for AIO4J or that
>> AMQ's use
>> of NIO is considered async
You want your client to first attempt to connect to the master (macserver).
So turn off randomization like this and see if your results are any
different.
failover:(tcp://macserver:61616,tcp://localhost:61616)?randomize=false&initialReconnectDelay=100
The documentation on the web site states t
1 - 100 of 228 matches
Mail list logo
