CEP で WSO2Event アダプターを使用してストリームを構成しました。
<?xml version="1.0" encoding="UTF-8"?>
<inputEventAdaptor name="CEP_test_input_adapter" statistics="disable" trace="disable" type="wso2event" xmlns="http://wso2.org/carbon/eventadaptormanager"/>
イベントビルダーを使用:
<?xml version="1.0" encoding="UTF-8"?>
<eventBuilder name="CEP_test_builder" statistics="enable" trace="enable" xmlns="http://wso2.org/carbon/eventbuilder">
<from eventAdaptorName="CEP_test_input_adapter" eventAdaptorType="wso2event">
<property name="stream">CEP_test_stream2</property>
<property name="version">1.0.0</property>
</from>
<mapping customMapping="disable" type="wso2event"/>
<to streamName="CEP_test_stream2" version="1.0.0"/>
</eventBuilder>
ストリーム定義:
{
"name": "CEP_test_stream2",
"version": "1.0.0",
"nickName": "CEP_test2",
"description": "CEP_test2",
"metaData": [
{
"name": "tenant_id",
"type": "INT"
},
{
"name": "http_method",
"type": "STRING"
},
{
"name": "character_set_encoding",
"type": "STRING"
},
{
"name": "remote_address",
"type": "STRING"
},
{
"name": "transport_in_url",
"type": "STRING"
},
{
"name": "message_type",
"type": "STRING"
},
{
"name": "remote_host",
"type": "STRING"
},
{
"name": "service_prefix",
"type": "STRING"
},
{
"name": "host",
"type": "STRING"
}
],
"correlationData": [
{
"name": "activity_id",
"type": "STRING"
}
],
"payloadData": [
{
"name": "message_direction",
"type": "STRING"
},
{
"name": "service_name",
"type": "STRING"
},
{
"name": "operation_name",
"type": "STRING"
},
{
"name": "message_id",
"type": "STRING"
},
{
"name": "timestamp",
"type": "LONG"
},
{
"name": "t1",
"type": "STRING"
},
{
"name": "t2",
"type": "STRING"
},
{
"name": "t3",
"type": "STRING"
}
]
}
「イベントシミュレーター」経由で試してみると、CEP OK を通過しますが、ESB 経由でイベントを送信しようとすると、CEP で何も起こりません:
ダンプ ヘッダー、ダンプ ボディ、および属性 t1、t2、t3 (CEP と同じ定義) を使用して、CEP の ESB BAM プロファイルを構成しました。「テスト サーバー」をクリックすると、「BAM サーバーに正常に接続されました」というポップアップが表示されるため、接続は問題ありません。
プロキシ エージェントのシーケンスに追加しました:
<bam>
<serverProfile name="CEP_test">
<streamConfig name="CEP_test_stream2" version="1.0.0"/>
</serverProfile>
</bam>
プロキシを試した後、ログに結果が表示されます:
TID: [0] [ESB] [2014-07-12 11:47:24,126] INFO {org.apache.synapse.mediators.builtin.LogMediator} - CEP: = BEFORE BAM PROFILE {org.apache.synapse.mediators.builtin.LogMediator}
TID: [0] [ESB] [2014-07-12 11:47:24,136] INFO {org.wso2.carbon.mediator.bam.Stream} - Data Publisher Created. {org.wso2.carbon.mediator.bam.Stream}
TID: [0] [ESB] [2014-07-12 11:47:24,255] INFO {org.apache.synapse.mediators.builtin.LogMediator} - CEP: = AFTER BAM PROFILE {org.apache.synapse.mediators.builtin.LogMediator}
しかし、CEP にイベントがないのはなぜですか? 何か案は?私は何を間違えましたか?助けてくれてありがとう!:)