Thanks Imesh. Now it looks cleaner and easy to handle at the publisher's level.
Thanks, Reka On Wed, Oct 23, 2013 at 11:33 AM, Nirmal Fernando <[email protected]>wrote: > Thanks Imesh. It looks good now. > > > On Wed, Oct 23, 2013 at 11:25 AM, Imesh Gunaratne <[email protected]>wrote: > >> Hi Nirmal, >> >> Thanks, yes I think I misunderstood the intention of the TopicPublisher. >> I just introduced an event publisher (which was missing earlier) to >> publish events with their header values. >> >> Thanks >> Imesh >> >> >> On Wed, Oct 23, 2013 at 11:03 AM, Nirmal Fernando <[email protected] >> > wrote: >> >>> Imesh, >>> >>> You have misinterpreted the API here. Please revert this and use the >>> 'publish(Object messageObj, Properties headers)' API operation. It's a duty >>> of the message publisher to set what ever the headers it needs to send. >>> >>> >>> On Wed, Oct 23, 2013 at 10:56 AM, <[email protected]> wrote: >>> >>>> Updated Branches: >>>> refs/heads/master 89191d74a -> ba0f6dd66 >>>> >>>> >>>> Updated TopicPublisher.publish(Object) method to set event class name >>>> header property >>>> >>>> >>>> Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo >>>> Commit: >>>> http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/2bb5c37a >>>> Tree: >>>> http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/2bb5c37a >>>> Diff: >>>> http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/2bb5c37a >>>> >>>> Branch: refs/heads/master >>>> Commit: 2bb5c37a9dd0022f5ec7e0d606eae56d6cd929e0 >>>> Parents: 4bbae15 >>>> Author: Imesh Gunaratne <[email protected]> >>>> Authored: Wed Oct 23 10:55:27 2013 +0530 >>>> Committer: Imesh Gunaratne <[email protected]> >>>> Committed: Wed Oct 23 10:55:27 2013 +0530 >>>> >>>> ---------------------------------------------------------------------- >>>> .../stratos/messaging/broker/publish/TopicPublisher.java | 6 >>>> ++++-- >>>> 1 file changed, 4 insertions(+), 2 deletions(-) >>>> ---------------------------------------------------------------------- >>>> >>>> >>>> >>>> http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/2bb5c37a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/publish/TopicPublisher.java >>>> ---------------------------------------------------------------------- >>>> diff --git >>>> a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/publish/TopicPublisher.java >>>> b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/publish/TopicPublisher.java >>>> index 59ecd85..1c73399 100644 >>>> --- >>>> a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/publish/TopicPublisher.java >>>> +++ >>>> b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/publish/TopicPublisher.java >>>> @@ -30,6 +30,7 @@ import >>>> org.apache.stratos.messaging.broker.connect.TopicConnector; >>>> import org.apache.stratos.messaging.publish.MessagePublisher; >>>> >>>> import com.google.gson.Gson; >>>> +import org.apache.stratos.messaging.util.Constants; >>>> >>>> /** >>>> * Any instance who needs to publish data to a topic, should >>>> communicate with >>>> @@ -63,8 +64,9 @@ public class TopicPublisher extends MessagePublisher { >>>> * obtained. >>>> */ >>>> public void publish(Object messageObj) { >>>> - >>>> - publish(messageObj, null); >>>> + Properties properties = new Properties(); >>>> + properties.put(Constants.EVENT_CLASS_NAME, >>>> messageObj.getClass().getName()); >>>> + publish(messageObj, properties); >>>> } >>>> >>>> public void publish(Object messageObj, Properties headers) { >>>> >>>> >>> >>> >>> -- >>> Best Regards, >>> Nirmal >>> >>> Nirmal Fernando. >>> PPMC Member & Committer of Apache Stratos, >>> Senior Software Engineer, WSO2 Inc. >>> >>> Blog: http://nirmalfdo.blogspot.com/ >>> >> >> > > > -- > Best Regards, > Nirmal > > Nirmal Fernando. > PPMC Member & Committer of Apache Stratos, > Senior Software Engineer, WSO2 Inc. > > Blog: http://nirmalfdo.blogspot.com/ > -- Reka Thirunavukkarasu Software Engineer, WSO2, Inc.:http://wso2.com, Mobile: +94776442007
