With a forwarding bridge in-place between a remote collector and the central
server, a queue that is created on the collector will not automatically be
reflected/created on the server. You either have to define a queue in the
server broker's cfg file or have clients, which are connected to the se
Eric,
Move to the latest 5.1.1 SNAPSHOT. I think your 'duplex' configuration will
work much better with that SNAPSHOT.
Joe
Eric-AWL wrote:
>
> You were right ttmdev.
> In a half-duplex configuration, it works !
>
> Like you tell it to me, I had to add &q
Here's a sample spring cfg file that I've used to start an 'embedded'
ActiveMQ broker. Note how the connectionFactory bean points the embedded
broker to an external ActiveMQ broker cfg file, which I have also included
below. Within the broker cfg file you can define your transport and network
conn
It looks to me like your message listener is blocked. If there is a message
listener in-progress, the close method for a session or consumer blocks
until that in-progress message listener has completed.
You don't have to close the session to change a selector. Close your
existing consumer and cr
Can't help you re the exception you're getting. However, I do suggest that if
you do not require the jetty servlet engine, that you comment it out of your
embedded broker's xml cfg file. Not running the servlet engine really cuts
down on the overall total number of threads created by the jvm and a
connectionfactory.createQueueConnection(usr,pwd) is simply overriding the
userid and password that was assigned to the connectionfactory when it was
instantiated via its ActiveMQConnectionFactory(user, password, url)
constructor. AFAIK, you cannot dynamically add users; the default broker
security
Well, in theory it should work because it appears to conform to the proper
syntax. That is, failover://(uri1,...,uriN)?TransportOptions
I gave it a quick try, and here are my results. Note that in your case, you
should have randomize set to false because you first want to connect via the
discover
I am using the 5.1 SNAPSHOT and this failover uri works for me.
failover://(tcp://localhost:61616?wireFormat.cacheEnabled=false&wireFormat.maxInactivityDuration=0&wireFormat.tightEncodingEnabled=true)?maxReconnectDelay=1000
Jason Rosenberg wrote:
>
> I think the uri parsing doesn't like nested
Hi Sean,
Curious to know the average message size used and whether you used the
default broker configuration?
Thanks,
Joe
www.ttmsolutions.com
Sean Bastille-2 wrote:
>
> I guess my first message was too long, but that's alright, I ended up
> getting the answers I needed. I figured I should l
ent priorities into different queues
> - Have the clients (STOMP is this case) subscribe to the various priority
> queues
> - The clients select() on all the sockets and when data is ready to be
> read,
> the client reads from socket of the highest priority queue.
>
> Sugg
ould do what I'm looking for (maybe
> you
> can explain further).
>
> I'd like the same group of consumers to process messages with different
> priorities but to give preference in the order of processing to higher
> priority messages.
>
> On Feb 12, 2008 11:01
You may want to try using the 'failover' transport. With the example below,
if the broker fails the transport will begin retrying the connection to the
broker. You may want to use a different maxReconnectDelay.
failover://(tcp://localhost:61616)?maxReconnectDelay=1000
Joe
www.ttmsolutions.com
Hi Roger,
I'd disregard the consumer priority feature; it does not function as
described in the consumer priority page.
Here's the exclusive consumer web page.
http://activemq.apache.org/exclusive-consumer.html
Joe
www.ttmsolutions.com
Roger Hoover wrote:
>
> I want to implement a
Re the reference to "AIO", does this mean support for AIO4J or that AMQ's use
of NIO is considered asynchronous i/o?
Joe
rajdavies wrote:
>
>
> On Feb 14, 2008, at 12:05 AM, davewolfs wrote:
>
>>
>> Hello everyone,
>>
>> I am hoping that some of you could provide me with some realistic
>>
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
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
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
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 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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
>
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
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?
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
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
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
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
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
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
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:
>>
>
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
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
/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 ?
>>
>>
>>
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
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
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
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:
>
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
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
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:
>
>
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.
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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.
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
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
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
;
> 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
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:
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
> 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
> 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
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.
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?
>
>
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
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.
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
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
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
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
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
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 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
1 - 100 of 228 matches
Mail list logo
