eMagiz Documentation

eMagiz Documentation

  • Docs
  • API
  • Help
  • Blog

›eMagiz Docs

eMagiz Docs

  • Home
  • Configuration import
  • Entity
  • SFTP size file list filter
  • Parameter map to XML transformer
  • Standard header enricher - Reply channel
  • XMPP header enricher - Chat thread id
  • IMAP idle channel adapter
  • Blocking channel connector
  • SOAP attachments header mapper
  • FTP accept once per modification file list filter
  • Standard header enricher - Expiration date
  • Recipient list router
  • HTTP Components message sender
  • Edit Message Bus: Namespace settings
  • Select Properties
  • Transform from enumeration
  • Standard splitter
  • TCP outbound gateway
  • Add security settings
  • Edit Gateway Call
  • Edit XPath Field
  • XML to JSON transformer
  • View license
  • Transform from date/time
  • Connector transport configuration
  • Custom error message activator
  • Payload validating interceptor
  • Netty connector transport configuration
  • New Mendix project credentials
  • Segment group
  • Job registry bean post processor
  • Web service message receiver servlet
  • Ehcache cache
  • SFTP inbound channel adapter
  • Flat file to XML transformer
  • Netty acceptor
  • Create popup - Step 2
  • Kafka template
  • Simple job launcher
  • Tag
  • Message endpoint adapter
  • Byte array raw (de)serializer
  • Edit error alert template
  • JDBC result set to XML transformer
  • Default HTTP header mapper
  • Default SFTP caching session factory
  • Merlin crypto
  • JDBC H2 connection pool
  • Edit Alert Notifying
  • Parse map
  • ThClient table reading activator
  • JMS queue scheduled trigger
  • SQL Script
  • Simple WSDL 1.1 definition
  • Standard router
  • EDI mapping
  • Concurrent map cache
  • EDI to XML transformer
  • XSLT transformer
  • WebSphere caching connection factory
  • SFTP composite file list filter
  • XMPP outbound channel adapter
  • SFTP age file list filter
  • Base64 decoding transformer
  • Source filter
  • Copy properties to runtime
  • Firewall configuration (system admin)
  • Combined entry connector details
  • Payload root QName endpoint mapping - endpoint map entry
  • File to bytes transformer
  • Specify requirements integration details
  • MIME to S/MIME transformer
  • Management
  • Form Title
  • Task executor
  • SSL web service message sender
  • Netty acceptor transport configuration
  • FTP outbound channel adapter
  • Accept once file list filter
  • Metacom authentication SAAJ SOAP interceptor
  • Mendix authentication SOAP header mapper
  • Context handler
  • Simple dispatcher servlet
  • XML to flat file transformer
  • JDBC inbound channel adapter
  • XML mapping message consumer
  • JDBC parameter
  • XSLT snippet
  • Web service header enricher
  • OAuth 2.0 access token advice
  • Header filter
  • Property placeholder
  • Copy CDM Codes and System Codes to Environment
  • HTTP header
  • JSON to XML transformer
  • Generate flat file definition based on comma separated values
  • Standard header enricher - Priority
  • Image transformer
  • HTTP inbound channel adapter
  • OAuth 2.0 resource
  • File item reader message source
  • System settings
  • Amazon S3 authentication interceptor
  • Field parse info
  • MxConnector settings
  • TCP connection factory
  • HornetQ JMS server manager
  • XPath filter
  • Address settings
  • Error to XML transformer
  • Mail header enricher - Bcc
  • SOAP to message header mapping
  • Create popup - Step 1
  • Regex pattern file list filter
  • Message history
  • Kafka outbound channel adapter
  • Proxy web service message sender
  • Custom field
  • JDBC channel message store
  • JDBC outbound channel adapter
  • Runtime scheduled trigger
  • New definition
  • JMS caching connection factory
  • TCP inbound channel adapter
  • Port Forward Maintenance
  • Edit Image
  • Standard header enricher - Custom header
  • eMagiz 3.x license
  • In-VM acceptor transport configuration
  • OAuth 2.0 user redirect required exception resolver
  • Default FTP session factory
  • Simple cache manager
  • Bridge configuration
  • job-dashboard
  • Mendix FileDocument WS request transformer
  • Create new message bus
  • Log entry trigger
  • New XML definition
  • String to wrapped XML transformer
  • Servlet context handler
  • Ehcache cache manager
  • Mail inbound channel adapter
  • Default SFTP session factory
  • Conditional
  • SOAP action callback
  • Standard filter
  • SAAJ SOAP message factory
  • Group
  • ISO8583 XML to bytes transformer
  • Mapping service gateway
  • Delaying file list filter
  • HTTP outbound gateway
  • S/MIME to MIME transformer
  • SFTP simple pattern file list filter
  • Expression evaluating request handler advice
  • Mail attachment transformer
  • History of properties in this environment
  • eMagiz 1.x license
  • Composite cache manager
  • Default FTP caching session factory
  • Cache annotation driven
  • Deployment step
  • Qpid AMQP connector settings
  • Cluster connection configuration
  • XML validating filter
  • Kafka message driven channel adapter
  • Apache ActiveMQ Artemis server
  • Debug interceptor
  • JMS listener
  • Global wire tap
  • XSLT parameter
  • FTP simple pattern file list filter
  • Code type
  • XPath header enricher - Header
  • MIME message to XML transformer
  • A logical service level
  • CDM code
  • XMPP header enricher
  • Recipient
  • Notification setting
  • Column definition
  • New configuration
  • Entry tracking interceptor
  • File inbound channel adapter
  • Security settings
  • FOP XSL-FO result factory
  • File outbound channel adapter
  • Zimbra authentication SAAJ SOAP interceptor
  • new-version
  • Port Forward DMZ
  • Payload type router
  • FTP composite file list filter
  • Sonic connection factory
  • Job
  • eMagiz 2.x license
  • Component
  • HTTP outbound channel adapter
  • Route configuration
  • Default WSDL 1.1 definition
  • JMS listener container
  • JMS outbound gateway
  • JDBC BoneCP data source
  • Channel
  • Edit System
  • Edit Data Type
  • Message channel monitoring trigger
  • XML to MIME message transformer
  • Job manager
  • XMPP presence outbound channel adapter
  • ISO header
  • FTP age file list filter
  • Basic access authentication interceptor
  • Base64 encoding transformer
  • Web service header enricher - SOAP action
  • SOAP action
  • Standard service activator
  • Byte array STX/ETX (de)serializer
  • XML to string transformer
  • Default FTPS caching session factory
  • Accept once per modification file list filter
  • Servlet handler
  • ThClient connector
  • JDBC stored procedure outbound gateway
  • Standard header enricher - Error channel
  • ThClient changes reading activator
  • Logging channel adapter
  • Edit e-mail
  • SFTP outbound channel adapter
  • JMS queue configuration
  • XSLT view
  • JMS message driven channel adapter
  • JDBC stored procedure inbound channel adapter
  • JMS inbound gateway
  • FOP XSL-FO result transformer
  • Mail to string transformer
  • ActiveMQ security manager gateway
  • Message bridge
  • Result to string transformer
  • Payload root QName endpoint mapping
  • ISO8583 bytes to XML transformer
  • Size file list filter
  • Byte array CR/LF (de)serializer
  • Relationship
  • Rename configuration
  • TCP inbound gateway
  • Attribute
  • HTTP request address extracting interceptor
  • Standard header enricher - Correlation id
  • Mendix authentication SAAJ SOAP interceptor
  • Byte array length header (de)serializer
  • Instance configuration
  • Select type of new trigger
  • Byte array text length header (de)serializer
  • Mail header enricher - Attachment filename
  • Poller
  • Mail header enricher - Content type
  • JDBC SQL parameter definition
  • Result to document transformer
  • Concurrent map cache manager
  • Request handler circuit breaker advice
  • Global channel interceptor
  • Mail header enricher - From
  • Calculate exponential moving average
  • Edit eMagiz Mendix Connector configuration
  • Jetty Server
  • XML to EDI transformer
  • Age file list filter
  • JMS outbound channel adapter
  • Transform from boolean
  • OSGi service
  • MBean export
  • JMS XML message converter
  • Object to string transformer
  • Edit popup
  • Lock-file file list filter
  • Edit Attribute
  • FTP size file list filter
  • Mail outbound channel adapter
  • Edit String Value Transformation
  • Transform from numbers
  • UN/EDIFACT to XML transformer
  • Microflow invoking message consumer
  • SFTP regex pattern file list filter
  • New Mendix user credentials
  • In VM acceptor
  • File to string transformer
  • Timestamped filename generator
  • WebSphere connection factory
  • Wizard 'publish web service'
  • Property
  • HTTP inbound gateway
  • SSL select channel connector
  • FTP lock-file file list filter
  • Web service inbound gateway
  • Job execution listener gateway
  • JVM performance monitor
  • Topic configuration
  • Standard inbound channel adapter
  • Netty connector
  • Log appender channel adapter
  • Destination filter
  • Custom attribute
  • Mail header enricher
  • OAuth 2.0 REST template
  • Mail header enricher - Reply to
  • Edit Root Entity
  • Map job registry
  • Character replacing transformer
  • SOAP fault message resolver
  • XMPP inbound channel adapter
  • Detailed SOAP fault message resolver
  • Default FTPS session factory
  • FTP inbound channel adapter
  • Table definition
  • Basic security handler
  • Message handler monitoring trigger
  • New Mendix module
  • WS-Addressing action callback
  • XPath expression
  • Import a Mendix domain model
  • SFTP accept once per modification file list filter
  • Default TCP SSL context support
  • Resource handler
  • Static Input
  • Field
  • Qpid JMS connection factory
  • Mail header enricher - Cc
  • FTP regex pattern file list filter
  • REST template
  • MBean server
  • Segment
  • Format filename generator
  • Certificate configuration
  • Transform from string
  • Sub-component
  • JDBC OSGi data source reference
  • XPath transformer
  • Port Forward User
  • JDBC Initialize database
  • Job repository
  • Message type
  • Standard transformer
  • Byte array single terminator (de)serializer
  • XPath splitter
  • Properties
  • Select channel connector
  • JMX multi attribute polling message source
  • Log item type mapping
  • Header value router
  • Groovy variable
  • Port Forward JMS
  • XPath router
  • Mail header enricher - Multipart mode
  • JDBC outbound gateway
  • Sonic caching connection factory
  • SOAP message dispatcher
  • Control bus
  • Standard header enricher
  • Exit tracking interceptor
  • TCP outbound channel adapter
  • Azure Storage Services authentication interceptor
  • SFTP lock-file file list filter
  • Edit line tokenizer
  • XMPP connection
  • Edit message type
  • Servlet mapping
  • WSS4J security interceptor
  • XPath header enricher
  • Runtime monitoring trigger
  • In-VM connector transport configuration
  • Mail header enricher - Subject
  • Aggregator
  • Edit extra JMS queue
  • Create queue
  • Simple pattern file list filter
  • Mendix service definition
  • Java mail sender
  • Request handler retry advice
  • Job launching gateway
  • XSLT extension gateway
  • In VM connector
  • Composite file list filter
  • Cluster connection
  • XML to UN/EDIFACT transformer
  • Web service message listener
  • XMPP presence inbound channel adapter
  • JMS queue monitoring trigger
  • XMPP header enricher - Chat to
  • Target Accept
  • XMPP presence to XML transformer
  • JMS OSGi connection factory reference
  • Web service outbound gateway
  • Mail header enricher - To
  • JDBC stored procedure outbound channel adapter
  • Header value mapping
  • Flow controller
  • Simple XSD schema
  • HornetQ caching connection factory
  • HornetQ connection factory
  • Command controller
  • Payload type mapping
  • View Property
  • Create an AWS slot for this bus environment
  • XPath value mapping
  • Authorization service gateway
  • Command executor gateway
  • HornetQ security manager gateway
  • Message handler scheduled trigger
  • Error message trigger
  • Edit Cron Helper
  • Cron-trigger helper
  • Message channel scheduled trigger
  • Mikrotik service activator
  • -
  • Dashboard
  • Runtime dashboard
  • Packages
  • Bus processes
  • Edit Message Bus
  • Settings
  • Edit settings
  • New cloud runtime
  • Cloud runtime settings
  • Wire tap
  • Integration
  • Notification setting
  • Step
  • amqp-broker
  • view-amqp-broker
  • Value mapping
  • Kafka message listener container
  • Global settings
  • Web service URI variable
  • HTTP URI variable
  • Edit transport configuration
  • Edit
  • Flow designer
  • Other
  • System code
  • Edit eMagiz Runtime VM

