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

Cluster connection configuration

Creates a cluster of HornetQ servers that share the message processing load.

Documentation

HornetQ clusters allow groups of HornetQ servers to be grouped together in order to share message processing load. Each active node in the cluster is an active HornetQ server which manages its own messages and handles its own connections. A server must be configured to be clustered, you will need to set the clustered property to true, this is false by default.

The cluster is formed by each node declaring cluster connections to other nodes in the server configuration. When a node forms a cluster connection to another node, internally it creates a core bridge connection between it and the other node, this is done transparently behind the scenes - you don't have to declare an explicit bridge for each node. These cluster connections allow messages to flow between the nodes of the cluster to balance load.

Name

All cluster connections must have a unique name in the server.

Required

Address

Each cluster connection only applies to messages sent to an address that starts with this value. You can use the value jms to create a cluster connection that applies to all JMS queue and topic subscriptions, since they map to core queues that start with the substring jms.

The address can be any value and you can have many cluster connections with different values of address, simultaneously balancing messages for those addresses, potentially to different clusters of servers. By having multiple cluster connections on different addresses a single HornetQ server can effectively take part in multiple clusters simultaneously.

Be careful not to have multiple cluster connections with overlapping values of address, e.g. "europe" and "europe.news" since this could result in the same messages being distributed between more than one cluster connection, possibly resulting in duplicate deliveries.

Required

Connector name

Connector for connecting to this server. These settings are send to the cluster for discovery purposes, so other servers/clients can connect to this node without having these settings statically defined.

Required

Static connectors

A comma-separated list of connector names defined in the core configuration. The cluster connection will use these connectors to make its initial connection to the cluster. There may be many more servers in the cluster, but these will be discovered via one of these connectors once an initial connection has been made.

This property or discovery group name must be provided (they are mutually exclusive), but if neither is set an empty list of static connectors is used.

Allow direct connections only

Sometimes you want to explicitly define a cluster more explicitly, that is control which server connect to each other in the cluster. This is typically used to form non symmetrical clusters such as chain cluster or ring clusters. In this case, specify a static list of connectors (not a discovery group), and set this property to true.

By setting allow direct connections only to true the cluster connection will only create connections using the statically defined connections, where normally other cluster connections might be discovered after the initial connection is made.

Default is false.

Retry interval

This optional parameter determines the period in milliseconds between subsequent reconnection attempts, if the connection to a target node in the cluster has failed.

This parameter has the same meaning as the retry interval on a bridge.

Default is 500 ms.

Retry interval multiplier

This optional parameter determines a multiplier to apply to the time since the last retry to compute the time to the next retry. This allows you to implement an exponential backoff between retry attempts.

Let's take an example: If we set retry-interval to 1000 ms and we set retry-interval-multiplier to 2.0, then, if the first reconnect attempt fails, we will wait 1000 ms then 2000 ms then 4000 ms between subsequent reconnection attempts. The default value is 1.0 meaning each reconnect attempt is spaced at equal intervals.

Default is 1.0.

Max retry interval

The maximum retry interval in the case a retry interval multiplier has been specified.

Default is 2000 (2 seconds).

Reconnect attempts

This optional parameter determines the total number of reconnect attempts the bridge will make before giving up and shutting down. A value of -1 signifies an unlimited number of attempts.

Default is -1.

Use duplicate detection

Internally cluster connections use bridges to link the nodes, and bridges can be configured to add a duplicate id property in each message that is forwarded. If the target node of the bridge crashes and then recovers, messages might be resent from the source node. By enabling duplicate detection any duplicate messages will be filtered out and ignored on receipt at the target node.

This parameter has the same meaning as use duplicate detection on a bridge.

Default is true.

Forward when no consumers

This parameter determines whether messages will be distributed round robin between other nodes of the cluster irrespective of whether there are matching or indeed any consumers on other nodes.

If this is set to true then each incoming message will be round robin'd even though the same queues on the other nodes of the cluster may have no consumers at all, or they may have consumers that have non matching message filters (selectors). Note that HornetQ will not forward messages to other nodes if there are no queues of the same name on the other nodes, even if this parameter is set to true.

If this is set to false then HornetQ will only forward messages to other nodes of the cluster if the address to which they are being forwarded has queues which have consumers, and if those consumers have message filters (selectors) at least one of those selectors must match the message.

Default is false.

Discovery group name

This references the name of a discovery group defined in the core configuration. This discovery group is used to obtain the list of other servers in the cluster that this cluster connection will make connections to.

This property or static connectors must be provided (they are mutually exclusive).

Max hops

When a cluster connection decides the set of nodes to which it might load balance a message, those nodes do not have to be directly connected to it via a cluster connection. HornetQ can be configured to also load balance messages to nodes which might be connected to it only indirectly with other HornetQ servers as intermediates in a chain. This allows HornetQ to be configured in more complex topologies and still provide message load balancing.

Default is 1, which means messages are only load balanced to other HornetQ servers which are directly connected to this server.

Confirmation window size

This optional parameter determines the confirmation window size to use for the connection used to forward messages to the target node.

Warning When forwarding messages from a queue which has a max size bytes set, it's important that confirmation window size is less than or equal to max size bytes to prevent the flow of messages from ceasing.

Default is 1048576 (1 MiB).

Min large message size

The size (in bytes) before a message is treated as large. Large messages will be split up and sent in fragments.

Default is 102400 (100 KiB).

Be aware that you should not use values here that are bigger than the JMS server's journal buffer size, which is 501760 (490 KiB) by default.

Client failure check period

If the client does not receive any packets for client-failure-check-period milliseconds then it will consider the connection failed and will either initiate failover, or call any FailureListener instances (or ExceptionListener instances if you are using JMS) depending on how it has been configured.

If you're using JMS it's defined by the ClientFailureCheckPeriod attribute on a HornetQConnectionFactory instance, or if you're deploying JMS connection factory instances direct into JNDI on the server side, you can specify it in the core configuration, using the parameter client-failure-check-period.

The default value for client failure check period is 30000ms, i.e. 30 seconds. A value of -1 means the client will never fail the connection on the client side if no data is received from the server. Typically this is much lower than connection TTL to allow clients to reconnect in case of transitory failure.

Connection TTL

The time to live (in ms) for connections.

The TTL determines how long the server will keep a connection alive in the absence of any data arriving from the client. The client will automatically send "ping" packets periodically to prevent the server from closing it down. If the server doesn't receive any packets on a connection for the connection TTL time, then it will automatically close all the sessions on the server that relate to that connection.

Default is 60000 (1 minute).

Call timeout

The timeout (in ms) for remote calls.

Default is 30000 (30 seconds).

Call failover timeout

Similar to call timeout but used when a call is made during a failover attempt.

Default is -1 (no timeout).

Cluster notification interval

How often (in milliseconds) the cluster connection should broadcast itself when attaching to the cluster.

Default is 1000 (1 second).

Cluster notification attempts

How many times the cluster connection should broadcast itself when connecting to the cluster.

Default is 2.

← Qpid AMQP connector settingsXML validating filter →
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