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]
