Re: Interceptor for MQTT

[Martyn Taylor]

Hi Vicky

On 2 Jul 2016 19:33, "aries.aries"  wrote:
>
> Hi,
>
> Is there any other way to get the messages that has been published to the
> MQTT broker? Please help.

What do you mean by get the messages?

Can you let us know what is it that you're trying to achieve?
>
> Thanks,
> Vicky
Thanks
Martyn
>
> On Fri, Jul 1, 2016 at 1:59 AM, Justin Bertram-2 [via ActiveMQ] <
> ml-node+s2283324n4713526...@n4.nabble.com> wrote:
>
> > It's not working because that feature is not implemented in the broker
as
> > I stated in a previous email.  There's no way to get it working unless
you
> > modify the broker to support it.
> >
> >
> > Justin
> >
> > - Original Message -
> > From: "vicky" <[hidden email]
> > >
> > To: [hidden email] 
> > Sent: Wednesday, June 29, 2016 8:39:29 AM
> > Subject: Re: Interceptor for MQTT
> >
> > Hi,
> >
> > I am facing the same issue.
> > The interceptor is not working for MQTT messages.
> > The pub/sub is working though.
> > Please help me if you were able to get it working.
> >
> > Thanks,
> > Vicky
> >
> >
> >
> > --
> > If you reply to this email, your message will be added to the discussion
> > below:
> >
> >
http://activemq.2283324.n4.nabble.com/Interceptor-for-MQTT-tp4713408p4713526.html
> > To unsubscribe from Interceptor for MQTT, click here
> > <
http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code=4713408=YXJpZXMxMjMuYXJpZXMxMjNAZ21haWwuY29tfDQ3MTM0MDh8MTQzNzc4NzUxNw==
>
> > .
> > NAML
> > <
http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer=instant_html%21nabble%3Aemail.naml=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml
>
> >
>
>
>
>
> --
> View this message in context:
http://activemq.2283324.n4.nabble.com/Interceptor-for-MQTT-tp4713408p4713539.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Interceptor for MQTT

[aries.aries]

Hi,

Is there any other way to get the messages that has been published to the
MQTT broker? Please help.

Thanks,
Vicky

On Fri, Jul 1, 2016 at 1:59 AM, Justin Bertram-2 [via ActiveMQ] <
ml-node+s2283324n4713526...@n4.nabble.com> wrote:

> It's not working because that feature is not implemented in the broker as
> I stated in a previous email.  There's no way to get it working unless you
> modify the broker to support it.
>
>
> Justin
>
> - Original Message -
> From: "vicky" <[hidden email]
> >
> To: [hidden email] 
> Sent: Wednesday, June 29, 2016 8:39:29 AM
> Subject: Re: Interceptor for MQTT
>
> Hi,
>
> I am facing the same issue.
> The interceptor is not working for MQTT messages.
> The pub/sub is working though.
> Please help me if you were able to get it working.
>
> Thanks,
> Vicky
>
>
>
> --
> If you reply to this email, your message will be added to the discussion
> below:
>
> http://activemq.2283324.n4.nabble.com/Interceptor-for-MQTT-tp4713408p4713526.html
> To unsubscribe from Interceptor for MQTT, click here
> 
> .
> NAML
> 
>




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Interceptor-for-MQTT-tp4713408p4713539.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ Web Console

[suwie]

For any ActiveMQ expert out there, Does anyone know why the messages enqueued
is always increasing and the messages dequeued is always zero within the
Topics.jsp web page of ActiveMQ web console?

Do they actually occupy some percentage of the available storage? If they
do, how can we keep the numbers down or even clean them up regularly?

We regularly getting problem with full store usage after running for a while
and was wondering if this is one of the causes.

If someone can shed some light on this, that would be great.

 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-Web-Console-tp4713538.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ vs Tibco EMS Performance

[RaghuBaddam]

Hi All,

I am testing with both ActiveMQ and Tibco servers and the results are not
comparable so my question is 

In Tibco we have Sync store and Async stores,so what are the equivalent test
cases in ActiveMQ ?

concurrent store and dispatch = True/false
enableJournalDiskSyncs =  True/false

Can someone help me with their ideas.

or

I wants to know the equivalent parameters of ActiveMQ in Tibco:
concurrent store and dispatch =
enableJournalDiskSyncs = 

equivalent parameters of Tibco in ActiveMQ:
Async store = 
Sync store = 
Fsync =

https://issues.apache.org/jira/browse/AMQ-6314
  



-
Raghu Baddam
--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-vs-Tibco-EMS-Performance-tp4713510.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Interceptor for MQTT

[aries.aries]

Hi,

Is there any other way to get the messages that has been published to the
MQTT broker? Please help.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Interceptor-for-MQTT-tp4713408p4713523.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Need help to Improve ActiveMQ performance

