2016-03-06 3 views
2

как настроить очередь JMS (с помощью ActiveMQ внутри karaf) внутри blueprint.xml которые представляют внутри karaf развернуть папку ..как настроить очередь JMS внутри blueprint.xml

ниже мой код, который показывает конфигурации для JMS связи внутри blueprint.xml ..

<bean id="activemqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
    <property name="brokerURL" value="tcp://localhost:61616" /> 
    <property name="userName" value="karaf" /> 
    <property name="password" value="karaf" /> 
</bean> 

<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory"> 
    <property name="maxConnections" value="8" /> 
    <property name="connectionFactory" ref="activemqConnectionFactory" /> 
</bean> 

<bean id="resourceManager" class="org.apache.activemq.pool.ActiveMQResourceManager" init-method="recoverResource"> 
    <property name="transactionManager" ref="transactionManager" /> 
    <property name="connectionFactory" ref="activemqConnectionFactory" /> 
    <property name="resourceName" value="activemq.localhost" /> 
</bean> 

<reference id="transactionManager" interface="javax.transaction.TransactionManager" /> 

<service ref="activemqConnectionFactory" interface="javax.jms.ConnectionFactory"> 
    <service-properties> 
     <entry key="name" value="connectionFactory" /> 
     <entry key="osgi.jndi.service.name" value="jms/connectionFactory" /> 
    </service-properties> 
</service> 

ответ

-1

вы не настраивать очереди в OSGi, как вы делали в J2EE. Вы просто используете фабрику соединений в своей простой Java или настраиваете компонент camel-jms.

+0

Привет, но как мы получим объект очереди от поиска jndi ?? Можете ли вы привести мне пример того, как вы получаете объект очереди на стороне потребителя, используя jndi lookup .. вот мой потребительский код: – Aman

+0

Контекст context = new InitialContext(); \t \t \t ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup ("osgi: service/jms/connectionFactory"); \t \t \t соединение = соединениеFactory.createConnection(); \t \t \t connection.start(); \t \t \t session = connection.createSession (false, Session.AUTO_ACKNOWLEDGE); \t \t \t Queue queue = session.createQueue ("Request_Queue"); – Aman

+0

здесь я сильно ухаживаю за именем очереди «Request_Queue», но тот же, что и я, хочу выбрать, используя jndi, искать вверху ... ниже Целевая очередь = (Назначение) context.lookup («MyQueue»); – Aman

Смежные вопросы