[ 
https://issues.apache.org/jira/browse/QUARKS-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15231335#comment-15231335
 ] 

Daniel John Debrunner commented on QUARKS-131:
----------------------------------------------

> Some sort of "control bean registry service" 

There is a ControlService which registers the PeriodicMXBean already.

The issue is that it will not have a deterministic name, so a mechanism is 
needed that allows an application (topology) to assign a name to its periodic 
source.
Something like

TStream<JsonObject> rpm = topology().poll(..., 100, MILLISECONDS).*name("rpm")*;




> need easy way to get PeriodicMXBean associated with a poll() invocation
> -----------------------------------------------------------------------
>
>                 Key: QUARKS-131
>                 URL: https://issues.apache.org/jira/browse/QUARKS-131
>             Project: Quarks
>          Issue Type: Improvement
>            Reporter: Dale LaBossiere
>            Assignee: Dale LaBossiere
>
> I think we're missing some API is missing to make this all usable.
> A Topology/TStream domain user needs an easy way to get the PeriodicMXBean 
> for a particular Topology.poll() invocation. 
> The PeriodicSource oplet implements PeriodicMXBean which allows changing the 
> period.  
> The only demonstrated use is by 
> DirectJobTest.jobPeriodicSourceCancellation(), which iterates over the 
> Topology's underlying graph for instanceof PeriodicSource oplet (it's the 
> only ProcessSource oplet in the graph for this test).  
> That's certainly not easy / convenient / nor in the "TStream" domain the user 
> is mostly operating in.
> [~djd] [~vdogaru] what schemes for addressing this have already been 
> considered / decided?  Some sort of "control bean registry service" where a 
> user gets to supply a name (e.g., to poll()) and the runtime registers the 
> bean (e.g., PeriodicMXBean) under that name?  If there's not a concrete plan 
> lets work on that here.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to