Hi Lasantha, I'm using the ThriftTestServer [1] to check data publisher functionality in a java test class. I have set the TrustStore paramby DataPublisherTestUtil.setTrustStoreParams(); after setting KeyStore param in my local code.
After start the ThriftTestServer instance, I'm trying to create a publisher object and while doing that I'm getting the below error: [main] INFO org.wso2.carbon.databridge.receiver.thrift.ThriftDataReceiver - Thrift Server started at localhost [main] INFO org.wso2.carbon.databridge.receiver.thrift.ThriftDataReceiver - Thrift SSL port : 7712 [main] INFO org.wso2.carbon.databridge.receiver.thrift.ThriftDataReceiver - Thrift port : 7612 [main] INFO org.apache.stratos.cloud.controller.statistics.publisher.ThriftTestServer - Test Server Started [main] INFO org.wso2.carbon.databridge.agent.thrift.AgentHolder - Agent created ! [main] INFO org.apache.stratos.common.threading.StratosThreadPool - Thread pool created: [type] Executor Service [id] cloud.controller.stats.publisher.thread.pool [size] 10 [pool-5-thread-1] ERROR org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher - Error while connection to event receiver org.wso2.carbon.databridge.agent.thrift.exception.AgentException: Cannot borrow client for TCP,localhost:7613,TCP,localhost:7713 at org.wso2.carbon.databridge.agent.thrift.internal.publisher.authenticator.AgentAuthenticator.connect(AgentAuthenticator.java:58) at org.wso2.carbon.databridge.agent.thrift.DataPublisher.start(DataPublisher.java:273) at org.wso2.carbon.databridge.agent.thrift.DataPublisher.<init>(DataPublisher.java:161) at org.wso2.carbon.databridge.agent.thrift.AsyncDataPublisher$ReceiverConnectionWorker.run(AsyncDataPublisher.java:787) 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.apache.thrift.transport.TTransportException: Could not connect to 172.17.8.1 on port 7713 at org.apache.thrift.transport.TSSLTransportFactory.createClient(TSSLTransportFactory.java:212) at org.apache.thrift.transport.TSSLTransportFactory.getClientSocket(TSSLTransportFactory.java:166) at org.wso2.carbon.databridge.agent.thrift.internal.pool.client.secure.SecureClientPoolFactory.makeObject(SecureClientPoolFactory.java:90) at org.wso2.carbon.databridge.agent.thrift.internal.pool.client.secure.SecureClientPoolFactory.makeObject(SecureClientPoolFactory.java:48) at org.apache.commons.pool.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:1212) at org.wso2.carbon.databridge.agent.thrift.internal.publisher.authenticator.AgentAuthenticator.connect(AgentAuthenticator.java:50) ... 8 more Caused by: java.net.ConnectException: Connection refused at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:579) at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:625) at sun.security.ssl.SSLSocketImpl.<init>(SSLSocketImpl.java:413) at sun.security.ssl.SSLSocketFactoryImpl.createSocket(SSLSocketFactoryImpl.java:88) at org.apache.thrift.transport.TSSLTransportFactory.createClient(TSSLTransportFactory.java:208) ... 13 more What is the reason for this? Could you please point what I'm doing wrong. Thanks. [1]. https://github.com/apache/stratos/blob/master/products/python-cartridge-agent/modules/integration/test-common/src/main/java/org/apache/stratos/python/cartridge/agent/integration/common/ThriftTestServer.java On Tue, Sep 1, 2015 at 1:26 AM, Akila Ravihansa Perera <[email protected]> wrote: > Hi Lasantha, > > This is exactly what I needed. Had to struggle a bit to connect to the > test server from a Python client but managed to do that after couple of > tweaks. I faced an issue since we cannot define the cipher set to be used > in ThriftTestServer. Therefore, ThriftDataReceiver will get initialized > with default set of parameters for TSSLTransportParameters. I'd like to > suggest that we provide a method to customize these SSL parameters. > > Thanks a lot for the prompt response. This was really helpful :) > > On Sun, Aug 30, 2015 at 3:20 PM, Lasantha Fernando <[email protected]> > wrote: > >> Hi Akila, >> >> There is a ThriftTestServer we've written for tests in >> carbon-analytics-common. You can find an example here [1]. Also you can >> find other examples in the databridge-agent test cases. Can you go through >> them and see if that fits your purpose? >> >> [1] >> https://github.com/wso2/carbon-analytics-common/blob/master/components/data-bridge/org.wso2.carbon.databridge.agent/src/test/java/org/wso2/carbon/databridge/agent/test/thrift/ThriftTestServer.java >> >> Thanks, >> Lasantha >> >> On 30 August 2015 at 12:59, Akila Ravihansa Perera <[email protected]> >> wrote: >> >>> Hi, >>> >>> I'm looking for a way to mock the Thrift receiver in CEP. My requirement >>> is to write an integration test to assert stat publishing functionality (to >>> CEP via Thrift) in my Python app. I'm developing the automation test cases >>> using TestNG framework so I can use any Java based library. Is this >>> possible by using regular Java sockets? >>> >>> I'd rather prefer to start an embedded CEP Thrift receiver in my test >>> method and verify the functionality. Appreciate any help regarding this. >>> >>> Thanks. >>> -- >>> Akila Ravihansa Perera >>> WSO2 Inc.; http://wso2.com/ >>> >>> Blog: http://ravihansa3000.blogspot.com >>> >> >> >> >> -- >> *Lasantha Fernando* >> Senior Software Engineer - Data Technologies Team >> WSO2 Inc. http://wso2.com >> >> email: [email protected] >> mobile: (+94) 71 5247551 >> > > > > -- > Akila Ravihansa Perera > WSO2 Inc.; http://wso2.com/ > > Blog: http://ravihansa3000.blogspot.com > > _______________________________________________ > Dev mailing list > [email protected] > http://wso2.org/cgi-bin/mailman/listinfo/dev > > -- Thanuja Uruththirakodeeswaran Software Engineer WSO2 Inc.;http://wso2.com lean.enterprise.middleware mobile: +94 774363167
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
