7 Replies Latest reply on Oct 10, 2017 2:42 AM by Satish Shelake

    Wildfly HornetQ message gets stuck

    Satish Shelake Newbie

      HI,  

       

         I am facing problem in wildfly 8.2.1,   I have application which is using one queue with 30 MDB listener. If I put one message and based on message I written logic wait thread for some time, then I put messages on queue, Then for 100 messages 3 messages get stuck on queue. These 3 messages are getting execute after wait thread gets completed . It is strange behavior.  Why messages get stuck and not assign to other instance of MDB?

        • 1. Re: Wildfly HornetQ message gets stuck
          Miroslav Novak Master

          Hi Satish,

           

          could you share your configuration of the server?

           

          Thanks,

          Mirek

          • 2. Re: Wildfly HornetQ message gets stuck
            Satish Shelake Newbie

            <?xml version="1.0" ?>

             

             

            <server xmlns="urn:jboss:domain:2.2">

             

             

                <extensions>

                    <extension module="org.jboss.as.clustering.infinispan"/>

                    <extension module="org.jboss.as.connector"/>

                    <extension module="org.jboss.as.deployment-scanner"/>

                    <extension module="org.jboss.as.ee"/>

                    <extension module="org.jboss.as.ejb3"/>

                    <extension module="org.jboss.as.jacorb"/>

                    <extension module="org.jboss.as.jaxrs"/>

                    <extension module="org.jboss.as.jdr"/>

                    <extension module="org.jboss.as.jmx"/>

                    <extension module="org.jboss.as.jpa"/>

                    <extension module="org.jboss.as.jsf"/>

                    <extension module="org.jboss.as.jsr77"/>

                    <extension module="org.jboss.as.logging"/>

                    <extension module="org.jboss.as.mail"/>

                    <extension module="org.jboss.as.messaging"/>

                    <extension module="org.jboss.as.naming"/>

                    <extension module="org.jboss.as.pojo"/>

                    <extension module="org.jboss.as.remoting"/>

                    <extension module="org.jboss.as.sar"/>

                    <extension module="org.jboss.as.security"/>

                    <extension module="org.jboss.as.transactions"/>

                    <extension module="org.jboss.as.webservices"/>

                    <extension module="org.jboss.as.weld"/>

                    <extension module="org.wildfly.extension.batch"/>

                    <extension module="org.wildfly.extension.io"/>

                    <extension module="org.wildfly.extension.undertow"/>

                </extensions>

             

             

                <system-properties>

                    <property name="jms.queue.consumer.count" value="30"/>

                </system-properties>

                <vault>

                    <vault-option name="KEYSTORE_URL" value=".\vault\vault.keystore"/>

                    <vault-option name="KEYSTORE_PASSWORD" value="MASK-3P6SbQ/.hS7"/>

                    <vault-option name="KEYSTORE_ALIAS" value="vault"/>

                    <vault-option name="SALT" value="salt1234"/>

                    <vault-option name="ITERATION_COUNT" value="50"/>

                    <vault-option name="ENC_FILE_DIR" value=".\vault"/>

                </vault>

             

             

                <management>

                    <security-realms>

                        <security-realm name="ManagementRealm">

                            <server-identities>

                                <ssl>

                                     <keystore path="certificates/keystore.p12" relative-to="jboss.home.dir" keystore-password="${VAULT::ssl_keystore::password::1}" key-password="${VAULT::ssl_keypass::password::1}"/>

                                </ssl>

                            </server-identities>

                            <authentication>

                                <local default-user="$local" skip-group-loading="true"/>

                                <properties path="mgmt-users.properties" relative-to="jboss.server.config.dir"/>

                            </authentication>

                            <authorization map-groups-to-roles="false">

                                <properties path="mgmt-groups.properties" relative-to="jboss.server.config.dir"/>

                            </authorization>

                        </security-realm>

                        <security-realm name="ApplicationRealm">

                            <authentication>

                                <local default-user="$local" allowed-users="*" skip-group-loading="true"/>

                                <properties path="application-users.properties" relative-to="jboss.server.config.dir"/>

                            </authentication>

                            <authorization>

                                <properties path="application-roles.properties" relative-to="jboss.server.config.dir"/>

                            </authorization>

                        </security-realm>

                        <security-realm name="UndertowRealm">

                            <server-identities>

                                <ssl>

                                     <keystore path="certificates/keystore.p12" relative-to="jboss.home.dir" keystore-password="${VAULT::ssl_keystore::password::1}" key-password="${VAULT::ssl_keypass::password::1}"/>

                                </ssl>

                            </server-identities>

                        </security-realm>

                    </security-realms>

                    <audit-log>

                        <formatters>

                            <json-formatter name="json-formatter"/>

                        </formatters>

                        <handlers>

                            <file-handler name="file" formatter="json-formatter" path="audit-log.log" relative-to="jboss.server.data.dir"/>

                        </handlers>

                        <logger log-boot="true" log-read-only="false" enabled="false">

                            <handlers>

                                <handler name="file"/>

                            </handlers>

                        </logger>

                    </audit-log>

                    <management-interfaces>

                        <http-interface security-realm="ManagementRealm" http-upgrade-enabled="true">

                            <socket-binding https="management-https"/>

                        </http-interface>

                    </management-interfaces>

                    <access-control provider="simple">

                        <role-mapping>

                            <role name="SuperUser">

                                <include>

                                    <user name="$local"/>

                                </include>

                            </role>

                        </role-mapping>

                    </access-control>

                </management>

             

             

                <profile>

                    <subsystem xmlns="urn:jboss:domain:logging:2.0">

                        <console-handler name="CONSOLE">

                            <level name="INFO"/>

                            <formatter>

                                <named-formatter name="COLOR-PATTERN"/>

                            </formatter>

                        </console-handler>

                        <periodic-rotating-file-handler name="FILE" autoflush="true">

                            <formatter>

                                <named-formatter name="PATTERN"/>

                            </formatter>

                            <file relative-to="jboss.server.log.dir" path="server.log"/>

                            <suffix value=".yyyy-MM-dd"/>

                            <append value="true"/>

                        </periodic-rotating-file-handler>

                        <logger category="com.arjuna">

                            <level name="WARN"/>

                        </logger>

                        <logger category="org.apache.tomcat.util.modeler">

                            <level name="WARN"/>

                        </logger>

                        <logger category="org.jboss.as.config">

                            <level name="DEBUG"/>

                        </logger>

                        <logger category="sun.rmi">

                            <level name="WARN"/>

                        </logger>

                        <logger category="jacorb">

                            <level name="WARN"/>

                        </logger>

                        <logger category="jacorb.config">

                            <level name="ERROR"/>

                        </logger>

                        <logger category="jboss.jdbc.spy">

                            <level name="TRACE"/>

                        </logger>

                        <logger category="log4j.logger.org.hibernate.type" use-parent-handlers="true">

                            <level name="TRACE"/>

                            <handlers>

                                <handler name="CONSOLE"/>

                            </handlers>

                        </logger>

                        <logger category="log4j.logger.org.hibernate" use-parent-handlers="true">

                            <level name="ERROR"/>

                            <handlers>

                                <handler name="CONSOLE"/>

                            </handlers>

                        </logger>

            <logger category="org.apache.cxf.service" use-parent-handlers="true">

                            <level name="ERROR"/>

                        </logger>

            <logger category="org.hibernate.hql" use-parent-handlers="true">

                            <level name="ERROR"/>

                        </logger>

                        <root-logger>

                            <level name="INFO"/>

                            <handlers>

                                <handler name="CONSOLE"/>

                                <handler name="FILE"/>

                            </handlers>

                        </root-logger>

                        <formatter name="PATTERN">

                            <pattern-formatter pattern="%d{yyyy-MM-dd HH:mm:ss,SSS} %-5p [%c] (%t) %s%E%n"/>

                        </formatter>

                        <formatter name="COLOR-PATTERN">

                            <pattern-formatter pattern="%K{level}%d{HH:mm:ss,SSS} %-5p [%c] (%t) %s%E%n"/>

                        </formatter>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:batch:1.0">

                        <job-repository>

                            <in-memory/>

                        </job-repository>

                        <thread-pool>

                            <max-threads count="10"/>

                            <keepalive-time time="30" unit="seconds"/>

                        </thread-pool>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:datasources:2.0">

                        <datasources>

                            <datasource jndi-name="java:jboss/datasources/DS" pool-name="DS" enabled="true" use-java-context="true">

                                <connection-url>jdbc:hsqldb:hsql://localhost:9001/ConfigDb;</connection-url>

                                <driver>hsqldb</driver>

                                <pool>

                                    <max-pool-size>100</max-pool-size>

                                </pool>

                                <security>

                                    <user-name>sa</user-name>

                                     <password>${VAULT::_db::password::1}</password>

                                </security>

                            </datasource>

            <datasource jndi-name="java:jboss/datasources/logDS" pool-name="logDS" enabled="true" use-java-context="true">

                                <connection-url>jdbc:hsqldb:hsql://localhost:9001/LogDb;</connection-url>

                                <driver>hsqldb</driver>

                                <pool>

                                    <max-pool-size>100</max-pool-size>

                                </pool>

                                <security>

                                    <user-name>sa</user-name>

                                    <password>${VAULT::_db::password::1}</password>

                                </security>

                            </datasource>

                            <datasource jndi-name="java:jboss/datasources/ExampleDS" pool-name="ExampleDS" enabled="true" use-java-context="true">

                                <connection-url>jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE</connection-url>

                                <driver>h2</driver>

                                <security>

                                    <user-name>sa</user-name>

                                    <password>sa</password>

                                </security>

                            </datasource>

                            <drivers>

                                <driver name="hsqldb" module="org.hsqldb">

                                    <xa-datasource-class>org.hsqldb.jdbc.JdbcDataSource</xa-datasource-class>

                                </driver>

                                <driver name="h2" module="com.h2database.h2">

                                    <xa-datasource-class>org.h2.jdbcx.JdbcDataSource</xa-datasource-class>

                                </driver>

                            </drivers>

                        </datasources>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:deployment-scanner:2.0">

                        <deployment-scanner path="deployments" relative-to="jboss.server.base.dir" scan-interval="5000"/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:ee:2.0">

                        <ear-subdeployments-isolated>false</ear-subdeployments-isolated>

                        <spec-descriptor-property-replacement>true</spec-descriptor-property-replacement>

                        <jboss-descriptor-property-replacement>true</jboss-descriptor-property-replacement>

                        <concurrent>

                            <context-services>

                                <context-service name="default" jndi-name="java:jboss/ee/concurrency/context/default" use-transaction-setup-provider="true"/>

                            </context-services>

                            <managed-thread-factories>

                                <managed-thread-factory name="default" jndi-name="java:jboss/ee/concurrency/factory/default" context-service="default"/>

                            </managed-thread-factories>

                            <managed-executor-services>

                                <managed-executor-service name="default" jndi-name="java:jboss/ee/concurrency/executor/default" context-service="default" hung-task-threshold="60000" core-threads="5" max-threads="25" keepalive-time="5000"/>

                            </managed-executor-services>

                            <managed-scheduled-executor-services>

                                <managed-scheduled-executor-service name="default" jndi-name="java:jboss/ee/concurrency/scheduler/default" context-service="default" hung-task-threshold="60000" core-threads="2" keepalive-time="3000"/>

                            </managed-scheduled-executor-services>

                        </concurrent>

                        <default-bindings context-service="java:jboss/ee/concurrency/context/default" datasource="java:jboss/datasources/ExampleDS" jms-connection-factory="java:jboss/DefaultJMSConnectionFactory" managed-executor-service="java:jboss/ee/concurrency/executor/default" managed-scheduled-executor-service="java:jboss/ee/concurrency/scheduler/default" managed-thread-factory="java:jboss/ee/concurrency/factory/default"/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:ejb3:2.0">

                        <session-bean>

                            <stateless>

                                <bean-instance-pool-ref pool-name="slsb-strict-max-pool"/>

                            </stateless>

                            <stateful default-access-timeout="5000" cache-ref="simple" passivation-disabled-cache-ref="simple"/>

                            <singleton default-access-timeout="5000"/>

                        </session-bean>

                        <mdb>

                            <resource-adapter-ref resource-adapter-name="${ejb.resource-adapter-name:hornetq-ra.rar}"/>

                            <bean-instance-pool-ref pool-name="mdb-strict-max-pool"/>

                        </mdb>

                        <pools>

                            <bean-instance-pools>

                                <strict-max-pool name="slsb-strict-max-pool" max-pool-size="80" instance-acquisition-timeout="5" instance-acquisition-timeout-unit="MINUTES"/>

                                <strict-max-pool name="mdb-strict-max-pool" max-pool-size="30" instance-acquisition-timeout="5" instance-acquisition-timeout-unit="MINUTES"/>

                            </bean-instance-pools>

                        </pools>

                        <caches>

                            <cache name="simple"/>

                            <cache name="distributable" passivation-store-ref="infinispan" aliases="passivating clustered"/>

                        </caches>

                        <passivation-stores>

                            <passivation-store name="infinispan" cache-container="ejb" max-size="10000"/>

                        </passivation-stores>

                        <async thread-pool-name="default"/>

                        <timer-service thread-pool-name="default" default-data-store="default-file-store">

                            <data-stores>

                                <file-data-store name="default-file-store" path="timer-service-data" relative-to="jboss.server.data.dir"/>

                            </data-stores>

                        </timer-service>

                        <remote connector-ref="http-remoting-connector" thread-pool-name="default"/>

                        <thread-pools>

                            <thread-pool name="default">

                                <max-threads count="10"/>

                                <keepalive-time time="100" unit="milliseconds"/>

                            </thread-pool>

                        </thread-pools>

                        <iiop enable-by-default="true" use-qualified-name="false"/>

                        <default-security-domain value="other"/>

                        <default-missing-method-permissions-deny-access value="true"/>

                        <statistics enabled="true"/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:io:1.1">

                        <worker name="default"/>

                        <buffer-pool name="default"/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:infinispan:2.0">

                        <cache-container name="web" default-cache="passivation" module="org.wildfly.clustering.web.infinispan">

                            <local-cache name="passivation" batching="true">

                                <file-store passivation="true" purge="false"/>

                            </local-cache>

                            <local-cache name="persistent" batching="true">

                                <file-store passivation="false" purge="false"/>

                            </local-cache>

                        </cache-container>

                        <cache-container name="ejb" default-cache="passivation" module="org.wildfly.clustering.ejb.infinispan" aliases="sfsb">

                            <local-cache name="passivation" batching="true">

                                <file-store passivation="true" purge="false"/>

                            </local-cache>

                            <local-cache name="persistent" batching="true">

                                <file-store passivation="false" purge="false"/>

                            </local-cache>

                        </cache-container>

                        <cache-container name="hibernate" default-cache="local-query" module="org.hibernate">

                            <local-cache name="entity">

                                <transaction mode="NON_XA"/>

                                <eviction strategy="LRU" max-entries="10000"/>

                                <expiration max-idle="100000"/>

                            </local-cache>

                            <local-cache name="local-query">

                                <transaction mode="NONE"/>

                                <eviction strategy="LRU" max-entries="10000"/>

                                <expiration max-idle="100000"/>

                            </local-cache>

                            <local-cache name="timestamps">

                                <transaction mode="NONE"/>

                                <eviction strategy="NONE"/>

                            </local-cache>

                        </cache-container>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:jacorb:1.3">

                        <orb socket-binding="jacorb" ssl-socket-binding="jacorb-ssl">

                            <initializers security="identity" transactions="spec"/>

                        </orb>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:jaxrs:1.0"/>

                    <subsystem xmlns="urn:jboss:domain:jca:2.0">

                        <archive-validation enabled="true" fail-on-error="true" fail-on-warn="false"/>

                        <bean-validation enabled="true"/>

                        <default-workmanager>

                            <short-running-threads>

                                <core-threads count="50"/>

                                <queue-length count="50"/>

                                <max-threads count="50"/>

                                <keepalive-time time="10" unit="seconds"/>

                            </short-running-threads>

                            <long-running-threads>

                                <core-threads count="50"/>

                                <queue-length count="50"/>

                                <max-threads count="50"/>

                                <keepalive-time time="10" unit="seconds"/>

                            </long-running-threads>

                        </default-workmanager>

                        <cached-connection-manager/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:jdr:1.0"/>

                    <subsystem xmlns="urn:jboss:domain:jmx:1.3">

                        <expose-resolved-model/>

                        <expose-expression-model/>

                        <remoting-connector/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:jpa:1.1">

                        <jpa default-datasource="" default-extended-persistence-inheritance="DEEP"/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:jsf:1.0"/>

                    <subsystem xmlns="urn:jboss:domain:jsr77:1.0"/>

                    <subsystem xmlns="urn:jboss:domain:mail:2.0">

                        <mail-session name="default" jndi-name="java:jboss/mail/Default">

                            <smtp-server outbound-socket-binding-ref="mail-smtp"/>

                        </mail-session>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:messaging:2.0">

                        <hornetq-server>

                            <security-enabled>false</security-enabled>

                            <statistics-enabled>true</statistics-enabled>

                            <journal-file-size>102400</journal-file-size>

             

             

                            <connectors>

                                <http-connector name="http-connector" socket-binding="https">

                                    <param key="http-upgrade-endpoint" value="http-acceptor"/>

                                </http-connector>

                                <http-connector name="http-connector-throughput" socket-binding="https">

                                    <param key="http-upgrade-endpoint" value="http-acceptor-throughput"/>

                                    <param key="batch-delay" value="50"/>

                                </http-connector>

                                <in-vm-connector name="in-vm" server-id="0"/>

                            </connectors>

             

             

                            <acceptors>

                                <http-acceptor http-listener="default" name="http-acceptor"/>

                                <http-acceptor http-listener="default" name="http-acceptor-throughput">

                                    <param key="batch-delay" value="50"/>

                                    <param key="direct-deliver" value="false"/>

                                </http-acceptor>

                                <in-vm-acceptor name="in-vm" server-id="0"/>

                            </acceptors>

             

             

                            <security-settings>

                                <security-setting match="#">

                                    <permission type="send" roles="guest"/>

                                    <permission type="consume" roles="guest"/>

                                    <permission type="createNonDurableQueue" roles="guest"/>

                                    <permission type="deleteNonDurableQueue" roles="guest"/>

                                </security-setting>

                            </security-settings>

             

             

                            <address-settings>

                                <address-setting match="#">

                                    <dead-letter-address>jms.queue.DLQ</dead-letter-address>

                                    <expiry-address>jms.queue.ExpiryQueue</expiry-address>

                                    <max-size-bytes>10485760</max-size-bytes>

                                    <page-size-bytes>2097152</page-size-bytes>

                                    <message-counter-history-day-limit>10</message-counter-history-day-limit>

                                </address-setting>

                            </address-settings>

             

             

                            <jms-connection-factories>

                                <connection-factory name="InVmConnectionFactory">

                                    <connectors>

                                        <connector-ref connector-name="in-vm"/>

                                    </connectors>

                                    <entries>

                                        <entry name="java:/ConnectionFactory"/>

                                    </entries>

                                </connection-factory>

                                <connection-factory name="RemoteConnectionFactory">

                                    <connectors>

                                        <connector-ref connector-name="http-connector"/>

                                    </connectors>

                                    <entries>

                                        <entry name="java:jboss/exported/jms/RemoteConnectionFactory"/>

                                    </entries>

                                </connection-factory>

                                <pooled-connection-factory name="hornetq-ra">

                                    <transaction mode="xa"/>

                                    <connectors>

                                        <connector-ref connector-name="in-vm"/>

                                    </connectors>

                                    <entries>

                                        <entry name="java:/JmsXA"/>

                                        <entry name="java:jboss/DefaultJMSConnectionFactory"/>

                                    </entries>

                                </pooled-connection-factory>

                            </jms-connection-factories>

             

             

                            <jms-destinations>

                                <jms-queue name="ExpiryQueue">

                                    <entry name="java:/jms/queue/ExpiryQueue"/>

                                </jms-queue>

                                <jms-queue name="DLQ">

                                    <entry name="queue/DLQ"/>

                                </jms-queue>

                                <jms-queue name="testQueue">

                                    <entry name="queue/testQueue"/>

                                    <entry name="queue/Queue"/>

                                </jms-queue>

                                <jms-queue name="Queue1">

                                    <entry name="queue/Queue1"/>

                                    <entry name="queue/Queue1"/>

                                </jms-queue>

                                <jms-queue name="Queue2">

                                    <entry name="queue/Queue2"/>

                                    <entry name="queue/Queue2"/>

                                </jms-queue>

                                <jms-queue name="Queue3">

                                    <entry name="queue/Queue3"/>

                                    <entry name="queue/Queue3"/>

                                </jms-queue>

                                <jms-queue name="Queue4">

                                    <entry name="queue/Queue4"/>

                                    <entry name="queue/Queue4"/>

                                </jms-queue>

                                <jms-queue name="Queue5">

                                    <entry name="queue/Queue5"/>

                                    <entry name="queue/Queue5"/>

                                </jms-queue>

                                <jms-queue name="Queue6">

                                    <entry name="queue/Queue6"/>

                                    <entry name="queue/Queue6"/>

                                </jms-queue>

                                <jms-queue name="Queue7">

                                    <entry name="queue/Queue7"/>

                                    <entry name="queue/Queue7"/>

                                </jms-queue>

                                <jms-queue name="Queue8">

                                    <entry name="queue/Queue8"/>

                                    <entry name="queue/Queue8"/>

                                </jms-queue>

                                <jms-queue name="Queue9">

                                    <entry name="queue/Queue9"/>

                                    <entry name="queue/Queue9"/>

                                </jms-queue>

                                <jms-queue name="Queue10">

                                    <entry name="queue/Queue10"/>

                                    <entry name="queue/Queue10"/>

                                </jms-queue>

                                <jms-queue name="Queue11">

                                    <entry name="queue/Queue11"/>

                                    <entry name="queue/Queue11"/>

                                </jms-queue>

                                <jms-queue name="Queue12">

                                    <entry name="queue/Queue12"/>

                                    <entry name="queue/Queue12"/>

                                </jms-queue>

                                <jms-queue name="Queue13">

                                    <entry name="queue/Queue13"/>

                                    <entry name="queue/Queue13"/>

                                </jms-queue>

                                <jms-queue name="Queue14">

                                    <entry name="queue/Queue14"/>

                                    <entry name="queue/Queue14"/>

                                </jms-queue>

                                <jms-queue name="Queue15">

                                    <entry name="queue/Queue15"/>

                                    <entry name="queue/Queue15"/>

                                </jms-queue>

                                <jms-queue name="JMSBridgeSourceQ">

                                    <entry name="queue/JMSBridgeSourceQ"/>

                                    <entry name="queue/JMSBridgeSourceQ"/>

                                </jms-queue>

                                <jms-queue name="logWritterQueue">

                                    <entry name="queue/logWritterQueue"/>

                                    <entry name="queue/logWritterQueue"/>

                                </jms-queue>

                                <jms-topic name="testTopic">

                                    <entry name="topic/MyTopic"/>

                                </jms-topic>

                            </jms-destinations>

                        </hornetq-server>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:naming:2.0">

                        <remote-naming/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:pojo:1.0"/>

                    <subsystem xmlns="urn:jboss:domain:remoting:2.0">

                        <endpoint worker="default"/>

                        <http-connector name="http-remoting-connector" connector-ref="default" security-realm="ApplicationRealm"/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:resource-adapters:2.0"/>

                    <subsystem xmlns="urn:jboss:domain:sar:1.0"/>

                    <subsystem xmlns="urn:jboss:domain:security:1.2">

                        <security-domains>

                            <security-domain name="other" cache-type="default">

                                <authentication>

                                    <login-module code="Remoting" flag="optional">

                                        <module-option name="password-stacking" value="useFirstPass"/>

                                    </login-module>

                                    <login-module code="RealmDirect" flag="required">

                                        <module-option name="password-stacking" value="useFirstPass"/>

                                    </login-module>

                                </authentication>

                            </security-domain>

                            <security-domain name="jboss-web-policy" cache-type="default">

                                <authorization>

                                    <policy-module code="Delegating" flag="required"/>

                                </authorization>

                            </security-domain>

                            <security-domain name="jboss-ejb-policy" cache-type="default">

                                <authorization>

                                    <policy-module code="Delegating" flag="required"/>

                                </authorization>

                            </security-domain>

                        </security-domains>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:transactions:2.0">

                        <core-environment>

                            <process-id>

                                <uuid/>

                            </process-id>

                        </core-environment>

                        <recovery-environment socket-binding="txn-recovery-environment" status-socket-binding="txn-status-manager"/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:undertow:1.2">

                        <buffer-cache name="default"/>

                        <server name="default-server">

                            <https-listener name="default" socket-binding="https" security-realm="UndertowRealm" max-post-size="209715200"/>

                            <host name="default-host" alias="localhost">

                                <location name="/" handler="welcome-content"/>

                                <filter-ref name="server-header"/>

                                <filter-ref name="x-powered-by-header"/>

                            </host>

                        </server>

                        <servlet-container name="default">

                            <jsp-config/>

                            <websockets/>

                        </servlet-container>

                        <handlers>

                            <file name="welcome-content" path="${jboss.home.dir}/welcome-content"/>

                        </handlers>

                        <filters>

                            <response-header name="server-header" header-name="Server" header-value="WildFly/8"/>

                            <response-header name="x-powered-by-header" header-name="X-Powered-By" header-value="Undertow/1"/>

                        </filters>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:webservices:1.2">

                        <modify-wsdl-address>true</modify-wsdl-address>

                        <wsdl-host>jbossws.undefined.host</wsdl-host>

                        <wsdl-port>${jboss.https.port:8080}</wsdl-port>

                        <wsdl-secure-port>${jboss.https.port:8443}</wsdl-secure-port>

                        <endpoint-config name="Standard-Endpoint-Config"/>

                        <endpoint-config name="Recording-Endpoint-Config">

                            <pre-handler-chain name="recording-handlers" protocol-bindings="##SOAP11_HTTP ##SOAP11_HTTP_MTOM ##SOAP12_HTTP ##SOAP12_HTTP_MTOM">

                                <handler name="RecordingHandler" class="org.jboss.ws.common.invocation.RecordingServerHandler"/>

                            </pre-handler-chain>

                        </endpoint-config>

                        <client-config name="Standard-Client-Config"/>

                    </subsystem>

                    <subsystem xmlns="urn:jboss:domain:weld:2.0"/>

                </profile>

             

             

                <interfaces>

                    <interface name="management">

                        <inet-address value="${jboss.bind.address.management:127.0.0.1}"/>

                    </interface>

                    <interface name="public">

                        <any-ipv4-address/>

                    </interface>

                    <interface name="unsecure">

                        <inet-address value="${jboss.bind.address.unsecure:127.0.0.1}"/>

                    </interface>

                </interfaces>

             

             

                <socket-binding-group name="standard-sockets" default-interface="public" port-offset="${jboss.socket.binding.port-offset:0}">

                    <socket-binding name="management-http" interface="management" port="${jboss.management.http.port:9990}"/>

                    <socket-binding name="management-https" interface="management" port="${jboss.management.https.port:9993}"/>

                    <socket-binding name="ajp" port="${jboss.ajp.port:8009}"/>

                    <socket-binding name="http" port="${jboss.http.port:8080}"/>

                    <socket-binding name="https" port="${jboss.https.port:8443}"/>

                    <socket-binding name="remoting" port="${jboss.https.port:8443}"/>

                    <socket-binding name="jacorb" interface="unsecure" port="3528"/>

                    <socket-binding name="jacorb-ssl" interface="unsecure" port="3529"/>

                    <socket-binding name="messaging-group" port="0" multicast-address="${jboss.messaging.group.address:231.7.7.7}" multicast-port="${jboss.messaging.group.port:9876}"/>

                    <socket-binding name="txn-recovery-environment" port="4712"/>

                    <socket-binding name="txn-status-manager" port="4713"/>

                    <outbound-socket-binding name="mail-smtp">

                        <remote-destination host="localhost" port="25"/>

                    </outbound-socket-binding>

                    <outbound-socket-binding name="http-outbound">

                        <remote-destination host="127.0.0.1" port="${jboss.http.port:8080}"/>

                    </outbound-socket-binding>

                </socket-binding-group>

             

             

            </server>

            • 3. Re: Wildfly HornetQ message gets stuck
              Satish Shelake Newbie

              I have tried consumer window count with -1,bu

              • 4. Re: Wildfly HornetQ message gets stuck
                Satish Shelake Newbie

                It is working with 0 value for consumer window count. Thanks a lot for your support

                • 5. Re: Wildfly HornetQ message gets stuck
                  Satish Shelake Newbie

                  Hi, Tanks for your valuable support. It is working fine with 0 value of consumer window count.

                  • 6. Re: Wildfly HornetQ message gets stuck
                    Miroslav Novak Master

                    Yes, I had consumer-windows-size on my mind when I saw your problems. Simply messages were in client's buffer and in "delivering" state. Message count on queue is not precise as it shows just close value to a real state. Problem is that to get exact message count on queue, work on queue i.e. sends and receives must be stopped and all threads with sends/receives must get to a "finished" state which is extremely hard and dangerous to do.

                     

                    consumer-windows-size sets size of client's buffer. In this case every session of MDB (you called it listener) is one consumer which has its own message buffer. I'm not sure if setting to 0 is what you want as it heavily depends on your requirements.

                     

                    It's great that you have managed to solve it :-)

                     

                    Mirek

                    • 7. Re: Wildfly HornetQ message gets stuck
                      Satish Shelake Newbie

                      Thank you once again