Hi
I am getting below error when publishing activity from IS 5.0.0 with
message tracer 4.2.2 once patch0748 is applied. seems the patch0748 change
the BAM_MESSAGE_TRACE stream definition.
In order to get this worked, stream definition has to be manually updated
in registry. but once BAM server is restarted, same error throes by
/bam-toolbox/Message_Tracing.tbox while trying to create the stream
definition.
How do we get rid of this issue
[2015-03-07 23:11:44,059] INFO
{org.wso2.carbon.core.services.authentication.AuthenticationAdmin} -
'[email protected] [-1234]' logged out at [2015-03-07 23:11:44,0059]
[2015-03-07 23:11:44,212] ERROR
{org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher} - Stream
definition already exist
org.wso2.carbon.databridge.commons.exception.DifferentStreamDefinitionAlreadyDefinedException:
Same stream with different definition already defined before sending this
stream definitions to TCP,localhost:7615,TCP,localhost:7715
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.EventPublisher.defineStream(EventPublisher.java:237)
at
org.wso2.carbon.databridge.agent.thrift.DataPublisher.defineStream(DataPublisher.java:295)
at
org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher$DataPublishWorker.run(AsyncDataPublisher.java:746)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by:
org.wso2.carbon.databridge.commons.exception.DifferentStreamDefinitionAlreadyDefinedException:
Thrift Different Stream Definition Already Defined
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.ThriftEventPublisher.defineStream(ThriftEventPublisher.java:112)
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.EventPublisher.defineStream(EventPublisher.java:222)
... 7 more
Caused by:
ThriftDifferentStreamDefinitionAlreadyDefinedException(message:Similar
event stream for {
"name": "BAM_MESSAGE_TRACE",
"version": "1.0.0",
"nickName": "MessageTracerAgent",
"description": "Publish Message Tracing Event",
"metaData": [
{
"name": "request_url",
"type": "STRING"
},
{
"name": "host",
"type": "STRING"
},
{
"name": "server",
"type": "STRING"
}
],
"correlationData": [
{
"name": "activity_id",
"type": "STRING"
}
],
"payloadData": [
{
"name": "service_name",
"type": "STRING"
},
{
"name": "operation_name",
"type": "STRING"
},
{
"name": "message_direction",
"type": "STRING"
},
{
"name": "soap_body",
"type": "STRING"
},
{
"name": "soap_header",
"type": "STRING"
},
{
"name": "timestamp",
"type": "LONG"
},
{
"name": "status",
"type": "STRING"
}
]
} with the same name and version already exist: {
"name": "BAM_MESSAGE_TRACE",
"version": "1.0.0",
"nickName": "MessageTracerAgent",
"description": "Publish Message Tracing Event",
"metaData": [
{
"name": "request_url",
"type": "STRING"
},
{
"name": "remote_address",
"type": "STRING"
},
{
"name": "content_type",
"type": "STRING"
},
{
"name": "user_agent",
"type": "STRING"
},
{
"name": "host",
"type": "STRING"
},
{
"name": "referer",
"type": "STRING"
},
{
"name": "server",
"type": "STRING"
}
],
"correlationData": [
{
"name": "activity_id",
"type": "STRING"
}
],
"payloadData": [
{
"name": "service_name",
"type": "STRING"
},
{
"name": "operation_name",
"type": "STRING"
},
{
"name": "message_direction",
"type": "STRING"
},
{
"name": "soap_body",
"type": "STRING"
},
{
"name": "soap_header",
"type": "STRING"
},
{
"name": "timestamp",
"type": "LONG"
},
{
"name": "status",
"type": "STRING"
}
]
})
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$defineStream_result.read(ThriftEventTransmissionService.java:1441)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$Client.recv_defineStream(ThriftEventTransmissionService.java:80)
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$Client.defineStream(ThriftEventTransmissionService.java:66)
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.ThriftEventPublisher.defineStream(ThriftEventPublisher.java:109)
... 8 more
[2015-03-07 23:11:48,538] INFO
{org.wso2.carbon.core.services.util.CarbonAuthenticationUtil} -
'[email protected] [-1234]' logged in at [2015-03-07 23:11:48,538-0800]
[2015-03-07 23:11:48,609] ERROR
{org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher} - Stream
definition already exist
org.wso2.carbon.databridge.commons.exception.DifferentStreamDefinitionAlreadyDefinedException:
Same stream with different definition already defined before sending this
stream definitions to TCP,localhost:7615,TCP,localhost:7715
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.EventPublisher.defineStream(EventPublisher.java:237)
at
org.wso2.carbon.databridge.agent.thrift.DataPublisher.defineStream(DataPublisher.java:295)
at
org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher$DataPublishWorker.run(AsyncDataPublisher.java:746)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by:
org.wso2.carbon.databridge.commons.exception.DifferentStreamDefinitionAlreadyDefinedException:
Thrift Different Stream Definition Already Defined
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.ThriftEventPublisher.defineStream(ThriftEventPublisher.java:112)
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.EventPublisher.defineStream(EventPublisher.java:222)
... 7 more
Caused by:
ThriftDifferentStreamDefinitionAlreadyDefinedException(message:Similar
event stream for {
"name": "BAM_MESSAGE_TRACE",
"version": "1.0.0",
"nickName": "MessageTracerAgent",
"description": "Publish Message Tracing Event",
"metaData": [
{
"name": "request_url",
"type": "STRING"
},
{
"name": "host",
"type": "STRING"
},
{
"name": "server",
"type": "STRING"
}
],
"correlationData": [
{
"name": "activity_id",
"type": "STRING"
}
],
"payloadData": [
{
"name": "service_name",
"type": "STRING"
},
{
"name": "operation_name",
"type": "STRING"
},
{
"name": "message_direction",
"type": "STRING"
},
{
"name": "soap_body",
"type": "STRING"
},
{
"name": "soap_header",
"type": "STRING"
},
{
"name": "timestamp",
"type": "LONG"
},
{
"name": "status",
"type": "STRING"
}
]
} with the same name and version already exist: {
"name": "BAM_MESSAGE_TRACE",
"version": "1.0.0",
"nickName": "MessageTracerAgent",
"description": "Publish Message Tracing Event",
"metaData": [
{
"name": "request_url",
"type": "STRING"
},
{
"name": "remote_address",
"type": "STRING"
},
{
"name": "content_type",
"type": "STRING"
},
{
"name": "user_agent",
"type": "STRING"
},
{
"name": "host",
"type": "STRING"
},
{
"name": "referer",
"type": "STRING"
},
{
"name": "server",
"type": "STRING"
}
],
"correlationData": [
{
"name": "activity_id",
"type": "STRING"
}
],
"payloadData": [
{
"name": "service_name",
"type": "STRING"
},
{
"name": "operation_name",
"type": "STRING"
},
{
"name": "message_direction",
"type": "STRING"
},
{
"name": "soap_body",
"type": "STRING"
},
{
"name": "soap_header",
"type": "STRING"
},
{
"name": "timestamp",
"type": "LONG"
},
{
"name": "status",
"type": "STRING"
}
]
})
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$defineStream_result.read(ThriftEventTransmissionService.java:1441)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$Client.recv_defineStream(ThriftEventTransmissionService.java:80)
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$Client.defineStream(ThriftEventTransmissionService.java:66)
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.ThriftEventPublisher.defineStream(ThriftEventPublisher.java:109)
... 8 more
[2015-03-07 23:11:48,698] ERROR
{org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher} - Stream
definition already exist
org.wso2.carbon.databridge.commons.exception.DifferentStreamDefinitionAlreadyDefinedException:
Same stream with different definition already defined before sending this
stream definitions to TCP,localhost:7615,TCP,localhost:7715
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.EventPublisher.defineStream(EventPublisher.java:237)
at
org.wso2.carbon.databridge.agent.thrift.DataPublisher.defineStream(DataPublisher.java:295)
at
org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher$DataPublishWorker.run(AsyncDataPublisher.java:746)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by:
org.wso2.carbon.databridge.commons.exception.DifferentStreamDefinitionAlreadyDefinedException:
Thrift Different Stream Definition Already Defined
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.ThriftEventPublisher.defineStream(ThriftEventPublisher.java:112)
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.EventPublisher.defineStream(EventPublisher.java:222)
... 7 more
Caused by:
ThriftDifferentStreamDefinitionAlreadyDefinedException(message:Similar
event stream for {
"name": "BAM_MESSAGE_TRACE",
"version": "1.0.0",
"nickName": "MessageTracerAgent",
"description": "Publish Message Tracing Event",
"metaData": [
{
"name": "request_url",
"type": "STRING"
},
{
"name": "host",
"type": "STRING"
},
{
"name": "server",
"type": "STRING"
}
],
"correlationData": [
{
"name": "activity_id",
"type": "STRING"
}
],
"payloadData": [
{
"name": "service_name",
"type": "STRING"
},
{
"name": "operation_name",
"type": "STRING"
},
{
"name": "message_direction",
"type": "STRING"
},
{
"name": "soap_body",
"type": "STRING"
},
{
"name": "soap_header",
"type": "STRING"
},
{
"name": "timestamp",
"type": "LONG"
},
{
"name": "status",
"type": "STRING"
}
]
} with the same name and version already exist: {
"name": "BAM_MESSAGE_TRACE",
"version": "1.0.0",
"nickName": "MessageTracerAgent",
"description": "Publish Message Tracing Event",
"metaData": [
{
"name": "request_url",
"type": "STRING"
},
{
"name": "remote_address",
"type": "STRING"
},
{
"name": "content_type",
"type": "STRING"
},
{
"name": "user_agent",
"type": "STRING"
},
{
"name": "host",
"type": "STRING"
},
{
"name": "referer",
"type": "STRING"
},
{
"name": "server",
"type": "STRING"
}
],
"correlationData": [
{
"name": "activity_id",
"type": "STRING"
}
],
"payloadData": [
{
"name": "service_name",
"type": "STRING"
},
{
"name": "operation_name",
"type": "STRING"
},
{
"name": "message_direction",
"type": "STRING"
},
{
"name": "soap_body",
"type": "STRING"
},
{
"name": "soap_header",
"type": "STRING"
},
{
"name": "timestamp",
"type": "LONG"
},
{
"name": "status",
"type": "STRING"
}
]
})
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$defineStream_result.read(ThriftEventTransmissionService.java:1441)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$Client.recv_defineStream(ThriftEventTransmissionService.java:80)
at
org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$Client.defineStream(ThriftEventTransmissionService.java:66)
at
org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.ThriftEventPublisher.defineStream(ThriftEventPublisher.java:109)
... 8 more
Thanks,
Nuwanw
--
Nuwan Wimalasekara
Senior Software Engineer - Test Automation
WSO2, Inc.: http://wso2.com
lean. enterprise. middleware
phone: +94 71 668 4620
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev