qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Marnie McCormack <marnie.mccorm...@googlemail.com>
Subject Re: Issue connecting to Qpid Broker
Date Wed, 14 Oct 2009 20:19:20 GMT
Can you cat the content of your jndi properties file ? Swtiching log level
to debug for the broker would show a connection attempt, but I suspect your
jndi might be the issue.

Thanks,
Marnie

On Tue, Oct 13, 2009 at 6:08 PM, Yogesh Rao <yogu13@gmail.com> wrote:

> Hi Can anyone help me on this ????
> Any directions on this would be extremely helpful ...
>
> Thanks in advance !!
>
> On Sun, Oct 11, 2009 at 11:00 PM, Yogesh Rao <yogu13@gmail.com> wrote:
>
> > Hi,
> >
> > I am facing an unusual problem when i try to connect to qpid from within
> > Log4j. Let me give a overview of what i am trying to do here ... I am
> > creating my own JMS appender implementation (for some specific reason)
> and
> > trying to send the logging message over JMS. This is based on publish
> > subscribe. I have written sample pub / sub code and it works very well
> with
> > qpid. I am trying to move that into JMSAppender and it seems to be
> throwing
> > a timeout exception when it tries to createTopicConnection ...
> >
> > Below is the code which i have written ...
> >
> > public class JMSAppender extends AppenderSkeleton {
> >
> >        public void activateOptions() {
> >
> > try {
> >
> > Properties env = new Properties( );
> > env.load(new FileInputStream("d:/qpid-config.properties"));
> > Context jndi = new InitialContext(env);
> > TopicConnectionFactory topicConnectionFactory = (TopicConnectionFactory)
> > lookup(jndi, "qpidConnectionFactory");
> > Topic topic = (Topic) lookup(jndi, "logTopic");
> > if (userName != null) {
> >
> > topicConnection = topicConnectionFactory.createTopicConnection(userName,
> > password);
> >
> > } else {
> >          * // here is the problem *
> >           *topicConnection =
> > topicConnectionFactory.createTopicConnection();*
> > }
> > topicSession =
> > topicConnection.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
> > topicPublisher = topicSession.createPublisher(topic);
> > topicConnection.start();
> > jndi.close();
> >
> > } catch (Exception e) {
> >
> > e.printStackTrace();
> >
> > }
> >
> >
> > }
> >
> >
> > Below is the exception trace that i get ....
> >
> > javax.jms.JMSException: Error creating connection: Timeout waiting for
> > connection.
> >  at
> >
> org.apache.qpid.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:325)
> > at
> >
> org.apache.qpid.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:296)
> >  at
> >
> org.apache.qpid.client.AMQConnectionFactory.createTopicConnection(AMQConnectionFactory.java:348)
> > at sample.logging.JMSAppender.activateOptions(JMSAppender.java:62)
> >  at
> > org.apache.log4j.config.PropertySetter.activate(PropertySetter.java:257)
> > at
> >
> org.apache.log4j.xml.DOMConfigurator.parseAppender(DOMConfigurator.java:285)
> >  at
> >
> org.apache.log4j.xml.DOMConfigurator.findAppenderByName(DOMConfigurator.java:171)
> > at
> >
> org.apache.log4j.xml.DOMConfigurator.findAppenderByReference(DOMConfigurator.java:184)
> >
> > Do let me know how can i fix the issue... looking at the code i don't see
> > any problem, strangely this only happens when log4j is trying to connect
> to
> > qpid using the appender... could that be a problem ? Please advice...
> >
> > Thank you in advance ...
> >
> >
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message