You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@stratos.apache.org by "Sajith Kariyawasam (JIRA)" <ji...@apache.org> on 2014/10/01 15:47:33 UTC
[jira] [Created] (STRATOS-860) Error when publishing to health
topic in CEP extensions
Sajith Kariyawasam created STRATOS-860:
------------------------------------------
Summary: 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
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)