Hi Harsha, I've run this example quite a bit - can you post (copy into your message rather than attach) the broker log for your running broker please ? Can you also verify the use credentials i.e. userid/pwd guest/guest ?
The most likely explanation is that the user credentials are invalid. Regards, Marnie On Wed, Jan 13, 2010 at 12:00 PM, Robbie Gemmell <[email protected]>wrote: > Hi Harsha, > > I havent had a chance to look further at this yet, ill try tonight. > Although I didnt for my test below, I often run the broker and > examples through Eclipse during development so I dont think that is > your problem (certainly the example classes seem to have worked or you > would probably have recieved a completely different error). Can you > try starting the broker outwith Eclipse to be sure though? > > Robbie > > 2010/1/12 Harsha Halgaswatta <[email protected]>: > > Hi Robbie > > > > Thanks for taking time on this , i used trunk as well , but i tried > > SubscriptionWrapper inside eclipse. Not paired with the examples jars. > > is it a problem ? . I can start the broker through eclipse , but could > > not connect. > > > > > > my config is as follows: > > > > <broker> > > <prefix>/home/harsha/Qpid/qpid/java/broker</prefix> > > <work>${QPID_WORK}</work> > > <conf>${prefix}/etc</conf> > > <connector> > > <!-- To enable SSL edit the keystorePath and keystorePassword > > and set enabled to true. > > To disasble Non-SSL port set sslOnly to true --> > > <ssl> > > <enabled>false</enabled> > > <sslOnly>true</sslOnly> > > > > <keyStorePath>/home/harsha/Qpid/qpid/java/build/bin/qpid.keystore</keyStorePath> > > <keystorePassword>keystorepass</keystorePassword> > > </ssl> > > <qpidnio>false</qpidnio> > > <protectio> > > <enabled>false</enabled> > > <readBufferLimitSize>262144</readBufferLimitSize> > > <writeBufferLimitSize>262144</writeBufferLimitSize> > > </protectio> > > <transport>nio</transport> > > <port>5672</port> > > <sslport>8672</sslport> > > <socketReceiveBuffer>32768</socketReceiveBuffer> > > <socketSendBuffer>32768</socketSendBuffer> > > </connector> > > <management> > > <enabled>false</enabled> > > <jmxport>8999</jmxport> > > <ssl> > > <enabled>true</enabled> > > <!-- Update below path to your keystore location, eg > > ${conf}/qpid.keystore --> > > > > <keyStorePath>/home/harsha/Qpid/qpid/java/build/bin/qpid.keystore</keyStorePath> > > <keyStorePassword>password</keyStorePassword> > > </ssl> > > </management> > > <advanced> > > <filterchain enableExecutorPool="true"/> > > <enablePooledAllocator>false</enablePooledAllocator> > > <enableDirectBuffers>false</enableDirectBuffers> > > <framesize>65535</framesize> > > <compressBufferOnQueue>false</compressBufferOnQueue> > > <enableJMSXUserID>false</enableJMSXUserID> > > <locale>en_US</locale> > > </advanced> > > > > <security> > > <principal-databases> > > <!-- Example use of Base64 encoded MD5 hashes for > > authentication via CRAM-MD5-Hashed --> > > <principal-database> > > <name>passwordfile</name> > > > > > <class>org.apache.qpid.server.security.auth.database.PlainPasswordFilePrincipalDatabase</class> > > <attributes> > > <attribute> > > <name>passwordFile</name> > > <value>${conf}/passwd</value> > > </attribute> > > </attributes> > > </principal-database> > > </principal-databases> > > > > <access> > > > <class>org.apache.qpid.server.security.access.plugins.AllowAll</class> > > </access> > > > > <msg-auth>false</msg-auth> > > > > <jmx> > > <access>${conf}/jmxremote.access</access> > > <principal-database>passwordfile</principal-database> > > </jmx> > > </security> > > > > <virtualhosts> > > > > <default>test</default> > > <virtualhost> > > <name>localhost</name> > > <localhost> > > <store> > > <class>org.apache.qpid.server.store.MemoryMessageStore > > </class> > > </store> > > > > <housekeeping> > > > <expiredMessageCheckPeriod>20000</expiredMessageCheckPeriod> > > </housekeeping> > > > > <exchanges> > > <exchange> > > <type>direct</type> > > <name>test.direct</name> > > <durable>true</durable> > > </exchange> > > <exchange> > > <type>topic</type> > > <name>test.topic</name> > > </exchange> > > </exchanges> > > <queues> > > <exchange>amq.direct</exchange> > > <maximumQueueDepth>4235264</maximumQueueDepth> > > <!-- 4Mb --> > > <maximumMessageSize>2117632</maximumMessageSize> > > <!-- 2Mb --> > > <maximumMessageAge>600000</maximumMessageAge> > > <!-- 10 mins --> > > <maximumMessageCount>50</maximumMessageCount> > > <!-- 50 messages --> > > > > <queue> > > <name>queue</name> > > </queue> > > <queue> > > <name>ping</name> > > </queue> > > <queue> > > <name>test-queue</name> > > <test-queue> > > <exchange>test.direct</exchange> > > <durable>true</durable> > > </test-queue> > > </queue> > > <queue> > > <name>test-ping</name> > > <test-ping> > > <exchange>test.direct</exchange> > > </test-ping> > > </queue> > > > > </queues> > > </localhost> > > </virtualhost> > > > > > > <virtualhost> > > <name>development</name> > > <development> > > <store> > > <class>org.apache.qpid.server.store.MemoryMessageStore > > </class> > > </store> > > > > <queues> > > <minimumAlertRepeatGap>30000</minimumAlertRepeatGap> > > <maximumMessageCount>50</maximumMessageCount> > > <queue> > > <name>queue</name> > > <queue> > > <exchange>amq.direct</exchange> > > <maximumQueueDepth>4235264</maximumQueueDepth> > > <!-- 4Mb --> > > > <maximumMessageSize>2117632</maximumMessageSize> > > <!-- 2Mb --> > > <maximumMessageAge>600000</maximumMessageAge> > > <!-- 10 mins --> > > </queue> > > </queue> > > <queue> > > <name>ping</name> > > <ping> > > <exchange>amq.direct</exchange> > > <maximumQueueDepth>4235264</maximumQueueDepth> > > <!-- 4Mb --> > > > <maximumMessageSize>2117632</maximumMessageSize> > > <!-- 2Mb --> > > <maximumMessageAge>600000</maximumMessageAge> > > <!-- 10 mins --> > > </ping> > > </queue> > > </queues> > > </development> > > </virtualhost> > > <virtualhost> > > <name>test</name> > > <test> > > <store> > > <class>org.apache.qpid.server.store.MemoryMessageStore > > </class> > > </store> > > > > <queues> > > <minimumAlertRepeatGap>30000</minimumAlertRepeatGap> > > <maximumMessageCount>50</maximumMessageCount> > > <queue> > > <name>queue</name> > > <queue> > > <exchange>amq.direct</exchange> > > <maximumQueueDepth>4235264</maximumQueueDepth> > > <!-- 4Mb --> > > > <maximumMessageSize>2117632</maximumMessageSize> > > <!-- 2Mb --> > > <maximumMessageAge>600000</maximumMessageAge> > > <!-- 10 mins --> > > </queue> > > </queue> > > <queue> > > <name>ping</name> > > <ping> > > <exchange>amq.direct</exchange> > > <maximumQueueDepth>4235264</maximumQueueDepth> > > <!-- 4Mb --> > > > <maximumMessageSize>2117632</maximumMessageSize> > > <!-- 2Mb --> > > <maximumMessageAge>600000</maximumMessageAge> > > <!-- 10 mins --> > > </ping> > > </queue> > > </queues> > > </test> > > </virtualhost> > > </virtualhosts> > > <heartbeat> > > <delay>0</delay> > > <timeoutFactor>2.0</timeoutFactor> > > </heartbeat> > > <queue> > > <auto_register>true</auto_register> > > </queue> > > > > <status-updates>ON</status-updates> > > > > </broker> > > > > > > and the example.properties file is : > > > > > > java.naming.factory.initial = > > org.apache.qpid.jndi.PropertiesFileInitialContextFactory > > connectionfactory.local = > > amqp://admin:ad...@localhost/test?brokerlist='tcp://127.0.0.1:5672' > > queue.MyQueue = example.MyQueue > > topic.ibmStocks = stocks.nyse.ibm > > destination.direct = direct://amq.direct//directQueue > > > > > > Thanks in advance > > Harsha > > > > --------------------------------------------------------------------- > > Apache Qpid - AMQP Messaging Implementation > > Project: http://qpid.apache.org > > Use/Interact: mailto:[email protected] > > > > > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:[email protected] > >
