Hi Prasanna, Please post the connection error trace.
Thanks! On Fri, Oct 17, 2014 at 2:54 PM, Prasanna Dangalla <[email protected]> wrote: > Hi Waruna > > Yes, I put the amqp-client-3.0.3.jar to repository/components/lib in greg > to test it in greg and to test it in my sample client I put the maven > dependency as follows in the pom file > > <dependency> > <groupId>com.rabbitmq</groupId> > <artifactId>amqp-client</artifactId> > <version>3.3.5</version> > </dependency> > > > > On Fri, Oct 17, 2014 at 2:48 PM, Waruna Perera <[email protected]> wrote: > >> Hi Prasanna, >> >> Did you put any client libraries of activemq server in side amqp cleint >> class path? >> >> Thanks >> >> On Fri, Oct 17, 2014 at 2:45 PM, Prasanna Dangalla <[email protected]> >> wrote: >> >>> Sorry the $subject should be as follows >>> Amqp client not connecting to activemq server. >>> >>> >>> On Fri, Oct 17, 2014 at 2:31 PM, Prasanna Dangalla <[email protected]> >>> wrote: >>> >>>> Hi, >>>> >>>> I'm trying connect from a amqp client to a aqtivemq server with default >>>> settings to test cache Invalidation in greg. It always gives the error >>>> message saying connection refused, I wrote a sample client using the >>>> rabbitmq client library. It to doesn't work with activemq server too. But >>>> it works in AmalG's lap. Both laps having the same ubuntu versions, >>>> activemq server versions and rabbitmq client versions. Then I tried it with >>>> a rabbitmq server instead of a activemq server and it works fine. I wonder >>>> whether activemq needs a linux library to communicate. >>>> >>>> Activemq server versions used which does not connects: 5.4.2 / 5.10.0 >>>> Rabitmq version used: 3.3.5 >>>> >>>> rabitmq sample client code >>>> >>>> import com.rabbitmq.client.ConnectionFactory; >>>> import com.rabbitmq.client.Connection; >>>> import com.rabbitmq.client.Channel; >>>> >>>> public class Cache { >>>> private final static String QUEUE_NAME = "hello"; >>>> >>>> public static void main(String[] argv) >>>> throws java.io.IOException { >>>> >>>> //creating the connection factory >>>> ConnectionFactory factory = new ConnectionFactory(); >>>> factory.setHost("localhost"); >>>> >>>> //Creating a connection to the server >>>> Connection connection = factory.newConnection(); >>>> Channel channel = connection.createChannel(); >>>> >>>> //declaring a queuw >>>> channel.queueDeclare(QUEUE_NAME, false, false, false, null); >>>> String message = "Hello World!"; >>>> >>>> //publishing the queue the queue >>>> channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); >>>> System.out.println(" [x] Sent '" + message + "'"); >>>> >>>> //closing the connection >>>> channel.close(); >>>> connection.close(); >>>> } >>>> } >>>> >>>> >>>> Fails in the following line of code >>>> //Creating a connection to the server >>>> Connection connection = factory.newConnection(); >>>> >>>> Thanks >>>> >>>> Prasanna Dangalla >>>> Software Engineer, WSO2, Inc.; http://wso2.com/ >>>> lean.enterprise.middleware >>>> >>>> cell: +94 777 55 80 30 | +94 718 11 27 51 >>>> twitter: @prasa77 >>>> >>> >>> >>> >>> -- >>> Prasanna Dangalla >>> Software Engineer, WSO2, Inc.; http://wso2.com/ >>> lean.enterprise.middleware >>> >>> cell: +94 777 55 80 30 | +94 718 11 27 51 >>> twitter: @prasa77 >>> >>> _______________________________________________ >>> Dev mailing list >>> [email protected] >>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>> >>> >> >> >> -- >> Waruna Perera >> Senior Software Engineer - Test Automation >> Mobile: +94 77 3867037 >> WSO2, Inc.; http://wso2.com/ >> lean . enterprise . middlewear. >> > > > > -- > Prasanna Dangalla > Software Engineer, WSO2, Inc.; http://wso2.com/ > lean.enterprise.middleware > > cell: +94 777 55 80 30 | +94 718 11 27 51 > twitter: @prasa77 > -- Waruna Perera Senior Software Engineer - Test Automation Mobile: +94 77 3867037 WSO2, Inc.; http://wso2.com/ lean . enterprise . middlewear.
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
