Re: Where to see acknowledgement in ActiveMQ Web console?

[Tim Bain]

Yes, message deletion results from message acknowledgement, so if you're
seeing messages getting deleted at the rate they're consumed, then your
acknowledgements are working.

Tim

On Jul 13, 2017 7:14 AM, "Abhijit Kangale"  wrote:

> Hi,
>
> In my project I have below functionality -
>
> 1)'datapump-messaging' module (Producer) writes messages to acitveMQ in
> queue (this module will create queue if already not present based on
> configuration).
> 2) 'datapump-services' module (Consumer) reads messages from the queue
> (created in step 1).
>
> In my consumer module I am using JMSTemplete to read the message from the
> queue. I am specifically using execute method of JmsTemplete to read the
> message. Code snippet below.
>
> Object message = companyQueueJmsTemplate.execute(new
> SessionCallback()
> {
> Object result = null;
>
> @Override
> public Object doInJms(Session session) throws JMSException
> {
> MessageConsumer consumer = session
>
> .createConsumer(companyQueueJmsTemplate.getDestinationResolver().
> resolveDestinationName(session,
> queueName, false));
>
> try
> {
> Message received = consumer.receive(5000);
> if (received != null)
> {
> result =
> companyQueueJmsTemplate.getMessageConverter().fromMessage(received);
>
> received.acknowledge();
> }
> }
> catch (Exception e)
> {
> logger.error("Error occurred pulling Message from
> Queue", e.getMessage());
> }
> finally
> {
> consumer.close();
> }
> return result;
> }
> }, true);
>
> Additionally while configuring JmsTemplete bean I have set
> 'CLIENT_ACKNOWLEDGE' mode.
>
> jmsTemplate.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
>
> As I am acknowledging using "received.acknowledge();", code works
> perfectly,
> but the question is where in ActiveMQ web console to verify that message is
> delivered and read by consumer properly? Do we have any such provision in
> console to verify, because as my consumer reads message it gets deleted
> from
> the queue?
>
> Thanks.
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Where-to-see-acknowledgement-in-ActiveMQ-
> Web-console-tp4728515.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Where to see acknowledgement in ActiveMQ Web console?

[Abhijit Kangale]

Hi,

In my project I have below functionality -

1)'datapump-messaging' module (Producer) writes messages to acitveMQ in
queue (this module will create queue if already not present based on
configuration). 
2) 'datapump-services' module (Consumer) reads messages from the queue
(created in step 1).

In my consumer module I am using JMSTemplete to read the message from the
queue. I am specifically using execute method of JmsTemplete to read the
message. Code snippet below.

Object message = companyQueueJmsTemplate.execute(new
SessionCallback()
{
Object result = null;

@Override
public Object doInJms(Session session) throws JMSException
{
MessageConsumer consumer = session
   
.createConsumer(companyQueueJmsTemplate.getDestinationResolver().resolveDestinationName(session,
queueName, false));

try
{
Message received = consumer.receive(5000);
if (received != null)
{
result =
companyQueueJmsTemplate.getMessageConverter().fromMessage(received);

received.acknowledge();
}
}
catch (Exception e)
{
logger.error("Error occurred pulling Message from
Queue", e.getMessage());
}
finally
{
consumer.close();
}
return result;
}
}, true);

Additionally while configuring JmsTemplete bean I have set
'CLIENT_ACKNOWLEDGE' mode.

jmsTemplate.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);

As I am acknowledging using "received.acknowledge();", code works perfectly,
but the question is where in ActiveMQ web console to verify that message is
delivered and read by consumer properly? Do we have any such provision in
console to verify, because as my consumer reads message it gets deleted from
the queue?

Thanks.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Where-to-see-acknowledgement-in-ActiveMQ-Web-console-tp4728515.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Active MQ - runtimeConfigurationPlugin - Set Message Priority - Not working

[Tim Bain]

Just to be sure: if you restart ActiveMQ with the policy in place, is it
applied as expected? I want to make sure that the only thing not working is
the application of the change at runtime.

On Jul 13, 2017 3:35 AM, "akpuvvada"  wrote:

> Hi Tim,
>
> You are correct that the property is not getting updated.
> Even in JConsole, I am not able to update this particular property.
> I guess this is not settable at Run-time.
> Any idea?
>
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Active-MQ-runtimeConfigurationPlugin-Set-Message-Priority-Not-
> working-tp4728264p4728516.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Re: /bin/activemq command not working

[Tim Bain]

Your port numbers don't match.

On Jul 13, 2017 4:21 AM, "xabhi"  wrote:

> Hi,
> I am trying to get destination stats using /bin/activemq command. This was
> earlier available via activemq-admin command. (
> http://activemq.apache.org/activemq-command-line-tools-reference.html
>   )
>
> ? ~/apache-activemq-5.14.4/bin/activemq dstat topics
> -Dactivemq.jmx.url=service:jmx:rmi:///jndi/rmi://mqbrokerqa:9011/jmxrmi
> ...
> Connecting to JMX URL: service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
> INFO: Broker not available at:
> service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
>
> It is not picking up the jmx url.
>
> However, below command works:
> ./activemq query --view InactiveDurableTopicSubscribers --jmxurl
> service:jmx:rmi:///jndi/rmi://mqbrokerqa:9011/jmxrmi
>
> Thanks,
> Abhi
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/bin-activemq-command-not-working-tp4728517.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

/bin/activemq command not working

[xabhi]

Hi,
I am trying to get destination stats using /bin/activemq command. This was
earlier available via activemq-admin command. (
http://activemq.apache.org/activemq-command-line-tools-reference.html
  )

? ~/apache-activemq-5.14.4/bin/activemq dstat topics
-Dactivemq.jmx.url=service:jmx:rmi:///jndi/rmi://mqbrokerqa:9011/jmxrmi 
...
Connecting to JMX URL: service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
INFO: Broker not available at:
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi

It is not picking up the jmx url.

However, below command works:
./activemq query --view InactiveDurableTopicSubscribers --jmxurl
service:jmx:rmi:///jndi/rmi://mqbrokerqa:9011/jmxrmi

Thanks,
Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/bin-activemq-command-not-working-tp4728517.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Active MQ - runtimeConfigurationPlugin - Set Message Priority - Not working

[akpuvvada]

Hi Tim,

You are correct that the property is not getting updated.
Even in JConsole, I am not able to update this particular property.
I guess this is not settable at Run-time.
Any idea?





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Active-MQ-runtimeConfigurationPlugin-Set-Message-Priority-Not-working-tp4728264p4728516.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.