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

Reply via email to