[RaghuBaddam]

Hi,

I am testing ActiveMQ and the performance is too low if I use
enableJournalDiskSyncs (400 msgs / sec of 10kb) and If I disable
enableJournalDiskSyncs (4000 msgs / sec of 10kb) It is really 10times
increase in performance, I tuned almost all the ActiveMQ parameters but It
is not giving any better results, I know that If I enable
concurrentStoreAndDispatchQueues, we will get good results but before that I
want to understand that, Is there any other way we can Increase our
performance(I know using Transacted session is an option but we have
multiple applications so we can’t Insist everyone to use Transacted session
:( ) 

Is there there any way we can avoid fsync each time with no message loss ?

We are trying to reach a point where there is No message loss and Good
performance with ActiveMQ.

Basically we are migrating from Tibco EMS to ActiveMQ, so we really need
your help. 

Thanks in Advance
Raghu Baddam



-
Raghu Baddam
--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Need-help-to-Improve-ActiveMQ-performance-tp4713527.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

JMX Output for activemq query changed between 5.10 vs 5.13.3

[gkgarg24]

Hi

I am using activemq commandline tool to get Subscriber data using command 

*./activemq-admin query -QTopic= Test.Foo* in 5.10 and *./activemq query
-QTopic=Test.Foo* in 5.13.

but the output is different in these 2 case.  I noticed because I needed
attributes which were available in 5.10

Does someone know if JMX output is changed in 5.13?  I have highlighted the
output present in 5.10 but missing in 5.13

 5.10 *
AverageMessageSize = 2517.0
UseCache = true
MemoryPercentUsage = 0
Name = Test.Foo
BlockedProducerWarningInterval = 3
MaxMessageSize = 2517
MemoryUsagePortion = 1.0
destinationType = Topic
BlockedSends = 0
EnqueueCount = 10
TotalBlockedTime = 0
Options =
MinMessageSize = 2517
Subscriptions =
[org.apache.activemq:type=Broker,brokerName=msgq-01.masterbroker-1,destinationType=Topic,destinationName=Test.Foo,endpoint=Consumer,clientId=app-02-scl,consumerId=Durable(app-02-scl_TEST-SUB1)]
PrioritizedMessages = false
DLQ = false
AlwaysRetroactive = false
AverageEnqueueTime = 0.0
DispatchCount = 0
AverageBlockedTime = 0.0
destinationName = Test.Foo
MemoryLimit = 6442450944
MaxProducersToAudit = 64
ProducerFlowControl = false
QueueSize = 0
ConsumerCount = 1
MaxEnqueueTime = 0
MaxAuditDepth = 2048
InFlightCount = 0
MemoryUsageByteCount = 0
ExpiredCount = 0
brokerName = msgq-01.masterbroker-1
DequeueCount = 0
MaxPageSize = 5000
MinEnqueueTime = 0
ProducerCount = 0
type = Broker

*DestinationTopic = true
DestinationName = Test.Foo
DequeueCounter = 0
DestinationTemporary = false
SessionId = 0
SubcriptionName = TEST-SUB1
EnqueueCounter = 0
PrefetchSize = 1000
Exclusive = false
Network = false
Retroactive = false
SubscriptionId = -1
Active = false
destinationType = Topic
clientId = app-02-scl
endpoint = Consumer
DispatchedQueueSize = 0
CursorPercentUsage = 0
ConnectionId = NOTSET
ConsumedCount = 0
Durable = false
CursorMemoryUsage = 983373
destinationName = Test.Foo
consumerId = Durable(app-02-scl_TEST-SUB1)
DestinationQueue = false
PendingQueueSize = 0
DispatchedCounter = 0
SubcriptionId = -1
SlowConsumer = false
SubscriptionName = TEST-SUB1
MessageCountAwaitingAcknowledge = 0
MaximumPendingMessageLimit = 0
CursorFull = false
Priority = 0
ClientId = app-02-scl
brokerName = msgq-01.masterbroker-1
NoLocal = false
type = Broker*


* 5.13.3**

AverageMessageSize = 0
UseCache = true
MemoryPercentUsage = 0
Name = Test.Foo
BlockedProducerWarningInterval = 3
MaxMessageSize = 0
MemoryUsagePortion = 1.0
destinationType = Topic
BlockedSends = 0
StoreMessageSize = 90955
EnqueueCount = 0
TotalBlockedTime = 0
Options =
MinMessageSize = 0
Subscriptions =
[org.apache.activemq:type=Broker,brokerName=dev.load-02.masterbroker-1,destinationType=Topic,destinationName=Test.Foo,endpoint=Consumer,clientId=app-03-vm-pool-2-thread-1,consumerId=Durable(app-03-vm-pool-2-thread-1_TEST-SUB1),
org.apache.activemq:type=Broker,brokerName=dev.load-02.masterbroker-1,destinationType=Topic,destinationName=Test.Foo,endpoint=Consumer,clientId=cl2-pool-2-thread-1,consumerId=Durable(cl2-pool-2-thread-1_TEST-SUB1),
org.apache.activemq:type=Broker,brokerName=dev.load-02.masterbroker-1,destinationType=Topic,destinationName=Test.Foo,endpoint=Consumer,clientId=app-02-cl-pool-2-thread-1,consumerId=Durable(app-02-cl-pool-2-thread-1_TEST-SUB1),
org.apache.activemq:type=Broker,brokerName=dev.load-02.masterbroker-1,destinationType=Topic,destinationName=Test.Foo,endpoint=Consumer,clientId=app-02-scl,consumerId=Durable(app-02-scl_TEST-SUB1)]
PrioritizedMessages = false
DLQ = false
AlwaysRetroactive = false
AverageEnqueueTime = 0.0
ForwardCount = 0
DispatchCount = 0
AverageBlockedTime = 0.0
destinationName = Test.Foo
MemoryLimit = 6012954214
MaxProducersToAudit = 64
ProducerFlowControl = false
QueueSize = 0
ConsumerCount = 4
MaxEnqueueTime = 0
MaxAuditDepth = 1
InFlightCount = 0
MemoryUsageByteCount = 0
ExpiredCount = 0
brokerName = dev.load-02.masterbroker-1
DequeueCount = 0
MaxPageSize = 5000
MinEnqueueTime = 0
ProducerCount = 0
type = Broker



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/JMX-Output-for-activemq-query-changed-between-5-10-vs-5-13-3-tp4713437.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

A small fraction of messages remaining in queue forever.

[Kamal Vaddadi]

We have noticed that, when running with high throughput, a small fraction of
messages are not getting consumed even though the consumers are active.
These messages are remaining forever in a queue until broker is restarted. 


Does anyone know in what circumstances this can happen and how to diagnose
and ideally avoid it? We are using

ActiveMQ: version 5.10.0
Database: Oracle
JVM: 1.8 
Queue Type: persistent


Thank you




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/A-small-fraction-of-messages-remaining-in-queue-forever-tp4713429.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Kahadb vs Leveldb vs Replciated Leveldb] Performance Results

