streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dsulli...@apache.org
Subject svn commit: r1523037 - /incubator/streams/branches/cassandra/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java
Date Fri, 13 Sep 2013 17:57:49 GMT
Author: dsullivan
Date: Fri Sep 13 17:57:49 2013
New Revision: 1523037

URL: http://svn.apache.org/r1523037
Log:
adding log statements to subscriber

Modified:
    incubator/streams/branches/cassandra/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java

Modified: incubator/streams/branches/cassandra/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/cassandra/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java?rev=1523037&r1=1523036&r2=1523037&view=diff
==============================================================================
--- incubator/streams/branches/cassandra/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java
(original)
+++ incubator/streams/branches/cassandra/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java
Fri Sep 13 17:57:49 2013
@@ -16,6 +16,7 @@ public class ActivityStreamsSubscriberRe
     private static SubscriptionService subscriptionService = new CassandraSubscriptionService();
 
     public void process(Exchange exchange){
+        LOG.info("processing the subscriber...");
         //add the necessary headers to the message so that the activity registration component
         //can do a lookup to either make a new processor and endpoint, or pass the message
to the right one
         String httpMethod = exchange.getIn().getHeader("CamelHttpMethod").toString();
@@ -32,6 +33,7 @@ public class ActivityStreamsSubscriberRe
 
             String body = exchange.getIn().getBody(String.class);
 
+            LOG.info("receiving the subscriber: "+body);
             //OAuth token? What does subscriber post to init a subscription URL?
             //maybe its a list of URLs to subscribe to subscriptions=1,2,3,4&auth_token=XXXX
 



Mime
View raw message