Showing
1 changed file
with
1 additions
and
1 deletions
@@ -582,7 +582,7 @@ public class DefaultTransportService implements TransportService { | @@ -582,7 +582,7 @@ public class DefaultTransportService implements TransportService { | ||
582 | throw new TkDataValidationException(ErrorMessage.INVALID_TOPIC.getMessage()); | 582 | throw new TkDataValidationException(ErrorMessage.INVALID_TOPIC.getMessage()); |
583 | } | 583 | } |
584 | String[] eventInfo = topicInfo[1].split("/"); | 584 | String[] eventInfo = topicInfo[1].split("/"); |
585 | - if(null == eventInfo || eventInfo.length !=3){ | 585 | + if(null == eventInfo || eventInfo.length !=2){ |
586 | throw new TkDataValidationException(ErrorMessage.INVALID_TOPIC.getMessage()); | 586 | throw new TkDataValidationException(ErrorMessage.INVALID_TOPIC.getMessage()); |
587 | } | 587 | } |
588 | reportActivityInternal(sessionInfo); | 588 | reportActivityInternal(sessionInfo); |