streams-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jason Letourneau (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (STREAMS-11) Create configuration mechanism for Activity Publisher registration similar to the Subscriber registration
Date Tue, 05 Feb 2013 19:00:13 GMT

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

Jason Letourneau resolved STREAMS-11.
-------------------------------------

    Resolution: Implemented
    
> 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

Mime
View raw message