bpicio / aws-sqs-ra

Amazon SQS JMS Resource Adapter
GNU Affero General Public License v3.0
2 stars 0 forks source link

MDB Receiver is single-threaded #2

Open natepe opened 1 year ago

natepe commented 1 year ago

Using Wildfly 21, when the pool size is greater than one, the mdb receiver does not scale up and create more instances of the mdb. Is this expected behavior? Is there a separate configuration to enable more instances?

bpalermo commented 1 year ago

Can you share your current configuration?

natepe commented 1 year ago

This is the configuration in the mdb:

@MessageDriven(name = "ReceiveSQSMDBean", activationConfig = {
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:jboss/sqs/queue/QueueName"),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
        @ActivationConfigProperty(propertyName = "transactionTimeout", propertyValue = "6000"),
        @ActivationConfigProperty(propertyName = "rebalanceConnections", propertyValue = "true") })

@ResourceAdapter("aws-sqs-rar.rar")
public class ReceiveSQSMDBean implements MessageListener {

This is the configuration in the wildfly standalone xml file:

<subsystem xmlns="urn:jboss:domain:resource-adapters:5.0">
            <resource-adapters>
                <resource-adapter id="aws-sqs-rar.rar">
                    <archive>
                        aws-sqs-rar.rar
                    </archive>
                   <transaction-support>NoTransaction</transaction-support>
                   <admin-objects>
                        <admin-object class-name="io.bpic.aws.sqs.ra.SQSJMSQueue" jndi-name="java:jboss/sqs/queue/QueueName" pool-name="QueuePool">
                            <config-property name="queueName">dev_queue</config-property>
                        </admin-object>
                    </admin-objects>
                </resource-adapter>
            </resource-adapters>
        </subsystem>
bpalermo commented 1 year ago

Can you share the pool size config as well?