Address settings

Artemis has a unique addressing model that is both powerful and flexible and that offers great performance. The addressing model comprises three main concepts: addresses, queues and routing types.

An address represents a messaging endpoint. Within the configuration, a typical address is given a unique name, 0 or more queues, and a routing type.

A queue is associated with an address. There can be multiple queues per address. Once an incoming message is matched to an address, the message will be sent on to one or more of its queues, depending on the routing type configured. Queues can be configured to be automatically created and deleted.

Documentation


id: address-settings title: Address settings sidebar_label: Address settings


Configuration settings that are applied on the address level.

A block of settings which will be applied against any addresses with a name that matches a certain wildcard expression.

When match is jms.queue.example for example, the settings would only be applied to any addresses which exactly match the address jms.queue.example. You can also use wildcards to apply settings against many addresses. For example, if you used the match string jms.queue.#, the settings would be applied to all addresses that start with jms.queue. (which would be all JMS queues).

Note that only the most specific match is applied for each address. Some examples from most specific to least specific: jms.queue.example (matches one JMS queue), jms.*.example (matches one JMS queue and one JMS topic), jms.queue.# (matches all JMS queues), jms.# (matches all JMS queues and JMS topics).

Match

A HornetQ wildcard expression contains words delimited by the character . (full stop).

