Hi Lasantha, Sorry, I tried this with different ports and when changing the client port to 7613, forgot to change the server port to 7613. I've corrected it and attached the new log.
[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 : 7713 [main] INFO org.wso2.carbon.databridge.receiver.thrift.ThriftDataReceiver - Thrift port : 7613 [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 Thanks. On Tue, Dec 1, 2015 at 3:14 PM, Lasantha Fernando <lasan...@wso2.com> wrote: > Hi Thanuja, > > Looking at the logs above, it seems that the ThriftDataReceiver started on > port 7612, with SSL port 7712. > > [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 > > But the agent is trying to connect to port 7613,7713. > > [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 > > Can you go through the code and verify that the agent is sending to the > same port on which agent is started? It is probably a minor issue when > setting the offsets. > > Thanks, > Lasantha > > > On 1 December 2015 at 15:09, Thanuja Uruththirakodeeswaran < > thanu...@wso2.com> wrote: > >> 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 < >> raviha...@wso2.com> 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 <lasan...@wso2.com> >>> 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 <raviha...@wso2.com> >>>> 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: lasan...@wso2.com >>>> mobile: (+94) 71 5247551 >>>> >>> >>> >>> >>> -- >>> Akila Ravihansa Perera >>> WSO2 Inc.; http://wso2.com/ >>> >>> Blog: http://ravihansa3000.blogspot.com >>> >>> _______________________________________________ >>> Dev mailing list >>> Dev@wso2.org >>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>> >>> >> >> >> -- >> Thanuja Uruththirakodeeswaran >> Software Engineer >> WSO2 Inc.;http://wso2.com >> lean.enterprise.middleware >> >> mobile: +94 774363167 >> > > > > -- > *Lasantha Fernando* > Senior Software Engineer - Data Technologies Team > WSO2 Inc. http://wso2.com > > email: lasan...@wso2.com > mobile: (+94) 71 5247551 > -- Thanuja Uruththirakodeeswaran Software Engineer WSO2 Inc.;http://wso2.com lean.enterprise.middleware mobile: +94 774363167
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
