stratos-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nirmal Fernando <nirmal070...@gmail.com>
Subject Re: [1/2] git commit: Updated TopicPublisher.publish(Object) method to set event class name header property
Date Wed, 23 Oct 2013 05:33:20 GMT
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, <imesh@apache.org> 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 <imesh@apache.org>
> Authored: Wed Oct 23 10:55:27 2013 +0530
> Committer: Imesh Gunaratne <imesh@apache.org>
> 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/

Mime
View raw message