Inserting Qpid Proton 0.10 in to HornetQ 2.4.0.Final -- possible?
Hello,
I am presently trying to insert Qpid Proton 0.10 in to HornetQ 2.4.0.Final.
I have tried multiple approaches but whenever I try to establish either the session or connection I run
into fatal problems (in the example below, the code "hangs" with no error message when establishing the
session).
I will explain one of my approaches in the hope that someone may have some idea what is
going on. If anyone has any pointers they would be much appreciated.
Steps:
1) Rename HornetQ's proton-j-impl.jar to proton-j-impl.jar.old (in "C:\Messaging\hornetq-2.4.0.Final\lib")
2) Insert Qpid Proton 0.10 as proton-j-impl.jar
3) Set up the config files in "C:\Messaging\hornetq-2.4.0.Final\config\stand-alone\non-clustered" (as supplied below; based on the ProtonJ example config files).
4) Run server
5) Copy the basic AMQP example from Artemis
6) Adapt it.
7) Run example.
Any suggestions? Any clarifications/more info needed?
Thank you & regards,
Matthew
#####################
# hornetq-beans.xml #
#####################
<?xml version="1.0" encoding="UTF-8"?>
<deployment xmlns="urn:jboss:bean-deployer:2.0">
<!-- MBean server -->
<bean name="MBeanServer" class="javax.management.MBeanServer">
<constructor factoryClass="java.lang.management.ManagementFactory"
factoryMethod="getPlatformMBeanServer"/>
</bean>
<!-- The core configuration -->
<bean name="Configuration" class="org.hornetq.core.config.impl.FileConfiguration">
</bean>
<!-- The security manager -->
<bean name="HornetQSecurityManager" class="org.hornetq.spi.core.security.HornetQSecurityManagerImpl">
<start ignored="true"/>
<stop ignored="true"/>
</bean>
<!-- The core server -->
<bean name="HornetQServer" class="org.hornetq.core.server.impl.HornetQServerImpl">
<constructor>
<parameter>
<inject bean="Configuration"/>
</parameter>
<parameter>
<inject bean="MBeanServer"/>
</parameter>
<parameter>
<inject bean="HornetQSecurityManager"/>
</parameter>
</constructor>
<start ignored="true"/>
<stop ignored="true"/>
</bean>
<!-- The JMS server -->
<bean name="JMSServerManager" class="org.hornetq.jms.server.impl.JMSServerManagerImpl">
<constructor>
<parameter>
<inject bean="HornetQServer"/>
</parameter>
</constructor>
</bean>
</deployment>
#############################
# hornetq-configuration.xml #
#############################
<configuration xmlns="urn:hornetq"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd">
<bindings-directory>${build.directory}/server0/data/messaging/bindings</bindings-directory>
<journal-directory>${build.directory}/server0/data/messaging/journal</journal-directory>
<large-messages-directory>${build.directory}/server0/data/messaging/largemessages</large-messages-directory>
<paging-directory>${build.directory}/server0/data/messaging/paging</paging-directory>
<!-- Acceptors -->
<acceptors>
<acceptor name="proton-acceptor">
<factory-class>org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory</factory-class>
<param key="protocol" value="AMQP"/>
<param key="port" value="5672"/>
</acceptor>
</acceptors>
<queues>
<queue name="testQueue">
<address>testQueue</address>
</queue>
</queues>
<!-- Other config -->
<security-settings>
<!--security for example queue-->
<security-setting match="testQueue">
<permission type="createDurableQueue" roles="guest"/>
<permission type="deleteDurableQueue" roles="guest"/>
<permission type="createNonDurableQueue" roles="guest"/>
<permission type="deleteNonDurableQueue" roles="guest"/>
<permission type="consume" roles="guest"/>
<permission type="send" roles="guest"/>
</security-setting>
</security-settings>
</configuration>
###################
# hornetq-jms.xml #
###################
<configuration xmlns="urn:hornetq"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd">
</configuration>
#####################
# hornetq-users.xml #
#####################
<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd">
<!-- the default user. this is used where username is null-->
<defaultuser name="guest" password="guest">
<role name="guest"/>
</defaultuser>
</configuration>
######################
# logging.properties #
######################
handlers=java.util.logging.ConsoleHandler
java.util.logging.ConsoleHandler.formatter=org.hornetq.integration.logging.HornetQLoggerFormatter
java.util.logging.FileHandler.level=INFO
java.util.logging.FileHandler.formatter=org.hornetq.integration.logging.HornetQLoggerFormatter
java.util.logging.FileHandler.pattern=logs/hornetq.log
.level= INFO
#########################
# AMQPQueueExample.java #
#########################
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package matt_protonj;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.qpid.jms.JmsConnectionFactory;
public class AMQPQueueExample {
public static void main(String[] args) throws Exception {
Connection connection = null;
ConnectionFactory connectionFactory = new JmsConnectionFactory("amqp://localhost:5672");
try {
System.out.println("Step 1. Create an amqp qpid 1.0 connection");
connection = connectionFactory.createConnection("guest","guest");
System.out.println("Step 2. Create a session");
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
System.out.println("Step 3. Create a sender");
Queue queue = session.createQueue("testQueue");
MessageProducer sender = session.createProducer(queue);
System.out.println("Step 4. send a few simple message");
sender.send(session.createTextMessage("Hello world "));
connection.start();
System.out.println("Step 5. create a moving receiver, this means the message will be removed from the queue");
MessageConsumer consumer = session.createConsumer(queue);
System.out.println("Step 7. receive the simple message");
TextMessage m = (TextMessage) consumer.receive(5000);
System.out.println("message = " + m.getText());
}
finally {
if (connection != null) {
System.out.println("Step 9. close the connection");
connection.close();
}
}
}
}