The special characters # and * also have special meaning and can take the place of a word:

  • the character # matches any sequence of zero or more words
  • the character * matches a single word

So the wildcard news.europe.# would match news.europe, news.europe.sport, news.europe.politics and news.europe.politics.regional, but would not match news.usa, news.usa.sport nor entertainment.

The wildcard news.* would match news.europe, but not news.europe.sport.

The wildcard news.*.sport would match news.europe.sport and also news.usa.sport, but not news.europe.politics.

Note that addresses of JMS queues are always prefixed with jms.queue. and addresses of JMS topics with jms.topic.. So the wildcard jms.queue.# would match all JMS queues for example.

Required

Last value queue

Defines whether a queue only uses last values or not.

Last value queues are special queues which discard any messages when a newer message with the same value for a well-defined last value property is put in the queue. In other words, a last value queue only retains the last value.

The property name used to identify the last value is _HQ_LVQ_NAME.

Default is false.

Max size

The maximum memory the address could have before applying the address full message policy.

No that this setting applies per address. If you configure a maximum size for an address, that means each matching address will have the maximum size that you specified. It does not mean that the total overall size of all matching addresses is limited to this size.

Default is -1 (no limit).

Address full message policy

This attribute can have one of the following values: page, drop or block and determines what happens when an address reaches its maximum size.

