Hi Above has resolved once I change the stream name, anyway If I change stream properties that wont get reflected in the published data, and for that I need to create a new stream, another issue is that how to delete OLD streams which I have created is there any GUI feature?
cheres Dushan On Mon, Sep 10, 2012 at 9:57 PM, Dushan Abeyruwan <[email protected]> wrote: > Hi > > 0 seconds, irrespective of the timeout action, after the specified or > optional timeout > [2012-09-10 21:51:58,633] 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,192.168.1.2:7611,TCP,192.168.1.2:7711 > at > org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.EventPublisher.defineStream(EventPublisher.java:188) > at > org.wso2.carbon.databridge.agent.thrift.DataPublisher.defineStream(DataPublisher.java:291) > at > org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher$DataPublishWorker.run(AsyncDataPublisher.java:301) > at java.lang.Thread.run(Thread.java:662) > 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:122) > at > org.wso2.carbon.databridge.agent.thrift.internal.publisher.client.EventPublisher.defineStream(EventPublisher.java:176) > ... 3 more > Caused by: > ThriftDifferentStreamDefinitionAlreadyDefinedException(message:Similar > event stream for > StreamDefinition{streamId='stream1-1.0.0-b48199ba-a56b-4e3d-aa04-1542332bf69f', > name='stream1', version='1.0.0', nickName='test_stream1', > description='Testing stream for BAM Mediator', tags=null, > metaData=[Attribute{name='tenant_id', type=INT}, > Attribute{name='http_method', type=STRING}, > Attribute{name='character_set_encoding', type=STRING}, > Attribute{name='remote_address', type=STRING}, > Attribute{name='transport_in_url', type=STRING}, > Attribute{name='message_type', type=STRING}, Attribute{name='remote_host', > type=STRING}, Attribute{name='service_prefix', type=STRING}, > Attribute{name='host', type=STRING}], > correlationData=[Attribute{name='bam_activity_id', type=STRING}], > payloadData=[Attribute{name='message_direction', type=STRING}, > Attribute{name='service_name', type=STRING}, > Attribute{name='operation_name', type=STRING}, Attribute{name='message_id', > type=STRING}, Attribute{name='timestamp', type=LONG}, > Attribute{name='k1-current date', type=STRING}, > Attribute{name='k2-Constant', type=STRING}, Attribute{name='k3-sampleINT', > type=INT}, Attribute{name='count', type=INT}, Attribute{name='SOAPHeader', > type=STRING}, Attribute{name='SOAPBody', type=STRING}]} with the same name > and version already exist: > StreamDefinition{streamId='stream1-1.0.0-90df831e-eb86-4fb4-ac43-653d3ac4e887', > name='stream1', version='1.0.0', nickName='test_stream1', > description='Testing stream for BAM Mediator', tags=null, > metaData=[Attribute{name='tenant_id', type=INT}, > Attribute{name='http_method', type=STRING}, > Attribute{name='character_set_encoding', type=STRING}, > Attribute{name='remote_address', type=STRING}, > Attribute{name='transport_in_url', type=STRING}, > Attribute{name='message_type', type=STRING}, Attribute{name='remote_host', > type=STRING}, Attribute{name='service_prefix', type=STRING}, > Attribute{name='host', type=STRING}], > correlationData=[Attribute{name='bam_activity_id', type=STRING}], > payloadData=[Attribute{name='message_direction', type=STRING}, > Attribute{name='service_name', type=STRING}, > Attribute{name='operation_name', type=STRING}, Attribute{name='message_id', > type=STRING}, Attribute{name='timestamp', type=LONG}, > Attribute{name='k1-current date', type=STRING}, > Attribute{name='k2-Constant', type=STRING}, Attribute{name='k3-sampleINT', > type=INT}, Attribute{name='SOAPHeader', type=STRING}, > Attribute{name='SOAPBody', type=STRING}]}) > at > org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$defineStream_result.read(ThriftEventTransmissionService.java:1303) > at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) > at > org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$Client.recv_defineStream(ThriftEventTransmissionService.java:104) > at > org.wso2.carbon.databridge.commons.thrift.service.general.ThriftEventTransmissionService$Client.defineStream(ThriftEventTransmissionSer > > > cheers, > Dushan Abeyruwan > *Senior Software Engineer* > *Integration Technologies Team* > *WSO2 Inc. http://wso2.com/* > *Mobile:(+94)714408632* > > -- Dushan Abeyruwan *Senior Software Engineer* *Integration Technologies Team* *WSO2 Inc. http://wso2.com/* *Mobile:(+94)714408632*
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
