[
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)
