Hi,
I am new t0 ActiveMQ(5.9.0,5.10.0). I am trying to create a JMS Bridge
between ActiveMQ and WebSphereMQ which i was able to do this successfully. I
am able to send and receive messages in Active MQ and WebSphere MQ.
But messages are not delivered from ActiveMQ if there is some time delay in
connection with WebSphereMQ. Below is scenario
1. Stop WebSphere MQ Queue Manager
2. Post Message in Active MQ
3. Wait for 1 minute
4. Start WebSphere MQ Queue Manager.
During this scenario the message is not delivered to WebsphereMQ Queue
Manager and sent to dequeue. Can someone please help me in resolving this
issue.
When i set the prefetch size as 1 and post 30 messages in activemq then the
inflight messages for that queue increases every 30 seconds. Once
websphereMQ is started these inflight messages are lost only the rest of the
messages are delivered. I dont see any Messages in dead letter Queue also.
Below is my activemq.xml configuration
<jmsBridgeConnectors>
<jmsQueueConnector
outboundQueueConnectionFactory="#remoteFactoryLinux">
<inboundQueueBridges>
<inboundQueueBridge inboundQueueName="TEMP.OUT" />
</inboundQueueBridges>
<outboundQueueBridges>
<outboundQueueBridge outboundQueueName="TEMP.IN" />
</outboundQueueBridges>
</jmsQueueConnector>
</jmsBridgeConnectors>
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" queuePrefetch="1000">
<deadLetterStrategy>
<individualDeadLetterStrategy queuePrefix="DLQ."
useQueueForQueueMessages="true" />
<sharedDeadLetterStrategy processExpired="true"
processNonPersistent="true" />
</deadLetterStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<plugins>
<redeliveryPlugin fallbackToDeadLetter="true"
sendToDlqIfMaxRetriesExceeded="true">
<redeliveryPolicyMap>
<redeliveryPolicyMap>
<redeliveryPolicyEntries>
<redeliveryPolicy queue="TEMP.IN"
maximumRedeliveries="-1" redeliveryDelay="10000" />
</redeliveryPolicyEntries>
<defaultEntry>
<redeliveryPolicy maximumRedeliveries="-1"
initialRedeliveryDelay="5000" redeliveryDelay="10000" />
</defaultEntry>
</redeliveryPolicyMap>
</redeliveryPolicyMap>
</redeliveryPlugin>
</plugins>
<managementContext>
<managementContext createConnector="false"/>
</managementContext>
<persistenceAdapter>
<kahaDB directory="${data}/kahadb"/>
<kahaPersistenceAdapter directory="activemq-data"
maxDataFileLength="33554432"/>
</persistenceAdapter>
<plugins>
<jaasAuthenticationPlugin configuration="karaf" />
</plugins>
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="64 mb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="10 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="10 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<transportConnectors>
<transportConnector name="openwire"
uri="tcp://localhost:61616?useKeepAlive=false;wireFormat.maxInactivityDuration=20000"/>
</transportConnectors>
<plugins>
<simpleAuthenticationPlugin anonymousAccessAllowed="true"
anonymousUser="admin1" anonymousGroup="unauthenticated">
<users>
<authenticationUser username="admin" password="admin"
groups="users,admins"/>
<authenticationUser username="user" password="password"
groups="users"/>
<authenticationUser username="guest" password="password"
groups="guests"/>
</users>
</simpleAuthenticationPlugin>
</plugins>
</broker>
<bean id="remoteFactoryLinux"
class="com.ibm.mq.jms.MQQueueConnectionFactory">
<property name="transportType" value="1"/>
<property name="hostName" value="1.1.1.1"/>
<property name="port" value="1414"/>
<property name="queueManager" value="QM"/>
<property name="channel" value="CHANNEL"/>
<property name="ClientReconnectTimeout" value="3600"/>
</bean>
</beans>
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-WebSphere-MQ-JMS-Bridge-Issue-tp4695649.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