If the value is page then further messages will be paged to disk. If the value is drop then further messages will be silently dropped. If the value is block then client message producers will block when they try and send further messages.

Default is page.

Page size

The size of each page file used on the paging system.

The page size must be (significantly) smaller than the max size.

Default is 10485760 (10 MiB)

Page cache max size

The system will keep up to this amount of page files in memory to optimize IO during paging navigation.

Default is 5.

Max delivery attempts

Defines how many time a cancelled message can be redelivered before sending to the dead letter address.

Default is 10.

Redelivery delay

Defines how long to wait before attempting redelivery of a cancelled message.

Default is 0 (no delay between redelivery attempts).

Redelivery multiplier

Multiplier to apply to the time since the last redelivery attempt to compute the time to the next attempt. This allows you to implement an exponential backoff between redelivery attempts.

Default is 1.0, resulting in a fixed delay between redelivery attempts.

Max redelivery delay

Maximum value for the redelivery delay, i.e. this limits how much the delay can increase when using a multiplier that is bigger than 1.0.

Default is equal to the redelivery delay.

Dead letter address

Defines where to send a message that cannot be delivered.

If a dead letter address is not specified, messages will be removed after max delivery attempts unsuccessful attempts.

Default is empty.

Expiry delay

Defines the expiration time that will be used for messages which are using the default expiration time (i.e. 0).

