Hi Chalitha I got the similar error on https://wso2.org/jira/browse/BAM-1689. The answer will be on this jira
regards Shavantha Weerasinghe Senior Software Engineer QA WSO2, Inc. lean.enterprise.middleware. http://wso2.com http://wso2.org Tel : 94 11 214 5345 Fax :94 11 2145300 On Wed, Sep 10, 2014 at 5:03 PM, Chalitha Waldeniyage <chali...@wso2.com> wrote: > Hi > > When i am integrating API Manager latest pack(04/09/2014) with BAM 2.3.0 > and invoking the API through Jmeter, following error message has prompted > in API Manager side. Please provide directives in proceeding. > > > ERROR - AsyncDataPublisher Stream definition already exist > org.wso2.carbon.databridge.commons.exception.DifferentStreamDefinitionAlreadyDefinedException: > Same stream id with different definition already defined before sending > this event definitions to TCP,10.100.5.45:7612,TCP,10.100.5.45:7712 > 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:690) > 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:744) > 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 > StreamDefinition{ > streamId='org.wso2.apimgt.statistics.fault:1.0.0', > name='org.wso2.apimgt.statistics.fault', > version='1.0.0', > nickName='API Manager Fault Data', > description='Fault Data', > tags=null, > metaData=[Attribute{name='clientType', type=STRING}], > correlationData=null, > payloadData=[Attribute{name='consumerKey', type=STRING}, > Attribute{name='context', type=STRING}, Attribute{name='api_version', > type=STRING}, Attribute{name='api', type=STRING}, > Attribute{name='resourcePath', type=STRING}, Attribute{name='method', > type=STRING}, Attribute{name='version', type=STRING}, > Attribute{name='errorCode', type=STRING}, Attribute{name='errorMessage', > type=STRING}, Attribute{name='requestTime', type=STRING}, > Attribute{name='userId', type=STRING}, Attribute{name='tenantDomain', > type=STRING}, Attribute{name='hostName', type=STRING}, > Attribute{name='apiPublisher', type=STRING}, > Attribute{name='applicationName', type=STRING}, > Attribute{name='applicationId', type=STRING}], > } > with the same name and version already exist: > StreamDefinition{ > streamId='org.wso2.apimgt.statistics.fault:1.0.0', > name='org.wso2.apimgt.statistics.fault', > version='1.0.0', > nickName='API Manager Fault Data', > description='Fault Data', > tags=null, > metaData=[Attribute{name='clientType', type=STRING}], > correlationData=null, > payloadData=[Attribute{name='consumerKey', type=STRING}, > Attribute{name='context', type=STRING}, Attribute{name='api_version', > type=STRING}, Attribute{name='api', type=STRING}, > Attribute{name='resource', type=STRING}, Attribute{name='method', > type=STRING}, Attribute{name='version', type=STRING}, > Attribute{name='errorCode', type=STRING}, Attribute{name='errorMessage', > type=STRING}, Attribute{name='requestTime', type=STRING}, > Attribute{name='userId', type=STRING}, Attribute{name='tenantDomain', > type=STRING}, Attribute{name='hostName', type=STRING}, > Attribute{name='apiPublisher', type=STRING}, > Attribute{name='applicationName', type=STRING}, > Attribute{name='applicationId', 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 > > > -- > *Chalitha Maheshwari* > Software Engineer-QA, > WSO2 Inc. > > *E-mail:* chali...@wso2.com > *Mobile: *+94710 411 112 > > _______________________________________________ > Dev mailing list > Dev@wso2.org > http://wso2.org/cgi-bin/mailman/listinfo/dev > >
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
