Lekkie,
I checked in the code, you need to define the jndiDestinationName. The
jmsProviderDestinationName is used only is destination and
jndiDestinationName are null.
If you want to register the queue into the JNDI tree you need to use the
jndiDestinationName property.
It should work.
Regards
JB
lekkie wrote:
I was trying to access a JMS consumer service exposed on Servicemix and its
throwing the follwoing exception:
javax.naming.NameNotFoundException: queue/A/Soap
at
org.apache.activemq.jndi.ReadOnlyContext.lookup(ReadOnlyContext.java:215)
at javax.naming.InitialContext.lookup(InitialContext.java:351)
at
testDriver.WebServiceTestDriver.sendBinaryFileJMS(WebServiceTestDriver.java:89)
at testDriver.WebServiceTestDriver.main(WebServiceTestDriver.java:71)
Here is my client code (running from eclipse):
String fileName = "C:\\binaryfile.html";
byte[] payload = getBytesFromFile(fileName);
String dest = "queue/A/Soap";
Properties env = new Properties();
if (System.getProperty("java.naming.provider.url") == null) {
env.put("java.naming.provider.url", "tcp://localhost:61616");
}
if (System.getProperty("java.naming.factory.initial") == null) {
env.put("java.naming.factory.initial",
"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
}
InitialContext ic = new InitialContext(env);
ConnectionFactory confac = (ConnectionFactory)
ic.lookup("ConnectionFactory");
Connection connection = confac.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer((Destination)
ic.lookup(dest));
BytesMessage bm = session.createBytesMessage();
bm.writeBytes(payload);
producer.send(bm);
connection.close();
and here is my xbean.xml on servicemix which imho look good:
<beans xmlns:jms="http://servicemix.apache.org/jms/1.0";
xmlns:is="http://services.is";
xmlns:amqpool="http://jencks.org/amqpool/2.0";>
<bean id="connectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"
/>
</bean>
</property>
<!--Configure maximum connections used by the pool -->
<property name="maxConnections" value="10" />
<!--Configure maximum sessions per connection -->
<property name="maximumActive" value="10" />
</bean>
<jms:endpoint service="is:isJMSFileConsumer"
endpoint="isJMSFileConsumer"
targetService="is:isFTPWriter"
targetEndpoint="isFTPWriter"
role="consumer"
destinationStyle="queue"
jmsProviderDestinationName="queue/A/Soap"
connectionFactory="#connectionFactory"
soap="true"
defaultMep="http://www.w3.org/2004/08/wsdl/robust-in-only"/>
</beans>
--
Jean-Baptiste Onofré
---------------------------------
HomePage
http://www.nanthrax.net
---------------------------------
Contacts
[email protected]
[email protected]
---------------------------------
OpenSource
BuildProcess/AutoDeploy
http://buildprocess.sourceforge.net
Apache ServiceMix
http://servicemix.apache.org
-----------------------------------
PGP : 17D4F086
