Package com.adaptris.core.jms.sonic

Class LargeMessageConfig

    • Field Detail

      • DEFAULT_MONITOR_TIMEOUT_MS

        public static final long DEFAULT_MONITOR_TIMEOUT_MS
        The default monitor timeout.
        See Also:
        Constant Field Values

      • DEFAULT_RETRY_COUNT

        public static final int DEFAULT_RETRY_COUNT
        The default retry count.
        See Also:
        Constant Field Values

      • DEFAULT_RETRY_INTERVAL

        public static final long DEFAULT_RETRY_INTERVAL
        The default retry interval.
        See Also:
        Constant Field Values

      • DEFAULT_CHANNEL_TIMEOUT

        public static final int DEFAULT_CHANNEL_TIMEOUT
        the default channel timeout.
        See Also:
        Constant Field Values

      • log

        protected transient org.slf4j.Logger log

    • Constructor Detail

      • LargeMessageConfig

        public LargeMessageConfig()
        Standard constructor.

    • Method Detail

      • applyConfiguration

        protected abstract void applyConfiguration​(progress.message.jclient.Channel channel)
                                    throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException

      • applyBaseConfiguration

        protected void applyBaseConfiguration​(progress.message.jclient.Channel channel)
                               throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException

      • getLocalStoreDirectory

        protected java.io.File getLocalStoreDirectory()

      • getMonitorTimeoutMs

        public java.lang.Long getMonitorTimeoutMs()
        Returns:
        the monitorTimeoutMs

      • setMonitorTimeoutMs

        public void setMonitorTimeoutMs​(java.lang.Long l)
        The timeout to be used when monitoring completion of messages.
        Parameters:
        l - the monitorTimeoutMs to set

      • monitorTimeoutMs

        protected long monitorTimeoutMs()

      • getMoveJmsHeaders

        public java.lang.Boolean getMoveJmsHeaders()

        Returns true if JMS Headers (as well as JMS Properties) should be copied.

        Returns:
        true if JMS Headers (as well as JMS Properties) should be copied, otherwise false
        See Also:
        MetadataHandlerContext.moveJmsHeaders()

      • setMoveJmsHeaders

        public void setMoveJmsHeaders​(java.lang.Boolean b)

        Sets whether JMS Headers (as well as JMS Properties) should be copied.

        Parameters:
        b - true if JMS Headers (as well as JMS Properties) should be copied, otherwise false

      • getReportAllErrors

        public java.lang.Boolean getReportAllErrors()
        Returns:
        the reportAllErrors

      • setReportAllErrors

        public void setReportAllErrors​(java.lang.Boolean b)
        Report all non-critical errors with a stacktrace.

        When moving JMS Headers, it is possible depending on the vendor that some exceptions are thrown when attempting to get standard JMS headers. By default, these errors are simply logged without a stack-trace. If the full strack trace is required, then set this to be true.

        Parameters:
        b - the reportAllErrors to set

      • getRetryCount

        public java.lang.Integer getRetryCount()

        This method will retrieve the number of times this channel will retry sending a fragment of information.

        Returns:
        the number of times to retry.
        See Also:
        Channel.getRetryCount()

      • setRetryCount

        public void setRetryCount​(java.lang.Integer i)

        This method will set the number of times this channel will retry sending a fragment of information.

        Parameters:
        i - The number of times to retry.
        See Also:
        Channel.setRetryCount(int)

      • retryCount

        protected int retryCount()

      • getRetryInterval

        public java.lang.Long getRetryInterval()

        This will set the amount of time to wait before attempting to retrying to send or receive a piece of information.

        Returns:
        the interval between retry attempts in milliseconds
        See Also:
        Channel.getRetryInterval()

      • setRetryInterval

        public void setRetryInterval​(java.lang.Long i)

        Sets the interval between retry attempts in milliseconds. Producer only.

        Parameters:
        i - the interval between retry attempts in milliseconds
        See Also:
        Channel.setRetryInterval(long)

      • retryInterval

        protected long retryInterval()

      • getChannelTimeout

        public java.lang.Integer getChannelTimeout()

        Returns the channel timeout. The channel timeout is the period for which this classes waits for the channel to be acknowledged by the consumer and thus transfer to start.

        Returns:
        the channel timeout

      • setChannelTimeout

        public void setChannelTimeout​(java.lang.Integer i)

        Sets the channel timeout. The channel timeout is the period for which this classes waits for the channel to be acknowledged by the consumer and thus transfer to start.

        Parameters:
        i - the channel timeout

      • channelTimeout

        protected int channelTimeout()

      • logChannelInfo

        protected void logChannelInfo​(java.lang.String hdr,
                              progress.message.jclient.Channel c)
                       throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException