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)
