| Excerpt | ||
|---|---|---|
| ||
WSO2 CEP Samples : Access Analysis sample using Tuple mapping, Siddhi CEP Engine and local broker |
...
Before creating the bucket to filter stock quotes it is essential to have a Carbon broker. Since In this example we are going to use agent Broker, it is needed to create a broker with type agent.To do that
- Start CEP Server. Refer to the Running the Product for instructions.
- Login as admin.
In the Configure menu you can find a Menu item called "Broker" and under that you can see sub menu 'Add' and click on that.
You will get a page with header "Create a New Broker" and you need to enter following details in that form to create a agent broker.
No Format Broker Name : localAgentBroker Type : agent URL : tcp://localhost:7611 Authenticator URL : ssl://localhost:7711 User Name : admin Password : admin
- Finally click on Add Broker button and you will get the added broker to the list of available brokers.
Repeat step 3 & 4 to create another new broker with following details.
No Format Broker Name : externalAgentBroker Type : agent URL : tcp://localhost:7661 Authenticator URL : ssl://localhost:7761 User Name : admin Password : admin
For more information about brokers visit here.
...
| Code Block | ||
|---|---|---|
| ||
[java] StreamDefinition StreamDefinition{streamId='users.org1-1.2.0-12ecdab1-0bb0-44ff-b782-3af4040f0890', name='users.org1', version='1.2.0', nickName='null', description='null', tags=null, metaData=[Attribute{name='organization', type=STRING}, Attribute{name='country', type=STRING}], correlationData=[], payloadData=[Attribute{name='email', type=STRING}]}
[java] admin connected
[java] eventListSize=1 eventList [Event{streamId='users.org1-1.2.0-12ecdab1-0bb0-44ff-b782-3af4040f0890', timeStamp=0, metaData=[org1, Au], correlationData=[], payloadData=[sam@org1.com]}] for username admin
[java] eventListSize=1 eventList [Event{streamId='users.org1-1.2.0-12ecdab1-0bb0-44ff-b782-3af4040f0890', timeStamp=0, metaData=[org1, Au], correlationData=[], payloadData=[abc@org1.com]}] for username admin |
Find the sample project file of the subscriber and publisher from the below link
https://svn.wso2.org/repos/wso2/people/suho/doc-sample/Access_Analyzer-Publisher_Subscriber.zip