You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@streams.apache.org by "Jason Letourneau (JIRA)" <ji...@apache.org> on 2013/02/05 15:29:14 UTC

[jira] [Assigned] (STREAMS-11) Create configuration mechanism for Activity Publisher registration similar to the Subscriber registration

     [ https://issues.apache.org/jira/browse/STREAMS-11?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jason Letourneau reassigned STREAMS-11:
---------------------------------------

    Assignee: Jason Letourneau
    
> Create configuration mechanism for Activity Publisher registration similar to the Subscriber registration
> ---------------------------------------------------------------------------------------------------------
>
>                 Key: STREAMS-11
>                 URL: https://issues.apache.org/jira/browse/STREAMS-11
>             Project: Streams
>          Issue Type: Improvement
>            Reporter: Jason Letourneau
>            Assignee: Jason Letourneau
>
> Publishers should post JSON with authToken and class of the Consumer they want created with any appropriate configuration.  this should involve creating a new class for the configuration (like the subscriber configuration in the activity-subscriber bundle).  A PushConsumer is currently returned, but that should be an interface from the registration module, the actual implementation is deserialized by jackson in the registration processor.  The subscription reg mechinism classes of reference to create this consumer registration mechanism are: ActivityStreamsSubscriberRegistrationProcessor, ActivityStreamsSubscriberRegistrationImpl, and ActivityStreamsSubscription.  Example current JSON for subscriber is below.  Consumer will be simpler:
> {
>     "authToken": "token",
>     "@class":"org.apache.streams.osgi.components.activitysubscriber.impl.ActivityStreamsSubscriptionImpl",
>     "filters": [
>         {
>             "@class":"org.apache.streams.osgi.components.activitysubscriber.impl.ActivityStreamsSubscriptionLuceneFilterImpl",
>             "query": "string represented query of type expected by filter implementation"
>         }
>     ],
>     "outputs": [
>         {
>             "output_type": "http",
>             "method": "post",
>             "url": "http.example.com:8888",
>             "delivery_frequency": "60",
>             "max_size": "10485760",
>             "auth_type": "none",
>             "username": "username",
>             "password": "password"
>         }
>     ]
> }

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira