@@ -35,24 +35,32 @@ public class ActivityStreamProcessor implements Processor {
3535 public static final String ACTIVITY_STREAM_OBJECT_ID = "ActivityStreamObjectId" ;
3636 public static final String ACTIVITY_STREAM_OBJECT_TYPE = "ActivityStreamObjectType" ;
3737
38+ private static final String OBJECT = "object" ;
39+ private static final String ID = "id" ;
40+ private static final String TYPE = "type" ;
41+ private static final String NAME = "name" ;
42+ private static final String ACTOR = "actor" ;
43+ private static final String INBOX = "inbox" ;
44+
3845 /**
3946 * Process an incoming ActivityStream message
4047 * @param exchange the Camel exchange
4148 * @throws IOException in the event of an error
4249 */
4350 public void process (final Exchange exchange ) throws IOException {
51+
4452 final Map body = exchange .getIn ().getBody (Map .class );
4553
46- setHeader (exchange , ACTIVITY_STREAM_ID , body .get ("id" ));
47- setHeader (exchange , ACTIVITY_STREAM_TYPE , body .get ("type" ));
48- setHeader (exchange , ACTIVITY_STREAM_NAME , body .get ("name" ));
49- setHeader (exchange , ACTIVITY_STREAM_ACTOR , body .get ("actor" ));
50- setHeader (exchange , ACTIVITY_STREAM_INBOX , body .get ("inbox" ));
54+ setHeader (exchange , ACTIVITY_STREAM_ID , body .get (ID ));
55+ setHeader (exchange , ACTIVITY_STREAM_TYPE , body .get (TYPE ));
56+ setHeader (exchange , ACTIVITY_STREAM_NAME , body .get (NAME ));
57+ setHeader (exchange , ACTIVITY_STREAM_ACTOR , body .get (ACTOR ));
58+ setHeader (exchange , ACTIVITY_STREAM_INBOX , body .get (INBOX ));
5159
52- if (body .containsKey ("object" ) && body .get ("object" ) instanceof Map ) {
53- final Map object = (Map ) body .get ("object" );
54- setHeader (exchange , ACTIVITY_STREAM_OBJECT_ID , object .get ("id" ));
55- setHeader (exchange , ACTIVITY_STREAM_OBJECT_TYPE , object .get ("type" ));
60+ if (body .containsKey (OBJECT ) && body .get (OBJECT ) instanceof Map ) {
61+ final Map object = (Map ) body .get (OBJECT );
62+ setHeader (exchange , ACTIVITY_STREAM_OBJECT_ID , object .get (ID ));
63+ setHeader (exchange , ACTIVITY_STREAM_OBJECT_TYPE , object .get (TYPE ));
5664 }
5765 }
5866
0 commit comments