i am unable to see username neither with stomp with ws neither with tcp
.
i am putting this rule to camel so i can see it in file . and no
solution :(
\r\n${date:now:MMdd-hh-mm-ss} ${in.body} ::${headers}
\r\n
\r\n${date:now:MMdd-h
What do your STOMP headers look like? If you use the header property
called "login", then the use name should be set in the ConnectionInfo on
the advisory. I just double checked this and ran a test using STOMP over
WS and I did indeed get an advisory message with the user name property set.
On W
i think yes ... because if i dont put user i am unable to get access (using
web socket in the demo application)
so it must be set or perhaps the ws doesnt set user? that is why i
am asking when connecting ... the connectioninfo is not in the
advisory of connection (perhaps it must b
If the user name has been set it would be under the dataStructure field
inside the ConnectionInfo object. Just like in your previous message you
can see a ConsumerInfo object when listening for new consumers. Are you
sure you are setting the user name/credentials when making a connection?
When I
it seems that the headers are set with no message .. but in the headers
i dont see the username (guest) only headers of the message
On Wed, Jun 17, 2015 at 8:37 AM, ALi wrote:
> this is what i see with this two routes
>
>
> uri="activemq:topic:ActiveMQ.Advisory.Consumer.Queue.TEST.Q?mapJms
this is what i see with this two routes
\r\n${date:now:MMdd-hh-mm-ss} ${in.body} \r\n
\r\n${date:now:MMdd-hh-mm-ss} ${in.body} \r\n
20150617-08-31-04
20150617-08-31-37
20150617-08-31-37 ActiveMQMessage {commandId = 0, responseRe
No problem, let me know if you have any more questions.
Chris
On Tue, Jun 16, 2015 at 9:13 AM, ALi wrote:
> Thank you very nice explanation I will try in this manner
>
Thank you very nice explanation I will try in this manner
The advisory topic "ActiveMQ.Advisory.Consumer.Queue.TEST.Q" will send
messages alerting you of new consumers and you will receive a
"ConsumerInfo" object which won't contain the user name. That will contain
a reference to the consumerId instead, since the connection was already
created. The cons
i dont know where i am connecting with stomp and ws . this is what
this log shows:
(using camel to print message)
\r\n${date:now:MMdd-hh-mm-ss} ${in.header.user}
${in.body} ${in.headers} \r\n
20150616-01-16-27 ActiveMQMessage {commandId = 0, responseRequ
Advisory messages delivered to ActiveMQ.Advisory.Connection will contain a
ConnectionInfo object as part of the data structure field of the message.
That object will contain the user name used for the new connection.
Passwords will always be cleared, however.
On Tue, Jun 16, 2015 at 5:41 AM, ALi
Ah, I see - thank you for the clarification.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Advisory-messages-do-not-forward-on-staticallyIncludedDestinations-tp4680733p4681115.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
thanks, but I get
INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@e553e814:
startup date [Thu May 08 14:20:33 CEST 2014]; root of context hierarchy
ERROR | Failed to load: class path resource [activemq.xml], reason: Line 44
in XML document from class path resource [activemq.xml]
Hi,
Cheers,
Felix
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Advisory-messages-do-not-forward-on-staticallyIncludedDestinations-tp4680733p4680997.html
Sent from the ActiveMQ - User mailing li
Thanks Felix, that did the trick.
@artnaseef
I just want to extract the queue statistics and forwarded through the static
bridged network.
As the created message gets JMSType of 'Advisory' (do not know why) broker
did not let the message to pass through.
Advisories are disabled in my system and I
Can you give some detail to the problem?
Advisory topics have a very specific usage in the brokers, especially with a
network-of-brokers. Would it be possible to acheive the goal with a regular
Topic instead of an advisory one?
--
View this message in context:
http://activemq.2283324.n4.nabbl
even if statically configured, there are still subscriptions in the
mix. If you apply that policy to add topics using a wildcard it should
get picked up.
On 4 May 2014 16:16, nader wrote:
> Thanks for quick answer and sorry for my late response.
>
> I am really not sure if I understand the solut
Thanks for quick answer and sorry for my late response.
I am really not sure if I understand the solution you are providing here.
How can I permit forward 'Advisory' messages using
?
Would you please give an example?
In my network, consumers do not use subscription, as all routes are defined
sta
That is intentional because the network bridge will intercept and
react to certain advisory messages, but that decision went before the
use of the advisory type for the statistics broker. I guess the
statistics broker could use a different 'type'
This behaviour is implemented in a subscription fil
atlast i got it resolved..
This is how it works now..
Defined a topic
in my embedded broker.
Defined a listener class (which is the java class which will have the logic
built in to identify whether
a connection has been obtained/lost)
Defined a container using the DefaultMessageListenerCont
In almost similar scenario, I put TimeToLive properties in the messages.
In they aren't consumed after certain periods, it will go to default queue
(ActiveMQ.DLQ if i'm not mistaken)
On Thu, May 26, 2011 at 6:26 PM, Aneesh wrote:
> Hi
>
> Am pretty new to ActiveMQ and i am now looking for a sol
Hi ,
I know an alternate solution for ur problem.
use JMX . ur producer periodically checks for the size of the queue and
if the number of messages is greater than some 'count' ( specified by user
) , producer will wait until the number of messages goes below the 'count' .
take a loo
Hi Gary
Went quickly through the junits and got a rough idea.
Now coming to my requirement, my environment is ActiveMQ 5.2 integrated with
JBoss
and using Spring for configuring the broker and the producer/consumer.
For example i have a queue having the physical name outbound.queue and when
the s
Hi Gary
Thanks a lot for the guidance..
Let me have a look into that and will get back..
Thanks
Aneesh
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Advisory-Messages-tp3552270p3552449.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
start with the activemq junit tests to see how the advisories are used:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/
also, have a peek at the Abort slow consumer test. You could provide
your own implementation of a slow consumer strategy th
Thanks Tim. It works on Command instance.
-Original Message-
From: Timothy Bish [mailto:tabish...@gmail.com]
Sent: 03 May 2011 18:43
To: users@activemq.apache.org
Subject: Re: Advisory Messages - isConnectionInfo() and isRemoveInfo() methods
On Tue, 2011-05-03 at 18:10 +0100, Suneel
On Tue, 2011-05-03 at 18:10 +0100, Suneel Papineni wrote:
> Hi,
>
>
>
> I am trying to see if "isConnectionInfo() and isRemoveInfo()" methods
> are working fine. Created a consumer with a destination
> "ActiveMQ.Advisory.Connection" and implemented following code in
> onMessage() method.
>
> #
On Thu, 2011-02-10 at 14:14 +, Suneel Papineni wrote:
> Hi,
>
>
>
> I am using ActiveMQ 5.4.2 and NMS 1.5.0. As a producer I want to know
> what are all consumers connected to Message bus and what messages they
> are sending when they got connected or disconnected.
>
> I believe this can b
I have adapted the Camel route and now I'm able to receive the message
Here is an example for the destination :
topic://ActiveMQ.Advisory.Consumer.Queue.IN
10:28:44,140 | INFO | tenerContainer-1 | elca |
rg.apache.camel.processor.Logger 88 | Ex
On Mar 10, 2010, at 2:19 PM, cmoulliard wrote:
> I have defined a camel route to read messages published in the topics for
> advisory
>
> ex :
>
>uri="activemq:topic:ActiveMQ.Advisory.Consumer.Queue.IN" />
>
>
>
>
>
> Surprisingly, the body receive
Hi there,
you can browse the AdvisorySupport class and navigate from there to
understand
which objects are used to create the Advisory messages.
This having said, the architecture sounds a bit strange to me. One
reason why you use
JMS is to decouple producers and consumers. If I understand
31 matches
Mail list logo
