You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@stratos.apache.org by "Akila (JIRA)" <ji...@apache.org> on 2015/07/16 21:15:04 UTC
[jira] [Closed] (STRATOS-860) Error when publishing to health topic
in CEP extensions
[ https://issues.apache.org/jira/browse/STRATOS-860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Akila closed STRATOS-860.
-------------------------
Resolution: Fixed
Fix Version/s: 4.1.0
> Error when publishing to health topic in CEP extensions
> -------------------------------------------------------
>
> Key: STRATOS-860
> URL: https://issues.apache.org/jira/browse/STRATOS-860
> Project: Stratos
> Issue Type: Bug
> Components: CEP
> Affects Versions: 4.1.0 M1
> Reporter: Sajith Kariyawasam
> Assignee: Sajith Kariyawasam
> Fix For: 4.1.0
>
>
> Seeing the following exception when CEP extensions tries to publish to message broker
> TID: [0] [STRATOS] [2014-10-01 19:00:27,355] INFO {org.apache.stratos.cep.extension.FaultHandlingWindowProcessor} - Faulty member detected [member-id] test2.php.domain9280272f-ceb0-413c-b19c-717e00dbfc54 with [last time-stamp] 1412170141577 [time-out] 60000 milliseconds {org.apache.stratos.cep.extension.FaultHandlingWindowProcessor}
> TID: [0] [STRATOS] [2014-10-01 19:00:27,358] INFO {org.apache.stratos.cep.extension.FaultHandlingWindowProcessor} - Publishing member fault event for [member-id] test2.php.domain9280272f-ceb0-413c-b19c-717e00dbfc54 {org.apache.stratos.cep.extension.FaultHandlingWindowProcessor}
> TID: [0] [STRATOS] [2014-10-01 19:00:27,376] ERROR {org.apache.stratos.messaging.broker.publish.TopicPublisher} - Error while publishing to the topic: health/# {org.apache.stratos.messaging.broker.publish.TopicPublisher}
> java.lang.IllegalArgumentException
> at org.eclipse.paho.client.mqttv3.MqttAsyncClient.validateTopic(MqttAsyncClient.java:824)
> at org.eclipse.paho.client.mqttv3.MqttAsyncClient.publish(MqttAsyncClient.java:776)
> at org.eclipse.paho.client.mqttv3.MqttClient.publish(MqttClient.java:315)
> at org.apache.stratos.messaging.broker.publish.TopicPublisher.publish(TopicPublisher.java:85)
> at org.apache.stratos.cep.extension.FaultHandlingWindowProcessor.publishMemberFault(FaultHandlingWindowProcessor.java:206)
> at org.apache.stratos.cep.extension.FaultHandlingWindowProcessor.run(FaultHandlingWindowProcessor.java:223)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:744)
> TID: [0] [STRATOS] [2014-10-01 19:00:27,381] INFO {org.apache.stratos.messaging.broker.publish.TopicPublisher} - Will try to re-publish in 60 sec {org.apache.stratos.messaging.broker.publish.TopicPublisher}
> TID: [0] [STRATOS] [2014-10-01 19:01:27,382] ERROR {org.apache.stratos.messaging.broker.publish.TopicPublisher} - Error while publishing to the topic: health/# {org.apache.stratos.messaging.broker.publish.TopicPublisher}
> Client is connected (32100)
> at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:27)
> at org.eclipse.paho.client.mqttv3.MqttAsyncClient.connect(MqttAsyncClient.java:452)
> at org.eclipse.paho.client.mqttv3.MqttClient.connect(MqttClient.java:236)
> at org.apache.stratos.messaging.broker.publish.TopicPublisher.publish(TopicPublisher.java:84)
> at org.apache.stratos.cep.extension.FaultHandlingWindowProcessor.publishMemberFault(FaultHandlingWindowProcessor.java:206)
> at org.apache.stratos.cep.extension.FaultHandlingWindowProcessor.run(FaultHandlingWindowProcessor.java:223)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:744)
> TID: [0] [STRATOS] [2014-10-01 19:01:27,384] INFO {org.apache.stratos.messaging.broker.publish.TopicPublisher} - Will try to re-publish in 60 sec {org.apache.stratos.messaging.broker.publish.TopicPublisher}
> TID: [0] [STRATOS] [2014-10-01 19:02:27,385] ERROR {org.apache.stratos.messaging.broker.publish.TopicPublisher} - Error while publishing to the topic: health/# {org.apache.stratos.messaging.broker.publish.TopicPublisher}
> Client is connected (32100)
> at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:27)
> at org.eclipse.paho.client.mqttv3.MqttAsyncClient.connect(MqttAsyncClient.java:452)
> at org.eclipse.paho.client.mqttv3.MqttClient.connect(MqttClient.java:236)
> at org.apache.stratos.messaging.broker.publish.TopicPublisher.publish(TopicPublisher.java:84)
> at org.apache.stratos.cep.extension.FaultHandlingWindowProcessor.publishMemberFault(FaultHandlingWindowProcessor.java:206)
> at org.apache.stratos.cep.extension.FaultHandlingWindowProcessor.run(FaultHandlingWindowProcessor.java:223)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:744)
> TID: [0] [STRATOS] [2014-10-01 19:02:27,386] INFO {org.apache.stratos.messaging.broker.publish.TopicPublisher} - Will try to re-publish in 60 sec {org.apache.stratos.messaging.broker.publish.TopicPublisher}
> TID: [0] [STRATOS] [2014-10-01 19:03:27,387] ERROR {org.apache.stratos.messaging.broker.publish.TopicPublisher} - Error while publishing to the topic: health/# {org.apache.stratos.messaging.broker.publish.TopicPublisher}
> Client is connected (32100)
> at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:27)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)