What use case are we trying to cover by testing with BAM which is two
versions older than the current one (2.4.1)?
On Wed, Sep 10, 2014 at 5:06 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
>
>
--
Nuwan Dias
Associate Tech Lead - WSO2, Inc. http://wso2.com
email : nuw...@wso2.com
Phone : +94 777 775 729
_______________________________________________
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
