Search:

Mark,

We are not using any Thread-pool executors in our logic. Our component is supposed to be single-threaded.

There is one topic.
There are three durables for this topic.
Based upon the...

Please help with this issue. Am I doing anything wrong from the code stand-point?

It is very helpful if somebody can give me some pointers in resolving this issue.

I have overridden the receiveMessage(MessageConsumer consumer) {
and consumer.receive()
}
instead of polling...

After sending the message referred to by "toMessage", there is a lag in retrieval of message from the durable topic. The log is mentioned below:







2011-02-28 16:40:00,607 INFO ...

<bean id="oms.topicDurableProps" class="org.springframework.beans.factory.config.PropertiesFactoryBean">
<property name="singleton" value="true"/>
<property name="properties">
...

The SQL is working fine in TOAD.

My class is like this:



public class AllocatorDao extends NamedParameterJdbcTemplate
{
...
SqlParameterSource paramMap = new...

There is another downstream process MV which receives messages from this component OMS. But, it doesn't have any impact on this component.
We will try concurrent-consumers = 1 and let you know the...

We have designed this component in such a way (It was designed before I came) that it cannot handle threads. So, we made the component single-threaded. Lot of global variables.

If we set...

We are seeing this slow down once Messages start arriving. Our Component is single-threaded. However component itself is completing in 2 milliseconds. But, when we put the logging inside fromMessage...

Do we need to have any configuration changes on message-driven-channel-adapter in-order for the adapter to pick up the messages immediately from the topic?

It looks like the messages are not...

QoSEnabledJmsTemplate is working. But not sure why I couldn't see the priority getting reflected on Gems.

We tried two things to set message priority

first is JMS Template



<util:constant id="common.deliveryMode" static-field="javax.jms.Message.DEFAULT_DELIVERY_MODE"/>
...

We tried two things to set message priority

first is JMS Template



<util:constant id="common.deliveryMode" static-field="javax.jms.Message.DEFAULT_DELIVERY_MODE"/>
...

<si:router input-channel="comp.toRouter" ref="comp.router" method="route"/>

<bean id="comp.fatRouter" class="com.xxx.MessageTypeRouter">
<property name="name"...

<si:publish-subscribe-channel id="comp.toMultipleChannels"/>

<si:router input-channel="comp.toRouter" ref="comp.router" method="route"/>

<bean id="comp.router"...

The link is helpful. Thanks.

1) What if the <property name="sessionCacheSize" value="10" /> and the connections reach 10. Does it get more Connections from the Server than 10 or does it wait for one process to release the...

Thanks. It is a perfect solution.

We need the ability to cache the MQ Connection, because each time it is taking like 450 ms to get the Connection since the MQ server is in London and the code that is trying to get the connection is...

2010-06-07 14:55:29,573 INFO [pool-2-thread-1] proj.FATMasterTransferObjectConverter - message-processor:fromMessage OrderID:171176
<<171176>>
2010-06-07 14:55:30,030 INFO [pool-2-thread-1]...

I have a message that needs to gets converted into BytesMessage before being sent to two channels.
Currently, I have a message that gets put into two different channels through a Router and gets...

If I put concurrentConsumers inside message-driven-channel-adapter, Is it possible for multiple Consumers(more than 1) to consume "same" message send to this jms Queue? If so, what precaution should...

Currently, we are using 1.0.4.RELEASE. Just wondering when will it be released.


<dependency>
<groupId>org.springframework.integration</groupId>
...

Does the outbound-channel-adapter create new connection to EMS Queue everytime it puts a message into the EMS Queue?
(OR)
It just establishes a connection to EMS for the first time when the...

The following is the code that reads via MQ Queue and sends to MQ Queue using Message Converter(reads from jms:message-driven-channel-adapter and writes to jms:outbound-channel-adapter)


...