For example, if expiry delay is set to 10 and a message which is using the default expiration time (i.e. 0) arrives, then its expiration time of 0 will be changed to 10. However, if a message which is using an expiration time of 20 arrives, then its expiration time will remain unchanged.

Setting expiry-delay to -1 will disable this feature.

Default is -1.

Expiry address

Defines where to send a message that has expired.

If messages are expired and no expiry address is specified, messages are simply removed from the queue and dropped.

Default is empty.

Redistribution delay

Defines the delay in milliseconds after the last consumer is closed on a queue before redistributing messages from that queue to other nodes of the cluster which do have matching consumers. A delay of zero means the messages will be immediately redistributed. A value of -1 signifies that messages will never be redistributed.

It often makes sense to introduce a delay before redistributing as it's a common case that a consumer closes but another one quickly is created on the same queue, in such a case you probably don't want to redistribute immediately since the new consumer will arrive shortly.

Default is -1 (no redistribution).

Send to DLA on no route

If a message is sent to an address, but the server does not route it to any queues, for example, there might be no queues bound to that address, or none of the queues have filters that match, then normally that message would be discarded. However if this parameter is set to true for that address, if the message is not routed to any queues it will instead be sent to the dead letter address (DLA) for that address, if it exists.

Default is false.

Message counter history limit

How many days to keep message counter history.

Default is 0.

A slow consumer with a server-side queue (e.g. JMS topic subscriber) can pose a significant problem for broker performance. If messages build up in the consumer's server-side queue then memory will begin filling up and the broker may enter paging mode which would impact performance negatively. However, criteria can be set so that consumers which don't acknowledge messages quickly enough can potentially be disconnected from the broker which in the case of a non-durable JMS subscriber would allow the broker to remove the subscription and all of its messages freeing up valuable server resources.

By default the server will not detect slow consumers.

The calculation to determine whether or not a consumer is slow only inspects the number of messages a particular consumer has acknowledged. It doesn't take into account whether or not flow control has been enabled on the consumer, whether or not the consumer is streaming a large message, etc. The message production rate is also assumed to meet or exceed the slow consumer threshold. Keep this in mind when configuring slow consumer detection.

Please note that slow consumer checks are performed using the scheduled thread pool and that each queue on the broker with slow consumer detection enabled will cause a new entry in the internal java.util.concurrent.ScheduledThreadPoolExecutor instance. If there are a high number of queues and the slow consumer check period is relatively low then there may be delays in executing some of the checks. However, this will not impact the accuracy of the calculations used by the detection algorithm.

Slow consumer threshold

The minimum rate of message consumption allowed before a consumer is considered "slow." Measured in messages-per-second.

Default is -1 (i.e. disabled).

Slow consumer policy

What should happen when a slow consumer is detected.

Kill will kill the consumer's connection (which will obviously impact any other client threads using that same connection).

Notify will send a CONSUMER_SLOW management notification which an application could receive and take action with.

Default is notify.

Slow consumer check period

How often to check for slow consumers on a particular queue. Measured in seconds.

Default is 5.

← XPath filterRoute configuration →
eMagiz Documentation
Docs
Getting Started (or other categories)Guides (or other categories)API Reference (or other categories)
Community
User ShowcaseStack OverflowProject ChatTwitter
More
BlogGitHubStar
Copyright © 2019 eMagiz