[tisasmith]

Hello,

Informative article. Thanks a lot for sharing such nice information here. 

Regards
* Buy Generic Levitra   *



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Kahadb-vs-Leveldb-vs-Replciated-Leveldb-Performance-Results-tp4688306p4713410.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Dose the ActiveMQ broker support Virtualhost Feature?

[Steven]

Hello,everyone

My ActiveMQ broker's version is "5.13.3",Does this version ActiveMQ
broker support Virtualhost Feature?If it was supported,Could you tell me
that how to configure the broker?Thanks in Advance.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Dose-the-ActiveMQ-broker-support-Virtualhost-Feature-tp4713409.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] Error message in log file for cluster on v1.3

[abhijith]

Hi,

We have a master/slave configuration with static connectors.  This was
working fine till we upgraded to v1.3 yesterday.

With 1.3 we are constantly seeing below ERROR message being logged.

21:12:59,991 ERROR [org.apache.activemq.artemis.core.client] AMQ214016:
Failed to create netty connection: java.nio.channels.ClosedChannelException

With the frequency of the log, I thought it might be the slave connection. 
But slave itself declares as backup, so I am pretty sure master/slave setup
is fine.

19:48:23,936 ERROR [org.apache.activemq.artemis.core.client] AMQ214016:
Failed to create netty connection: java.nio.channels.ClosedChannelException
19:48:26,004 ERROR [org.apache.activemq.artemis.core.client] AMQ214016:
Failed to create netty connection: java.nio.channels.ClosedChannelException
19:48:28,054 ERROR [org.apache.activemq.artemis.core.client] AMQ214016:
Failed to create netty connection: java.nio.channels.ClosedChannelException

19:48:30,168 INFO  [org.apache.activemq.artemis.core.server] AMQ221109:
Apache ActiveMQ Artemis Backup Server version 1.3.0 [null] started, waiting
live to fail before it gets active
19:48:31,316 INFO  [org.apache.activemq.artemis.core.server] AMQ221024:
Backup server
ActiveMQServerImpl::serverUUID=1a465752-3ca0-11e6-bc64-020820d3a150 is
synchronized with live-server.
19:48:31,410 INFO  [org.apache.activemq.artemis.core.server] AMQ221031:
backup announced

It does not give any other error message.  So kind of lost on why this is
happening.  Messages itself flow through fine.

Thanks
Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Error-message-in-log-file-for-cluster-on-v1-3-tp4713397.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.