[STRATOS-860] Error when publishing to health topic in CEP extensions

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 4.1.0 M1
• Fix Version/s: 4.1.0
• Component/s: CEP
• Assignee: Sajith
• Reporter: Sajith
• Created: 01/Oct/14 13:46
• Updated: 16/Jul/15 19:14
• Resolved: 16/Jul/15 19:14

Description

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)