background preloader

Esper - Complex Event Processing

Esper - Complex Event Processing
Related:  CQRS, Event Sourcing, CEP

Drools Fusion Complex Event Process What is Event Processing (or Complex Event Processing, CEP)? Vision Features Use Cases Complex Event Processing In the Drools' vision of a unified behavioral modelling platform, Drools Fusion is the module responsible for enabling event processing capabilities. What is Event Processing (or Complex Event Processing, CEP)? According to wikipedia ( "Complex Event Processing, or CEP, is primarily an event processing concept that deals with the task of processing multiple events with the goal of identifying the meaningful events within the event cloud. According to the Complex Event Processing ( Drools Fusion Vision The vision on Drools 5 of a Behavioural Modeling Platform can only be achieved by moving away from any of the narrow modeling perspectives that see only Rules, or Processes, or Events as their main modeling concept. Drools Fusion Features

Decision Management - a Weblog interactive brokers - How should I store tick data? - Quantitative Finance Stack Exchange Using IBrokers from R is going to be the easiest route. A quick example of capturing data to disk would be: library(IBrokers) tws <- twsConnect() aapl.csv <- file("AAPL.csv", open="w") # run an infinite-loop ( <C-c> to break ) reqMktData(tws, twsSTK("AAPL"), eventWrapper=eWrapper.MktData.CSV(1), file=aapl.csv) close(aapl.csv) close(tws) This will send CSV style output to disk. Additionally the data can be stored in xts objects within the loop which can be appended to/filled to provide a constant in-memory object to use for analytics. Given the symbol limit of IB (100 concurrent more or less) and the 250ms updates - R can typically handle all of this without breaking a sweat (i.e. the JVM running IB's TWS or even IBGateway client is likely to be far surpassing the R/IBrokers process in terms of CPU usage). In terms of something closer to long-term storage/access, the packages Josh referred to (mmap and indexing) are also very useful.

Event-Driven SOA: Events meet Services by Guido Schmutz Achieve extreme loose coupling within a Service-Oriented Architecture by using event-driven interactions. Published July 2011 Introduction This article explores the difference between a request-driven and an event-driven solution for the same problem and discusses the pros and cons of each approach. In modern software solutions, three basic types of interactions can be identified and defined [1]: Time-driven - an agent, or a group of agents, initiates an interaction at a specified time. In a traditional Service-Oriented Architecture (SOA) request-driven interaction styles are common and widely used. Time-driven interactions are used when scheduling mechanisms are in place. Event-driven interactions are less common, although they can be a very helpful instrument for architects in order to increase the flexibility and agility of a service-oriented solution. The use case of the sample scenario Implementation using request-driven interactions Granularity of business events

Application Development State-owned enterprises (SOEs) in China face a quickly changing competitive landscape — one that their existing technology strategies can’t keep up with. To address this challenge, organizations are migrating from earlier-generation BI architectures, technologies, and organizational structures to new models and approaches. My “Chinese State-Owned Enterprise Targets Improved Agility” report, scheduled to appear later this month, describes the experience of a typical large Chinese SOE, the China National Cereals, Oils, and Foodstuffs Corporation (COFCO), which leveraged a BI-led program to jump-start the transformation of its technology management capabilities. COFCO is China’s largest supplier of agricultural and food products and services, including oils, rice, wine, tea, and various other products, and is expanding into real estate, shopping centers, and other industries.

Integrating the Trading Value Chain via .NET Framework Steven A. Smith 4th Story, LLC. John T. Powers Digipede Technologies, LLC. Brian Sentance Xenomorph Software Ltd. Stevan D. August 2007 Applies to: Financial Services Architecture .NET Framework Summary: This paper describes how .NET Framework 2.0 was used to integrate a strategy execution management system with grid-enabled trade order analytics and financial markets data management platform. Contents IntroductionIntegration Objectives4th Story Design OverviewXenomorph Design OverviewDigipede Network OverviewIntegrating Market DataIntegrating Trading Strategies with Grid ComputingConclusionReferences Introduction Many customers in the Securities and Capital Markets industry rely on products from Independent Software Vendors (ISVs) to obtain solutions for their business needs. Integration Objectives The following objectives were established at the beginning of the project: 4th Story Design Overview Figure 1. Xenomorph TimeScape Design Overview Figure 2. Digipede Network Overview Figure 3. Conclusion

Event Sourcing Capture all changes to an application state as a sequence of events. We can query an application's state to find out the current state of the world, and this answers many questions. However there are times when we don't just want to see where we are, we also want to know how we got there. Event Sourcing ensures that all changes to application state are stored as a sequence of events. Not just can we query these events, we can also use the event log to reconstruct past states, and as a foundation to automatically adjust the state to cope with retroactive changes. How it Works The fundamental idea of Event Sourcing is that of ensuring every change to the state of an application is captured in an event object, and that these event objects are themselves stored in the sequence they were applied for the same lifetime as the application state itself. Let's consider a simple example to do with shipping notifications. Figure 1: A simple interface for tracking shipping movements. Reversing Events

Business Process In developing a technology strategy for your organization, what will be your basis for deciding which technologies to pursue, when to pursue them, and how to implement them? In other words, what will be the foundation for your technology architecture and strategy? In considering this question, I assume we agree that technology strategy should directly support improvement of business outcomes, both now and over the long haul. To provide for the long haul, your technology architecture and strategy must be crafted to support a continuous stream of business change, both small incremental steps and large radical shifts. Your strategy could begin with a list of hot technologies — perhaps even ones that business colleagues are clamoring for — but how would you know which of them would lead to the most important improvements in business outcomes? (a) Aligns best with the ways that business leaders conceive, plan, execute, and measure improvements to business outcomes,