Re: [Jcyclone-users] a few questions
Brought to you by:
jm7
|
From: Alexandre V. <ava...@gm...> - 2006-12-20 23:10:38
|
Thanks Toli for sharing this I had a look at your code but it just gives me really basic clue on how to build a up a chain of stage. May be I should describe some more what I am looking for: Basically I have an app that process events say with "void pushEvent(X)" which is thread safe but not multithreaded in anyway ie you send an event in and it sends an event out (say computes square X) to some listener. I think JCyclone should help me to decorate this to provide (possibly in an excellent pluggable way) - run multiple event consumer instances from an incoming event queue - deliver the output events not to one listener but to possibly multipe listener instances as well (ie input queue / output queue introduced) - for both queues perform self tuning so that I don't need to wonder how many thread I should use here and there - possibly enforce ordering among input events if needed, and/or add a buffered sort stage that helps to deal with out of order events (possibly with timeout so as to no retain events too long on low load) - possibly enforce throttling (load shedding by rejection and/or send side blocking) - provide me some reporting / stats measurements - hide all thread / thread pool coding (be it Java 1.4 or 5) I definitely think JCyclone is qualified for all that from my readings but I could not yet manage to find a starting point that I can play with and try to add to. I'll spend some more time on it. Side note: such concepts are AFAIK applied in some J2EE app server. WebLogic 9 workmanager comes to my mind as I know it very well (overload protection, request class for soft-priority, self tuning of thread pool size and some reporting). For ordering it seems to stand more in a JMS extension called unit of order which applies sort of a per logical group batching). I don't want to leverage all that if you wonder because I am looking for a more lightweight "out of JEE" approach. Alex On 12/20/06, Toli Kuznets <to...@ma...> wrote: > Alex, > > Unfortunately, i don't know of any simple writeup on how to get > started with JCyclone. > If you want a basic example of how to setup JCyclone, there's a very > simple example of a file config-based setup with 3 stages and one > input plugin in the core/test/org/jcyclone/core/fileconfig directory. > The core/test/config/fileconfig-jcyclone.cfg describes how the system > is setup. Basically, you have 3 stages: Initial --> Middle --> Last, > and they send messages through and the test verifies that the message > comes out. > The plugin in this example is not actually used. > > If you wnat a more substantial example, feel free to take a look at > version 0.1.4 of our product, the Marketcetera Platform. (we have > moved from JCyclone to the embedded ActiveMQ setup which is not > something you are interested in). > You can check out tag 0.1.4 with: > svn co http://svn.marketcetera.org/platform/tags/0.1.4/ platform-014 > > If you look at the code in > core/src/main/java/org/marketcetera/jcyclone/ you'll see all the base > classes, and then you can see the underlying implementations and usage > in oms/src/main/java/org/marketcetera/oms > (you can also browse it all at > http://trac.marketcetera.org/trac.fcgi/browser/platform/tags/0.1.4/core/src/main/java/org/marketcetera/jcyclone/) > > I'm attaching a class diagram of how we setup JCyclone, and you can > also look at > http://repo.marketcetera.org/images/screenshots/oms-overview.png > for a more high-level view of how the stages are setup. > > We use a flat-text-file (not xml) format to setup the JCyclone stages, > you can see how everything is wired in the > http://trac.marketcetera.org/trac.fcgi/browser/platform/tags/0.1.4/oms/src/main/resources/oms.properties#L28 > file. > > Hope this helps. Feel free to ask any follow-up questions. > > On 12/20/06, Alexandre Vasseur <ava...@gm...> wrote: > > Hello > > I am having a hard time starting with JCyclone and despite what has > > been written recently on the list, I don't think ActiveMQ inVM > > transport or Mule and whatever message driven POJO is an alternative > > (as I am interested in throttling / admission control / self tuning > > capabilities of JCyclone) > > > > Does someone have a tutorial ? Going thru the test and ext/* does not > > help much and reading Matt thesis and work gives some clue but I would > > love to read a 15min tutorial/howto if someone has already written > > that (blog or elsewhere) > > Has anyone worked on some more XSD driven config instead of the > > current odd xml format that I can find in *.cfg files ? Any plans on > > that ? My assumption is that this would have helped me get started and > > play some more in a more checked and self-discovering way > > > > Best > > Alex > > > > -- > Toli Kuznets > http://www.marketcetera.com: Open-Source Trading Platform > download.run.trade. > > > ------------------------------------------------------------------------- > Take Surveys. Earn Cash. Influence the Future of IT > Join SourceForge.net's Techsay panel and you'll get the chance to share your > opinions on IT & business topics through brief surveys - and earn cash > http://www.techsay.com/default.php?page=join.php&p=sourceforge&CID=DEVDEV > > _______________________________________________ > JCyclone-users mailing list > JCy...@li... > https://lists.sourceforge.net/lists/listinfo/jcyclone-users > > > > |