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
